Documentation
¶
Index ¶
- type Event
- type Telemetry
- func (t *Telemetry) CommandTelemetryEvent(command string, savedTokens int, execTimeMs int64)
- func (t *Telemetry) EventCount() int
- func (t *Telemetry) FilterTelemetryEvent(originalTokens, filteredTokens int, layers map[string]int)
- func (t *Telemetry) Flush()
- func (t *Telemetry) IsEnabled() bool
- func (t *Telemetry) Record(eventType string, props map[string]interface{})
- func (t *Telemetry) SetOutput(path string)
- func (t *Telemetry) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Event ¶
type Event struct {
Type string `json:"type"`
Timestamp time.Time `json:"timestamp"`
Properties map[string]interface{} `json:"properties,omitempty"`
}
Event represents a telemetry event.
type Telemetry ¶
type Telemetry struct {
// contains filtered or unexported fields
}
Telemetry collects and batches telemetry events for async sending.
func NewDefault ¶
func NewDefault() *Telemetry
NewDefault creates a telemetry instance with default settings.
func (*Telemetry) CommandTelemetryEvent ¶
CommandTelemetryEvent records a command execution telemetry event.
func (*Telemetry) EventCount ¶
EventCount returns the number of pending events.
func (*Telemetry) FilterTelemetryEvent ¶
FilterTelemetryEvent records a filter pipeline telemetry event.
func (*Telemetry) Record ¶
Record records a telemetry event. If the buffer is full, the event is dropped (no backpressure). This prevents OOM when the flush backend is slow or unavailable.
Source Files
Click to show internal directories.
Click to hide internal directories.