usage

type BuildToolInvocationInput struct {
	ProjectName     string
	ConversationID  string
	ConversationUID string
	// ServiceName is the reverse-DNS provider service name (AgentBinding
	// spec.serviceName), e.g. streaming.streamco.example. Emitted as the
	// `service` dimension so billing can price per provider.
	ServiceName string
	Namespace   string // empty defaults to "default"
	NowMillis   int64  // 0 uses time.Now()
}

type BuildUsageInput struct {
	ProjectName     string
	ConversationID  string
	ConversationUID string
	Model           string // Anthropic model id, e.g. claude-sonnet-4-6
	Namespace       string // empty defaults to "default"
	Tokens          UsageTokens
	// NowMillis is the emit time in unix milliseconds; 0 uses time.Now().
	NowMillis int64
}

type CloudEvent struct {
	ID              string         `json:"id"`
	SpecVersion     string         `json:"specversion"`
	Type            string         `json:"type"`
	Source          string         `json:"source"`
	Subject         string         `json:"subject"`
	DataContentType string         `json:"datacontenttype"`
	Time            string         `json:"time"`
	Data            CloudEventData `json:"data"`
}

type CloudEventData struct {
	Value      string              `json:"value"`
	Dimensions map[string]string   `json:"dimensions,omitempty"`
	Resource   *CloudEventResource `json:"resource,omitempty"`
}

type CloudEventResource struct {
	Group     string `json:"group"`
	Kind      string `json:"kind"`
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	UID       string `json:"uid,omitempty"`
}

type EmitResult struct {
	// OK is true when the collector accepted the batch (2xx) OR emission was disabled.
	OK bool
	// Noop is true when no collector is configured — events were intentionally dropped.
	Noop bool
	// Count is the number of events submitted (0 when noop or empty).
	Count int
	// Status is the HTTP status of the last request, if one was made.
	Status int
	// Error is a human-readable failure message when OK is false.
	Error string
}

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

type EmitterConfig struct {
	// GatewayURL is the collector base URL (env USAGE_GATEWAY_URL). Empty ⇒ Emit is a no-op.
	GatewayURL string
	// APIKey is an optional collector api-key (env USAGE_GATEWAY_API_KEY).
	APIKey string
	// Source is the CloudEvents source URI identifying this producer.
	Source string
	// HTTPClient is injectable for tests; nil uses a client with the emit timeout.
	HTTPClient *http.Client
	// Logger is optional; nil discards emitter logs.
	Logger *slog.Logger
}

type Event struct {
	EventID    string
	MeterName  string
	Timestamp  string // ISO-8601
	ProjectRef ProjectRef
	Value      string // numeric value as a string (wire spec)
	Dimensions map[string]string
	Resource   EventResource
}

type EventResource struct {
	Ref    ResourceRef
	Labels map[string]string
}

type ProjectRef struct {
	Name string
}

type ResourceRef struct {
	ProjectRef ProjectRef
	Group      string
	Kind       string
	Namespace  string
	Name       string
	UID        string
}

type UsageTokens struct {
	InputTokens              int64
	OutputTokens             int64
	CachedInputTokens        int64
	CacheCreationInputTokens int64
	// Messages is the per-request message count. nil defaults to 1, matching
	// the TS `tokens.messages ?? 1`.
	Messages *int64
}