trafficusage

package

v1.21.6 Latest Latest Go to latest Published: Nov 10, 2026 License: GPL-3.0 Imports: 3 Imported by: 0

Details

Package trafficusage owns idempotent subscription usage accounting.

View Source

const BucketConsumer = "subscription.traffic_bucket"

BucketConsumer is persisted in the inbox; changing it replays old usage.

This section is empty.

This section is empty.

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

func New(store Store) *Service

func (s *Service) ApplyBucketOnce(ctx context.Context, bucket string, deltas []traffic.SubscribeTrafficDelta) error

ApplyBucketOnce commits usage and its inbox marker together. Network log retries can replay this operation without charging usage again.

type Store interface {
	Inbox() repository.InboxRepo
	InSubscriptionTx(context.Context, func(repository.SubscriptionStore) error) error
}