mrworker

Documentation

Index

• type Job
• type JobFunc
  • func (f JobFunc) Do(ctx context.Context) error
• type MessageBatchHandler
• type MessageConsumer
• type MessageHandler
• type Task

Types

type Job

type Job interface {
	Do(ctx context.Context) error
}

Job - некоторая работа, которая должна быть выполнена.

type JobFunc

type JobFunc func(ctx context.Context) error

JobFunc - обёртка для возможности представления анонимной функции в виде Job интерфейса.

func (JobFunc) Do

func (f JobFunc) Do(ctx context.Context) error

Do - запускает анонимную функцию в Job интерфейсе.

type MessageBatchHandler

type MessageBatchHandler interface {
	Execute(ctx context.Context, messages [][]byte) error
}

MessageBatchHandler - обработчик списка сообщений.

type MessageConsumer

type MessageConsumer interface {
	ReadMessages(ctx context.Context, limit int) (messages []any, err error)
	CancelMessages(ctx context.Context, messages []any) error
	CommitMessage(ctx context.Context, message any, preCommit func(ctx context.Context) error) error
	RejectMessage(ctx context.Context, message any, causeErr error) error
}

MessageConsumer - получатель сообщений с возможностью подтверждения их получения.

type MessageHandler

type MessageHandler interface {
	Execute(ctx context.Context, message any) (commit func(ctx context.Context) error, err error)
}

MessageHandler - обработчик сообщений с закреплением результата.

type Task

type Task interface {
	Caption() string
	Startup() bool
	Period() time.Duration
	Timeout() time.Duration
	SignalDo() <-chan struct{}
	Job
}

Task - задача исполняемая планировщиком задач.