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 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 Options

type Options struct {
	SystemEventsTopic string

	Entitlement *registry.Entitlement
	Router      router.Options

	Marshaler marshaler.Marshaler

	Logger *slog.Logger
}