metering

type AccountWindowObservationPage struct {
	Observations []lipsdkmetering.Observation
	NextCursor   string
}

type AccountWindowProjection struct {
	Subject         lipsdkmetering.SubjectRef
	Measures        []lipsdkmetering.Measure
	ObservedAt      time.Time
	ReceivedAt      time.Time
	ObservationRefs []lipsdkmetering.ObservationRef
}

type AccountWindowProjectionPage struct {
	Projections []AccountWindowProjection
	NextCursor  string
}

type AccountWindowQuery struct {
	StoreID            string
	TenantID           string
	ProviderAccountKey string
	PoolID             string
	WindowID           string
	ResetAt            *time.Time
	AsOf               time.Time
	Limit              int
	Cursor             string
}

type AccountWindowStore interface {
	ListAccountWindowObservations(context.Context, AccountWindowQuery) (AccountWindowObservationPage, error)
	ProjectAccountWindows(context.Context, AccountWindowQuery) (AccountWindowProjectionPage, error)
}

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

type BoundaryConfig struct {
	MaxTextBytes    int
	MaxMediaEntries int
}

type BoundarySnapshot struct {
	Input          PreparedInputSnapshot
	ProviderOutput OutputSnapshot
	CustomerOutput OutputSnapshot
}

type ClosedBLegReader interface {
	GetCallLegUsage(context.Context, string) (corebilling.CallLegUsageRecord, error)
}

type EconomicObservationSink interface {
	sdkmetering.ObservationSink
	AppendEconomicObservationWithOutbox(context.Context, sdkmetering.Observation) error
}

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

type LateEconomicAppenderConfig struct {
	StoreID string
	Legs    ClosedBLegReader
	// Sink remains compatibility-typed for composition boundaries; the
	// constructor rejects it unless its dynamic implementation exposes the
	// consumer-owned EconomicObservationSink capability.
	Sink     sdkmetering.ObservationSink
	Resolver ObservationResolver
}

type LateEconomicEvidence struct {
	Kind        LateEconomicEvidenceKind
	Identity    LateEconomicIdentity
	Observation sdkmetering.Observation
}

type LateEconomicEvidenceKind string

type LateEconomicIdentity struct {
	StoreID            string
	BillingCallID      corebilling.BillingCallID
	ALegID             string
	BLegID             string
	AttemptID          string
	AttemptSeq         uint64
	ProviderID         string
	ProviderAccountKey string
	ProviderRequestID  string
	ProviderChargeID   string
}

type MediaKind string

type MediaSummary struct {
	Kind            MediaKind
	Count           int64
	Bytes           int64
	BytesPresent    bool
	DurationMillis  int64
	DurationPresent bool
	Frames          int64
	FramesPresent   bool
	Pages           int64
	PagesPresent    bool
	WidthPixels     int64
	WidthPresent    bool
	HeightPixels    int64
	HeightPresent   bool
	MIME            string
}

type ObservationIdentity struct {
	StoreID       string
	RequestID     string
	CallID        string
	BillingCallID string
	ALegID        string
	BLegID        string
	AttemptID     string
	AttemptSeq    uint64
	Scope         scope.PrincipalScopeView
	ObservedAt    time.Time
	ReceivedAt    time.Time
}

type ObservationResolver interface {
	GetObservation(context.Context, string, uint64) (sdkmetering.Observation, error)
}

type OutputSnapshot struct {
	TextBytes           int64
	TextBytesPresent    bool
	TextTokens          int64
	TextTokensPresent   bool
	TextTokensEstimated bool
	TextTruncated       bool
	Media               []MediaSummary
	MediaTruncated      bool
	Truncated           bool
}

type PreparedInputObserver func(PreparedInputSummary)

type PreparedInputSnapshot struct {
	Prepared            bool
	Attempted           bool
	Accepted            bool
	AcceptedKnown       bool
	AdapterProvided     bool
	TextBytes           int64
	TextBytesPresent    bool
	PayloadBytes        int64
	PayloadBytesPresent bool
	TextTokens          int64
	TextTokensPresent   bool
	TextTokensEstimated bool
	TextTruncated       bool
	Media               []MediaSummary
	MediaTruncated      bool
	Truncated           bool
	MethodRef           string
}

type PreparedInputSummary struct {
	TextBytes           int64
	TextBytesPresent    bool
	PayloadBytes        int64
	PayloadBytesPresent bool
	TextTokens          int64
	TextTokensPresent   bool
	TextTokensEstimated bool
	Media               []MediaSummary
	TextTruncated       bool
	MediaTruncated      bool
	Truncated           bool
	MethodRef           string
}

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

type ProviderDebitSnapshot struct {
	Measures     []aggregate.ReducedMeasure
	Observations []sdkmetering.Observation
	Complete     bool
	Replayed     int
}

type ProviderEvidenceBinder interface {
	BindEconomicEvidence(ObservationIdentity)
}

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

type ProviderEvidenceDraft struct {
	SourceEventKey string
	// Revision is a host-assigned observation revision. A caller/provider
	// supplied source revision is NOT a supported capability: Add rejects any
	// non-zero Revision as an explicit unsupported-ordering-identity loss and
	// never drains the payload as provider evidence. This is an enforceable
	// boundary, not a TODO: the SDK observation cannot carry source-vs-host
	// revision provenance, so a late older explicit revision would be
	// observationally identical to a valid cumulative/delta update and could
	// duplicate a charge. The buffer assigns the revision instead.
	Revision uint64
	StreamID string
	// Sequence is a host-assigned lifetime receipt ordinal. A caller/provider
	// supplied non-zero Sequence is part of the same unsupported ordering
	// identity and is rejected at Add with the same loss disposition; the buffer
	// assigns the sequence.
	Sequence           uint64
	Origin             string
	Acquisition        string
	Authority          string
	Perspective        lipsdkmetering.EconomicPerspective
	Boundary           lipsdkmetering.Boundary
	Lifecycle          lipsdkmetering.LifecycleScope
	Semantics          string
	ProviderAccountKey string
	ProviderRequestID  string
	ProviderChargeID   string
	Measures           []lipsdkmetering.Measure
	Charges            []lipsdkmetering.ReportedCharge
	Supersedes         []lipsdkmetering.ObservationRef
	Evidence           []lipsdkmetering.SafeEvidenceField
	ObservedAt         time.Time
	ReceivedAt         time.Time
	Coverage           string
	CoverageReason     string
}