consumer

Documentation

Index

• type Consumer
  • func New(opts Options) (*Consumer, error)
  • func (w *Consumer) Close() error
  • func (w *Consumer) Run(ctx context.Context) error
• type DLQOptions
• type Options

Types

type Consumer

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

func New

func New(opts Options) (*Consumer, error)

func (*Consumer) Close

func (w *Consumer) Close() error

func (*Consumer) Run

func (w *Consumer) Run(ctx context.Context) error

type DLQOptions

type DLQOptions struct {
	Topic            string
	Throttle         bool
	ThrottleDuration time.Duration
	ThrottleCount    int64
}

type Options

type Options struct {
	SystemEventsTopic string
	Subscriber        message.Subscriber

	Publisher message.Publisher

	DLQ *DLQOptions

	Entitlement *registry.Entitlement

	Logger *slog.Logger
}