types

Documentation

Index

• type Executable
• type Payload
  • func NewPayload(ctx context.Context, job Executable, args any) *Payload
  • func (p Payload) Execute()
• type Resultor
  • func (r *Resultor) Error() error
  • func (r *Resultor) Result() any

Types

type Executable

type Executable interface {
	Execute(context.Context, any) (any, error)
}

type Payload

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

Payload encapsulates a job and its input into a neat package to be executed by another thread.

func NewPayload

func NewPayload(ctx context.Context, job Executable, args any) *Payload

NewPayload creates a new payload to send to a worker.

func (Payload) Execute

func (p Payload) Execute()

Execute executes the job and returns the result.

type Resultor

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

Result encapsulates the result of a job execution.

func (*Resultor) Error

func (r *Resultor) Error() error

Error returns the error of the job execution.

func (*Resultor) Result

func (r *Resultor) Result() any

Result returns the result of the job execution.