queueutils

Documentation

Index

• func BatchConcurrent[T any](batchSize int, things []T, fn func(group []T) error) error
• func BatchLinear[T any](batchSize int, things []T, fn func(group []T) error) error
• type OpMethod
• type OperationPool
  • func NewOperationPool(ql *zerolog.Logger, timeout time.Duration, description string, method OpMethod) *OperationPool
  • func (p *OperationPool) GetOperation(id string) *SerialOperation
  • func (p *OperationPool) RunOrContinue(id string)
  • func (p *OperationPool) SetTenants(tenants []*dbsqlc.Tenant)
• type SerialOperation
  • func (o *SerialOperation) Run(ql *zerolog.Logger)
  • func (o *SerialOperation) RunOrContinue(ql *zerolog.Logger)

Functions

func BatchConcurrent

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

func BatchLinear

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

Types

type OpMethod

type OpMethod func(ctx context.Context, id string) (bool, error)

type OperationPool

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

func NewOperationPool

func NewOperationPool(ql *zerolog.Logger, timeout time.Duration, description string, method OpMethod) *OperationPool

func (*OperationPool) GetOperation

func (p *OperationPool) GetOperation(id string) *SerialOperation

func (*OperationPool) RunOrContinue

func (p *OperationPool) RunOrContinue(id string)

func (*OperationPool) SetTenants

func (p *OperationPool) SetTenants(tenants []*dbsqlc.Tenant)

type SerialOperation

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

SerialOperation represents a method that can only run serially.

func (*SerialOperation) Run

func (o *SerialOperation) Run(ql *zerolog.Logger)

func (*SerialOperation) RunOrContinue

func (o *SerialOperation) RunOrContinue(ql *zerolog.Logger)