usagev1

type GetUsageByMetaRequest struct {

	// Meta key to filter on (required, e.g. "job_id")
	MetaKey string `protobuf:"bytes,1,opt,name=meta_key,json=metaKey,proto3" json:"meta_key,omitempty"`
	// Meta value to filter on (required, e.g. the job UUID)
	MetaValue string `protobuf:"bytes,2,opt,name=meta_value,json=metaValue,proto3" json:"meta_value,omitempty"`
	// Optional second meta key to split rows by (e.g. "task_id");
	// events without it aggregate under an empty group_value.
	GroupByMetaKey string `protobuf:"bytes,3,opt,name=group_by_meta_key,json=groupByMetaKey,proto3" json:"group_by_meta_key,omitempty"`
	// Optional project filter
	ProjectId string `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

type GetUsageByMetaResponse struct {
	Rows      []*UsageByMetaRow `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Truncated bool              `protobuf:"varint,2,opt,name=truncated,proto3" json:"truncated,omitempty"`
	// contains filtered or unexported fields
}

type GetUsageSummaryRequest struct {

	// Start of time range (inclusive)
	From *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// End of time range (exclusive)
	To *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// Optional filters
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	UserId    string `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Vendor    string `protobuf:"bytes,5,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Model     string `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	ActionId  string `protobuf:"bytes,7,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	Status    Status `protobuf:"varint,8,opt,name=status,proto3,enum=usage.v1.Status" json:"status,omitempty"`
	// Group by dimensions (day is always included)
	GroupByProjectId bool `protobuf:"varint,10,opt,name=group_by_project_id,json=groupByProjectId,proto3" json:"group_by_project_id,omitempty"`
	GroupByUserId    bool `protobuf:"varint,11,opt,name=group_by_user_id,json=groupByUserId,proto3" json:"group_by_user_id,omitempty"`
	GroupByVendor    bool `protobuf:"varint,12,opt,name=group_by_vendor,json=groupByVendor,proto3" json:"group_by_vendor,omitempty"`
	GroupByModel     bool `protobuf:"varint,13,opt,name=group_by_model,json=groupByModel,proto3" json:"group_by_model,omitempty"`
	GroupByActionId  bool `protobuf:"varint,14,opt,name=group_by_action_id,json=groupByActionId,proto3" json:"group_by_action_id,omitempty"`
	GroupByStatus    bool `protobuf:"varint,15,opt,name=group_by_status,json=groupByStatus,proto3" json:"group_by_status,omitempty"`
	// contains filtered or unexported fields
}

