Versions in this module Expand all Collapse all v0 v0.1.1 Apr 20, 2023 v0.1.0 Feb 10, 2023 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
Go to main page