hsynq

Documentation

Index

• func NewJobs(cli *asynq.Client, p hexa.ContextPropagator, t Transformer) hjob.Jobs
• func NewWorker(s *asynq.Server, p hexa.ContextPropagator, t Transformer) hjob.Worker
• type Headers
• type JsonJob
• type Transformer
  • func NewJsonTransformer() Transformer
• type UnmarshalJsonJob

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 Headers

type Headers map[string][]byte

Headers are job headers that we can set on each task.

type JsonJob

type JsonJob struct {
	Headers map[string][]byte
	Payload interface{} `json:"payload"`
}

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"`
}