worker

Documentation

Index

• type Message
  • func NewMessage(ctx context.Context, t string, payload any) (Message, error)
  • func (m *Message) Retry()
  • func (m *Message) SetCaller(caller string)

Types

type Message

type Message struct {
	// ID is the unique identifier of the job
	ID uuid.UUID `json:"id" validate:"required,uuid"`

	// Type is the type of the job. It should be the value of job.Type.String
	Type string `json:"type" validate:"required"`

	// Payload is the data to be passed to the job
	Payload string `json:"payload" validate:"-"`

	// RetryCount is the number of times the job has been retried
	RetryCount int `json:"retry_count" validate:"-"`

	// Caller is the information about the caller of the job
	Caller string `json:"caller" validate:"required"`

	// CreatedAt is the time the job was created
	CreatedAt time.Time `json:"created_at" validate:"required"`
}

func NewMessage

func NewMessage(ctx context.Context, t string, payload any) (Message, error)

NewMessage creates a new Message

func (*Message) Retry

func (m *Message) Retry()

Retry increments the RetryCount of the job

func (*Message) SetCaller

func (m *Message) SetCaller(caller string)

SetCaller sets the Caller of the job