telemetry

package
v0.0.0-...-4366ea0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventsAPI 

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

func NewEventsAPI 

func NewEventsAPI(eventRelay relay) *EventsAPI

func (*EventsAPI) Flush 

func (api *EventsAPI) Flush()

func (*EventsAPI) SendExtensionInit 

func (api *EventsAPI) SendExtensionInit(data interop.ExtensionInitData) error

func (*EventsAPI) SendImageError 

func (api *EventsAPI) SendImageError(errLog interop.ImageErrorLogData)

func (*EventsAPI) SendInitReport 

func (api *EventsAPI) SendInitReport(data interop.InitReportData) error

func (*EventsAPI) SendInitRuntimeDone 

func (api *EventsAPI) SendInitRuntimeDone(data interop.InitRuntimeDoneData) error

func (*EventsAPI) SendInitStart 

func (api *EventsAPI) SendInitStart(data interop.InitStartData) error

func (*EventsAPI) SendInternalXRayErrorCause 

func (api *EventsAPI) SendInternalXRayErrorCause(data interop.InternalXRayErrorCauseData) error

func (*EventsAPI) SendInvokeStart 

func (api *EventsAPI) SendInvokeStart(data interop.InvokeStartData) error

func (*EventsAPI) SendPlatformLogsDropped 

func (api *EventsAPI) SendPlatformLogsDropped(droppedBytes, droppedRecords int, reason string) error

func (*EventsAPI) SendReport 

func (api *EventsAPI) SendReport(data interop.ReportData) error

type LogsEgress 

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

func NewLogsEgress 

func NewLogsEgress(eventRelay relay, w io.Writer) *LogsEgress

func (*LogsEgress) GetExtensionSockets 

func (e *LogsEgress) GetExtensionSockets() (io.Writer, io.Writer, error)

func (*LogsEgress) GetRuntimeSockets 

func (e *LogsEgress) GetRuntimeSockets() (io.Writer, io.Writer, error)

type Relay 

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

func NewRelay 

func NewRelay() *Relay

type SubscriptionAPI 

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

func NewSubscriptionAPI 

func NewSubscriptionAPI(store subscriptionStore, logsDroppedEventAPI internal.LogsDroppedEventAPI, telemetrySubscriptionEventAPI telemetrySubscriptionEventAPI) *SubscriptionAPI

func (*SubscriptionAPI) Clear 

func (api *SubscriptionAPI) Clear()

func (*SubscriptionAPI) Configure 

func (api *SubscriptionAPI) Configure(passphrase string, addr netip.AddrPort)

func (*SubscriptionAPI) FlushMetrics 

func (api *SubscriptionAPI) FlushMetrics() interop.TelemetrySubscriptionMetrics

func (*SubscriptionAPI) GetEndpointURL 

func (api *SubscriptionAPI) GetEndpointURL() string

func (*SubscriptionAPI) GetServiceClosedErrorMessage 

func (api *SubscriptionAPI) GetServiceClosedErrorMessage() string

func (*SubscriptionAPI) GetServiceClosedErrorType 

func (api *SubscriptionAPI) GetServiceClosedErrorType() string

func (*SubscriptionAPI) RecordCounterMetric 

func (api *SubscriptionAPI) RecordCounterMetric(metricName string, count int)

func (*SubscriptionAPI) Subscribe 

func (api *SubscriptionAPI) Subscribe(agentName string, body io.Reader, _ map[string][]string, _ string) (resp []byte, status int, respHeaders map[string][]string, err error)

func (*SubscriptionAPI) TurnOff 

func (api *SubscriptionAPI) TurnOff()

type SubscriptionRequest 

type SubscriptionRequest struct {
	SchemaVersion string                           `json:"schemaVersion"`
	Categories    []string                         `json:"types"`
	Destination   internal.SubscriptionDestination `json:"destination"`
	Buffering     *internal.BufferingConfig        `json:"buffering,omitempty"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.