jobs

Documentation

Index

• func MakeBatched[T any](batchSize int, things []T, fn func(group []T) error) error
• type JobsController
• type JobsControllerImpl
  • func New(fs ...JobsControllerOpt) (*JobsControllerImpl, error)
  • func (jc *JobsControllerImpl) Start() (func() error, error)
• type JobsControllerOpt
  • func WithAlerter(a hatcheterrors.Alerter) JobsControllerOpt
  • func WithDataDecoderValidator(dv datautils.DataDecoderValidator) JobsControllerOpt
  • func WithLogger(l *zerolog.Logger) JobsControllerOpt
  • func WithMessageQueue(mq msgqueue.MessageQueue) JobsControllerOpt
  • func WithPartitionId(pid string) JobsControllerOpt
  • func WithRepository(r repository.EngineRepository) JobsControllerOpt
• type JobsControllerOpts
• type Partition
  • func NewPartition(mq msgqueue.MessageQueue, l *zerolog.Logger, repo repository.EngineRepository, ...) (*Partition, error)
  • func (p *Partition) Start() (func() error, error)

Functions

func MakeBatched

func MakeBatched[T any](batchSize int, things []T, fn func(group []T) error) error

Types

type JobsController

type JobsController interface {
	Start(ctx context.Context) error
}

type JobsControllerImpl

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

func New

func New(fs ...JobsControllerOpt) (*JobsControllerImpl, error)

func (*JobsControllerImpl) Start

func (jc *JobsControllerImpl) Start() (func() error, error)

type JobsControllerOpt

type JobsControllerOpt func(*JobsControllerOpts)

func WithAlerter

func WithAlerter(a hatcheterrors.Alerter) JobsControllerOpt

func WithDataDecoderValidator

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) JobsControllerOpt

func WithLogger

func WithLogger(l *zerolog.Logger) JobsControllerOpt

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) JobsControllerOpt

func WithPartitionId

func WithPartitionId(pid string) JobsControllerOpt

func WithRepository

func WithRepository(r repository.EngineRepository) JobsControllerOpt

type JobsControllerOpts

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

type Partition

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

func NewPartition

func NewPartition(
	mq msgqueue.MessageQueue,
	l *zerolog.Logger,
	repo repository.EngineRepository,
	dv datautils.DataDecoderValidator,
	a *hatcheterrors.Wrapped,
	partitionId string,
) (*Partition, error)

func (*Partition) Start

func (p *Partition) Start() (func() error, error)