usage

type Config struct {
	WorkerID         string
	Endpoint         string
	Token            string
	HTTPClient       *http.Client
	Logger           *slog.Logger
	Observer         UsageObserver
	LeaseDuration    time.Duration
	OperationTimeout time.Duration
	PollInterval     time.Duration
	RetryInterval    time.Duration
}

type Store interface {
	MarkExpiredIngressUsageRunsIncomplete(context.Context, time.Time) (int, error)
	FinalizePublicURLUsageBuckets(context.Context, time.Time, time.Time) (int, error)
	ClaimPublicURLUsageDeliveries(context.Context, string, int, time.Time, time.Duration) ([]controlstate.PublicURLUsageDeliveryWork, error)
	CompletePublicURLUsageDelivery(context.Context, controlstate.PublicURLUsageDeliveryWork, time.Time) error
	RetryPublicURLUsageDelivery(context.Context, controlstate.PublicURLUsageDeliveryWork, time.Time, string, time.Time) error
	RejectPublicURLUsageDelivery(context.Context, controlstate.PublicURLUsageDeliveryWork, string, time.Time) error
}

type UsageObserver interface {
	ObserveUsageWork(phase string, outcome observability.UsageWorkOutcome)
	AddUsageItems(result string, count int)
	ObserveUsageReceiver(outcome observability.UsageReceiverOutcome, elapsed time.Duration)
}

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