runner

Documentation

Index

• type DispatchStrategy
• type Runner
  • func NewSqsRunner(handler types.HandleMessage[awstypes.Message], batchSize int, ...) Runner
• type SqsRunner
  • func (r *SqsRunner) Run(ctx context.Context)
  • func (w *SqsRunner) Stop(ctx context.Context)

Types

type DispatchStrategy

type DispatchStrategy int

const (
	SemPool DispatchStrategy = iota + 1
	WorkerPool
)

type Runner

type Runner interface {
	Run(context.Context)
	Stop(context.Context)
}

func NewSqsRunner

func NewSqsRunner(
	handler types.HandleMessage[awstypes.Message],
	batchSize int,
	batchInterval time.Duration,
	client service.Sqs,
	queueUrl string,
	concurrency int,
	visibilityTimeout int,
	maxMessages int,
	queueAttributeNames []string,
	maxIdleTime int,
	dispatchStrategy DispatchStrategy,
) Runner

type SqsRunner

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

func (*SqsRunner) Run

func (r *SqsRunner) Run(ctx context.Context)

func (*SqsRunner) Stop

func (w *SqsRunner) Stop(ctx context.Context)