protocol

Jul 2, 2022

Changes in this version

+ const MimeJSON

+ const V1

+ const V2

+ type JSONSerializer struct

+ func NewJSONSerializer() *JSONSerializer

+ func (ser *JSONSerializer) Decode(p int, s string, t *Task) error

+ func (ser *JSONSerializer) Encode(p int, t *Task) (s string, err error)

+ type Serializer interface

+ Decode func(p int, s string, t *Task) error

+ Encode func(p int, t *Task) (s string, err error)

+ type SerializerRegistry struct

+ func NewSerializerRegistry() *SerializerRegistry

+ func (r *SerializerRegistry) Decode(raw []byte) (*Task, error)

+ func (r *SerializerRegistry) Encode(queue, mime string, prot int, t *Task) ([]byte, error)

+ func (r *SerializerRegistry) Register(serializer Serializer, mime, encoding string)

+ type Task struct

+ Args []interface{}

+ Expires time.Time

+ ID string

+ Kwargs map[string]interface{}

+ Name string

+ func (t *Task) IsExpired() bool