Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func New ¶
func New(opts WorkerOptions) (*Worker, error)
func (*Worker) AddHandler ¶
func (w *Worker) AddHandler(handler grouphandler.GroupEventHandler)
AddHandler adds an additional handler to the list of event handlers. Handlers are called in the order they are added and run after the built in handlers. In the case of any handler returning an error, the event will be retried so it is important that all handlers are idempotent.
type WorkerOptions ¶
type WorkerOptions struct {
SystemEventsTopic string
Router router.Options
EventBus eventbus.Publisher
Logger *slog.Logger
BillingService billing.Service
BillingSubscriptionSync subscriptionsync.Service
// ChargesService is optional; when non-nil the worker handles AdvanceChargesEvent.
ChargesService charges.ChargeService
SubscriptionService subscription.Service
LockdownNamespaces []string
}
func (WorkerOptions) Validate ¶
func (w WorkerOptions) Validate() error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.