consumer

Documentation

Index

• Variables
• type BalanceThresholdEventHandler
  • func (b *BalanceThresholdEventHandler) Handle(ctx context.Context, event snapshot.SnapshotEvent) error
• type BalanceThresholdEventHandlerState
• type Consumer
  • func New(opts Options) (*Consumer, error)
  • func (c *Consumer) Close() error
  • func (c *Consumer) Handle(ctx context.Context, event snapshot.SnapshotEvent) error
  • func (c *Consumer) Run(ctx context.Context) error
• type Options

Variables

var ErrNoBalanceAvailable = errors.New("no balance available")

Types

type BalanceThresholdEventHandler

type BalanceThresholdEventHandler struct {
	Notification notification.Service
	Logger       *slog.Logger
}

func (*BalanceThresholdEventHandler) Handle

func (b *BalanceThresholdEventHandler) Handle(ctx context.Context, event snapshot.SnapshotEvent) error

type BalanceThresholdEventHandlerState

type BalanceThresholdEventHandlerState struct {
	TotalGrants float64 `json:"totalGrants"`
}

type Consumer

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

func New

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

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Handle

func (c *Consumer) Handle(ctx context.Context, event snapshot.SnapshotEvent) error

func (*Consumer) Run

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

type Options

type Options struct {
	SystemEventsTopic string

	Router router.Options

	Notification notification.Service

	Marshaler marshaler.Marshaler

	Logger *slog.Logger
}