consumer

package

v1.0.0-beta.225 Latest Latest Go to latest Published: Nov 10, 2025 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation ¶

Index ¶

Variables
type BalanceEventDedupHash
- func NewBalanceEventDedupHash(snapshot snapshot.SnapshotEvent, ruleID string, ...) (*BalanceEventDedupHash, error)
- func (d BalanceEventDedupHash) V1() string
- func (d BalanceEventDedupHash) V2() string
type Consumer
- func New(opts Options) (*Consumer, error)
type EntitlementSnapshotHandler
- func (b *EntitlementSnapshotHandler) Handle(ctx context.Context, event snapshot.SnapshotEvent) error
type EntitlementSnapshotHandlerState
type InvoiceEventHandler
- func (h *InvoiceEventHandler) Handle(ctx context.Context, event billing.EventInvoice, ...) error
type Options
- func (o Options) Validate() error
type ThresholdKind

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

Types ¶

type BalanceEventDedupHash ¶

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

func NewBalanceEventDedupHash ¶

func NewBalanceEventDedupHash(snapshot snapshot.SnapshotEvent, ruleID string, threshold notification.BalanceThreshold) (*BalanceEventDedupHash, error)

func (BalanceEventDedupHash) V1 ¶

func (d BalanceEventDedupHash) V1() string

func (BalanceEventDedupHash) V2 ¶

func (d BalanceEventDedupHash) V2() string

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 EntitlementSnapshotHandler ¶

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

func (*EntitlementSnapshotHandler) Handle ¶

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

type EntitlementSnapshotHandlerState ¶

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

type InvoiceEventHandler ¶

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

func (*InvoiceEventHandler) Handle ¶

func (h *InvoiceEventHandler) Handle(ctx context.Context, event billing.EventInvoice, eventType notification.EventType) error

type Options ¶

type Options struct {
	SystemEventsTopic string

	Router router.Options

	Notification notification.Service

	Marshaler marshaler.Marshaler

	Logger *slog.Logger
}

func (Options) Validate ¶

func (o Options) Validate() error

type ThresholdKind ¶

type ThresholdKind string

const (
	ThresholdKindUsageThreshold   ThresholdKind = "usage"
	ThresholdKindBalanceThreshold ThresholdKind = "balance"
)

Source Files ¶

View all Source files

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