Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewJobs ¶
func NewJobs(cli *asynq.Client, p hexa.ContextPropagator, t Transformer) hjob.Jobs
func NewWorker ¶
func NewWorker(s *asynq.Server, p hexa.ContextPropagator, t Transformer) hjob.Worker
Types ¶
type Transformer ¶
type Transformer interface { BytesFromJob(headers Headers, payload interface{}) ([]byte, error) PayloadFromBytes(b []byte) (Headers, hjob.Payload, error) }
Transformer transforms job to bytes and convert bytes to hexa context and job payloads again.
func NewJsonTransformer ¶
func NewJsonTransformer() Transformer
type UnmarshalJsonJob ¶
type UnmarshalJsonJob struct { Headers map[string][]byte Payload json.RawMessage `json:"payload"` }
Click to show internal directories.
Click to hide internal directories.