consumer

package

v1.0.0-beta.204 Latest Latest Go to latest Published: Mar 21, 2025 License: Apache-2.0 Imports: 26 Imported by: 0

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL