consumer

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

type Options struct {
	SystemEventsTopic string
	Subscriber        message.Subscriber

	Publisher message.Publisher

	PoisonQueue *PoisonQueueOptions

	Entitlement *registry.Entitlement

	Logger *slog.Logger
}

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