[GH-ISSUE #873] [FEATURE REQUEST] customize serializer #430

New issue

Open

opened 2026-03-02 05:21:09 +03:00 by kerem · 0 comments

kerem commented

2026-03-02 05:21:09 +03:00

Owner

Originally created by @cold-bin on GitHub (Apr 29, 2024).
Original GitHub issue: https://github.com/hibiken/asynq/issues/873

Originally assigned to: @hibiken on GitHub.

Is your feature request related to a problem? Please describe.
I want to customize serializer, need a defined interface in order to better readability or better performance

// EncodeSchedulerEnqueueEvent marshals the given event
// and returns an encoded bytes.
func EncodeSchedulerEnqueueEvent(event *SchedulerEnqueueEvent) ([]byte, error) {
	if event == nil {
		return nil, fmt.Errorf("cannot encode nil enqueue event")
	}
	enqueuedAt, err := ptypes.TimestampProto(event.EnqueuedAt)
	if err != nil {
		return nil, err
	}
	return proto.Marshal(&pb.SchedulerEnqueueEvent{
		TaskId:      event.TaskID,
		EnqueueTime: enqueuedAt,
	})
}

Describe the solution you'd like

type Serializer interface{
  func Marshal(v any) ([]byte, error)
  func Unmarshal(data []byte, v any) error
}

so that, I can write my serializer.

Originally created by @cold-bin on GitHub (Apr 29, 2024). Original GitHub issue: https://github.com/hibiken/asynq/issues/873 Originally assigned to: @hibiken on GitHub. **Is your feature request related to a problem? Please describe.** I want to customize serializer, need a defined interface in order to better readability or better performance ```go // EncodeSchedulerEnqueueEvent marshals the given event // and returns an encoded bytes. func EncodeSchedulerEnqueueEvent(event *SchedulerEnqueueEvent) ([]byte, error) { if event == nil { return nil, fmt.Errorf("cannot encode nil enqueue event") } enqueuedAt, err := ptypes.TimestampProto(event.EnqueuedAt) if err != nil { return nil, err } return proto.Marshal(&pb.SchedulerEnqueueEvent{ TaskId: event.TaskID, EnqueueTime: enqueuedAt, }) } ``` **Describe the solution you'd like** ```go type Serializer interface{ func Marshal(v any) ([]byte, error) func Unmarshal(data []byte, v any) error } ``` so that, I can write my serializer.