usage

Jun 12, 2026

Changes in this version

+ const MaxTagKeyLen

+ func TagGroupKey(g string) (string, bool)

type Event

+ CostBreakdown map[string]int64

+ CostNanos *int64

+ Host string

+ Model string

+ Policy string

+ Pricing string

+ Provider string

+ Tags map[string]string

+ func (e Event) LogOnly() bool

type EventQuery

+ Host []string

+ Model []string

+ Policy []string

+ Provider []string

+ Tags map[string][]string

type SummaryRow

+ CostNanos int64

+ TTFTMs *DurationStats

+ Unpriced int64

type TimeSeriesPoint

+ CostNanos int64

+ DurationMs DurationStats

+ Errors4xx int64

+ Errors5xx int64

+ TTFTMs *DurationStats

+ Unpriced int64

Jun 2, 2026

Changes in this version

+ const DefaultEventLimit

+ const MaxBuckets

+ const MaxEventLimit

+ var ValidGroupBy = []string

+ func IsValidGroupBy(g string) bool

+ func SortTimeSeriesRows(rows []TimeSeriesRow, totals map[string]int64, groupBy string)

+ type Closer interface

+ Close func() error

+ type DurationStats struct

+ Avg int64

+ Max int64

+ P50 int64

+ P95 int64

+ P99 int64

+ type Event struct

+ Attempts int

+ DurationMs int64

+ ErrorKind string

+ ErrorMessage string

+ Extras map[string]string

+ FinishReason string

+ HostID string

+ HostKeyID string

+ ModelID string

+ PolicyID string

+ Reasoning *sdkusage.ReasoningTiming

+ RelayKeyHash string

+ RequestID string

+ RequestedModel string

+ Source string

+ Status int

+ Streamed bool

+ Timestamp time.Time

+ Tokens sdkusage.Tokens

+ Upstream *sdkusage.UpstreamTiming

+ func FilterEvents(events []Event, q EventQuery) []Event

+ func SortAndLimit(events []Event, limit int) []Event

+ type EventQuery struct

+ AttemptsMin int

+ CursorID string

+ CursorTS time.Time

+ DurationMsMax int64

+ DurationMsMin int64

+ ErrorKind []string

+ ErrorsOnly *bool

+ FinishReason []string

+ From time.Time

+ HostID []string

+ HostKeyID []string

+ Limit int

+ ModelID []string

+ PolicyID []string

+ Q string

+ RelayKeyHash []string

+ RequestID string

+ RequestedModel []string

+ Since time.Duration

+ Source []string

+ Status []int

+ StatusMax int

+ StatusMin int

+ Streamed *bool

+ TTFTMsMax int64

+ TTFTMsMin int64

+ To time.Time

+ type Reader interface

+ Events func(ctx context.Context, q EventQuery) ([]Event, error)

+ Summary func(ctx context.Context, q SummaryQuery) (SummaryResult, error)

+ TimeSeries func(ctx context.Context, q TimeSeriesQuery) (TimeSeriesResult, error)

+ type Sink interface

+ Write func(ev Event) error

+ type SummaryQuery struct

+ GroupBy string

+ type SummaryResult struct

+ From time.Time

+ Rows []SummaryRow

+ To time.Time

+ func Summarize(events []Event, groupBy string) (SummaryResult, error)

+ type SummaryRow struct

+ DurationMs DurationStats

+ ErrorCount int64

+ FirstSeen time.Time

+ Group map[string]string

+ LastSeen time.Time

+ Requests int64

+ Tokens map[string]int64

+ type TimeSeriesPoint struct

+ Bucket time.Time

+ ErrorCount int64

+ Requests int64

+ Tokens map[string]int64

+ type TimeSeriesQuery struct

+ GroupBy string

+ Interval time.Duration

+ type TimeSeriesResult struct

+ From time.Time

+ Interval string

+ Rows []TimeSeriesRow

+ To time.Time

+ func Bucketize(events []Event, interval time.Duration, groupBy string) (TimeSeriesResult, error)

+ type TimeSeriesRow struct

+ Group map[string]string

+ Points []TimeSeriesPoint