hsynq

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 6, 2022 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewJobs

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL