telemetry

type BatchStoreObservation struct {
	At           time.Time
	TenantWrites map[string]int
	Status       int
	Latency      time.Duration
}

type Event struct {
	At        time.Time `json:"at"`
	Type      string    `json:"type"`
	Method    string    `json:"method,omitempty"`
	Path      string    `json:"path,omitempty"`
	TenantID  string    `json:"tenant_id,omitempty"`
	Status    int       `json:"status"`
	LatencyMS int64     `json:"latency_ms"`
	Detail    string    `json:"detail,omitempty"`
}

type MinuteCount struct {
	Minute time.Time `json:"minute"`
	Count  int64     `json:"count"`
}

type Options struct {
	RequestWindowMinutes int
	EventBufferSize      int
}

type RequestObservation struct {
	At       time.Time
	Method   string
	Path     string
	TenantID string
	Status   int
	Latency  time.Duration
}

type SearchObservation struct {
	At       time.Time
	TenantID string
	Status   int
	Latency  time.Duration
}

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

type Snapshot struct {
	GeneratedAt          time.Time     `json:"generated_at"`
	ActiveRequests       int64         `json:"active_requests"`
	StoreCount           int64         `json:"store_count"`
	BatchStoreCount      int64         `json:"batch_store_count"`
	SearchCount          int64         `json:"search_count"`
	RequestsPerMinute    []MinuteCount `json:"requests_per_minute"`
	RecentEvents         []Event       `json:"recent_events"`
	TopTenantsByWrites   []TenantStat  `json:"top_tenants_by_writes"`
	TopTenantsBySearches []TenantStat  `json:"top_tenants_by_searches"`
}

type SnapshotOptions struct {
	Events     int
	TopTenants int
}

type StoreObservation struct {
	At       time.Time
	TenantID string
	Status   int
	Latency  time.Duration
}

type TenantStat struct {
	TenantID string `json:"tenant_id"`
	Writes   int64  `json:"writes"`
	Searches int64  `json:"searches"`
}