jobs

type CompletionIDs struct {
	// contains filtered or unexported fields
}

type HandlerRegistration struct {
	HandlerType reflect.Type
	Method      reflect.Value
}

type JobOptions struct {
	RunAt        time.Time
	Queue        string
	Untransacted bool
	Priority     gue.JobPriority
}

type LoadSaveFunc = func(ctx context.Context, body *json.RawMessage) (interface{}, error)

type MessageContext struct {
	// contains filtered or unexported fields
}

type MessageHandler interface {
	Handle(ctx context.Context, message interface{}) error
}

type MessagePublisher interface {
	Publish(ctx context.Context, message interface{}, options ...PublishOption) error
}

type PublishOption func(*TransportMessage, *JobOptions) error

type QueMessagePublisher struct {
	// contains filtered or unexported fields
}

type QueueDef struct {
	Name string
}

type Saga struct {
	ID          SagaID
	CreatedAt   time.Time
	UpdatedAt   time.Time
	ScheduledAt *time.Time
	Version     int
	Tags        map[string][]string
	Type        string
	Body        *json.RawMessage
}

type SagaID string

type SagaOption func(*Saga)

type SagaRepository struct {
	// contains filtered or unexported fields
}

type TransportMessage struct {
	Id      string              `json:"id"`
	Package string              `json:"package"`
	Type    string              `json:"type"`
	Trace   []string            `json:"trace"`
	Tags    map[string][]string `json:"tags"`
	Body    *json.RawMessage    `json:"body"`
}