type GetUsageSummaryResponse struct {
	Rows      []*UsageSummaryRow `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Truncated bool               `protobuf:"varint,2,opt,name=truncated,proto3" json:"truncated,omitempty"`
	// contains filtered or unexported fields
}

type RecordUsageEventRequest struct {
	Event *UsageEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type RecordUsageEventResponse struct {

	// Whether the event was newly created (false if duplicate event_id)
	Created bool `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

type RecordUsageEventsRequest struct {

	// Maximum 500 events per batch
	Events []*UsageEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type RecordUsageEventsResponse struct {

	// Number of events that were newly created
	CreatedCount int32 `protobuf:"varint,1,opt,name=created_count,json=createdCount,proto3" json:"created_count,omitempty"`
	// Number of events that were duplicates (already existed)
	DuplicateCount int32 `protobuf:"varint,2,opt,name=duplicate_count,json=duplicateCount,proto3" json:"duplicate_count,omitempty"`
	// contains filtered or unexported fields
}

type Status int32

type UnimplementedUsageServiceServer struct{}

type UnsafeUsageServiceServer interface {
	// contains filtered or unexported methods
}

type UsageByMetaRow struct {

	// Value of group_by_meta_key ("" when the key is absent or not requested)
	GroupValue   string `protobuf:"bytes,1,opt,name=group_value,json=groupValue,proto3" json:"group_value,omitempty"`
	Vendor       string `protobuf:"bytes,2,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Model        string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	TokensInput  int64  `protobuf:"varint,4,opt,name=tokens_input,json=tokensInput,proto3" json:"tokens_input,omitempty"`
	TokensOutput int64  `protobuf:"varint,5,opt,name=tokens_output,json=tokensOutput,proto3" json:"tokens_output,omitempty"`
	TokensTotal  int64  `protobuf:"varint,6,opt,name=tokens_total,json=tokensTotal,proto3" json:"tokens_total,omitempty"`
	RequestCount int64  `protobuf:"varint,7,opt,name=request_count,json=requestCount,proto3" json:"request_count,omitempty"`
	// Summed cost in nano-USD (1e-9 USD)
	CostNanousd int64 `protobuf:"varint,8,opt,name=cost_nanousd,json=costNanousd,proto3" json:"cost_nanousd,omitempty"`
	// Summed parts of tokens_input read from and written to the prompt cache
	CacheReadTokens  int64 `protobuf:"varint,9,opt,name=cache_read_tokens,json=cacheReadTokens,proto3" json:"cache_read_tokens,omitempty"`
	CacheWriteTokens int64 `protobuf:"varint,10,opt,name=cache_write_tokens,json=cacheWriteTokens,proto3" json:"cache_write_tokens,omitempty"`
	// contains filtered or unexported fields
}

type UsageEvent struct {

	// Unique identifier for this event (UUID), used for idempotency
	EventId string `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// Timestamp when the event occurred (optional, server uses NOW() if not provided)
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// User identifier (max 256 chars)
	UserId string `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// Project identifier (max 256 chars)
	ProjectId string `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Action identifier for debugging correlation (max 256 chars)
	ActionId string `protobuf:"bytes,5,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// LLM vendor (e.g., openai, anthropic, google)
	Vendor string `protobuf:"bytes,6,opt,name=vendor,proto3" json:"vendor,omitempty"`
	// Model name (e.g., gpt-4o-mini, claude-3-sonnet)
	Model string `protobuf:"bytes,7,opt,name=model,proto3" json:"model,omitempty"`
	// Request status
	Status Status `protobuf:"varint,8,opt,name=status,proto3,enum=usage.v1.Status" json:"status,omitempty"`
	// Request duration in milliseconds
	DurationMs int64 `protobuf:"varint,9,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	// Input tokens count
	TokensInput int64 `protobuf:"varint,10,opt,name=tokens_input,json=tokensInput,proto3" json:"tokens_input,omitempty"`
	// Output tokens count
	TokensOutput int64 `protobuf:"varint,11,opt,name=tokens_output,json=tokensOutput,proto3" json:"tokens_output,omitempty"`
	// Total tokens (validated: must equal tokens_input + tokens_output if provided)
	TokensTotal int64 `protobuf:"varint,12,opt,name=tokens_total,json=tokensTotal,proto3" json:"tokens_total,omitempty"`
	// Normalized error class (optional)
	ErrorClass string `protobuf:"bytes,13,opt,name=error_class,json=errorClass,proto3" json:"error_class,omitempty"`
	// Vendor HTTP status code (optional)
	VendorHttpStatus int32 `protobuf:"varint,14,opt,name=vendor_http_status,json=vendorHttpStatus,proto3" json:"vendor_http_status,omitempty"`
	// Additional metadata as key-value pairs (optional, keep small)
	Meta map[string]string `` /* 136-byte string literal not displayed */
	// Cost of the call in nano-USD (1e-9 USD), computed by the caller from its
	// price catalog at settle time; stored as an immutable fact (optional, >= 0)
	CostNanousd int64 `protobuf:"varint,16,opt,name=cost_nanousd,json=costNanousd,proto3" json:"cost_nanousd,omitempty"`
	// Input tokens served from the vendor's prompt cache (optional, >= 0). Part of
	// tokens_input, not added to it; usually billed at a fraction of the input rate.
	CacheReadTokens int64 `protobuf:"varint,17,opt,name=cache_read_tokens,json=cacheReadTokens,proto3" json:"cache_read_tokens,omitempty"`
	// Input tokens written to the vendor's prompt cache (optional, >= 0). Part of
	// tokens_input; cache_read_tokens + cache_write_tokens must not exceed it.
	CacheWriteTokens int64 `protobuf:"varint,18,opt,name=cache_write_tokens,json=cacheWriteTokens,proto3" json:"cache_write_tokens,omitempty"`
	// contains filtered or unexported fields
}

type UsageServiceClient interface {
	// RecordUsageEvent records a single usage event
	RecordUsageEvent(ctx context.Context, in *RecordUsageEventRequest, opts ...grpc.CallOption) (*RecordUsageEventResponse, error)
	// RecordUsageEvents records multiple usage events in a batch
	RecordUsageEvents(ctx context.Context, in *RecordUsageEventsRequest, opts ...grpc.CallOption) (*RecordUsageEventsResponse, error)
	// GetUsageSummary returns aggregated usage statistics
	GetUsageSummary(ctx context.Context, in *GetUsageSummaryRequest, opts ...grpc.CallOption) (*GetUsageSummaryResponse, error)
	// GetUsageByMeta returns usage aggregated over events carrying a meta
	// key/value, optionally split by a second meta key, always split by
	// vendor and model.
	GetUsageByMeta(ctx context.Context, in *GetUsageByMetaRequest, opts ...grpc.CallOption) (*GetUsageByMetaResponse, error)
}

type UsageServiceServer interface {
	// RecordUsageEvent records a single usage event
	RecordUsageEvent(context.Context, *RecordUsageEventRequest) (*RecordUsageEventResponse, error)
	// RecordUsageEvents records multiple usage events in a batch
	RecordUsageEvents(context.Context, *RecordUsageEventsRequest) (*RecordUsageEventsResponse, error)
	// GetUsageSummary returns aggregated usage statistics
	GetUsageSummary(context.Context, *GetUsageSummaryRequest) (*GetUsageSummaryResponse, error)
	// GetUsageByMeta returns usage aggregated over events carrying a meta
	// key/value, optionally split by a second meta key, always split by
	// vendor and model.
	GetUsageByMeta(context.Context, *GetUsageByMetaRequest) (*GetUsageByMetaResponse, error)
	// contains filtered or unexported methods
}

type UsageSummaryRow struct {

	// Time bucket (day)
	Bucket *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// Dimension values (only populated if grouped by)
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	UserId    string `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Vendor    string `protobuf:"bytes,4,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Model     string `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`
	ActionId  string `protobuf:"bytes,6,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	Status    Status `protobuf:"varint,7,opt,name=status,proto3,enum=usage.v1.Status" json:"status,omitempty"`
	// Aggregated values
	TokensInput   int64 `protobuf:"varint,10,opt,name=tokens_input,json=tokensInput,proto3" json:"tokens_input,omitempty"`
	TokensOutput  int64 `protobuf:"varint,11,opt,name=tokens_output,json=tokensOutput,proto3" json:"tokens_output,omitempty"`
	TokensTotal   int64 `protobuf:"varint,12,opt,name=tokens_total,json=tokensTotal,proto3" json:"tokens_total,omitempty"`
	RequestCount  int64 `protobuf:"varint,13,opt,name=request_count,json=requestCount,proto3" json:"request_count,omitempty"`
	SumDurationMs int64 `protobuf:"varint,14,opt,name=sum_duration_ms,json=sumDurationMs,proto3" json:"sum_duration_ms,omitempty"`
	// Summed cost in nano-USD (1e-9 USD)
	CostNanousd int64 `protobuf:"varint,15,opt,name=cost_nanousd,json=costNanousd,proto3" json:"cost_nanousd,omitempty"`
	// Summed parts of tokens_input read from and written to the prompt cache
	CacheReadTokens  int64 `protobuf:"varint,16,opt,name=cache_read_tokens,json=cacheReadTokens,proto3" json:"cache_read_tokens,omitempty"`
	CacheWriteTokens int64 `protobuf:"varint,17,opt,name=cache_write_tokens,json=cacheWriteTokens,proto3" json:"cache_write_tokens,omitempty"`
	// contains filtered or unexported fields
}