telemetry

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Jan 16, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SOCK_TRAFFIC_CONTROL     = 1
	XDP_SHUTDOWN             = 2
	ENABLE_ENCODING_METADATA = 3
)
View Source
const (
	TCP_ESTABLISHED = uint32(1)
	TCP_CLOSTED     = uint32(7)

	DEFAULT_UNKNOWN = "-"
)
View Source
const (
	OPERATION_USAGE_DATA_LEN = 32
)

Variables

This section is empty.

Functions

func DeleteServiceMetric added in v0.4.1

func DeleteServiceMetric(serviceName string)

func DeleteWorkloadMetric added in v0.4.1

func DeleteWorkloadMetric(workload *workloadapi.Workload)

func NewLogInfo added in v1.0.0

func NewLogInfo() *logInfo

func NewServiceMetricLabel added in v1.0.0

func NewServiceMetricLabel() *serviceMetricLabels

func NewWorkloadMetricLabel added in v1.0.0

func NewWorkloadMetricLabel() *workloadMetricLabels

func OutputAccesslog added in v0.5.0

func OutputAccesslog(data requestMetric, accesslog logInfo)

func RunPrometheusClient

func RunPrometheusClient(ctx context.Context)

Types

type BpfProgMetric added in v1.0.0

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

func NewBpfProgMetric added in v1.0.0

func NewBpfProgMetric() *BpfProgMetric

func (*BpfProgMetric) Run added in v1.0.0

func (m *BpfProgMetric) Run(ctx context.Context, KmeshPerfInfo *ebpf.Map)

type MapInfo added in v1.0.0

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

type MapMetricController added in v1.0.0

type MapMetricController struct {
}

func NewMapMetric added in v1.0.0

func NewMapMetric() *MapMetricController

func (*MapMetricController) Run added in v1.0.0

func (m *MapMetricController) Run(ctx context.Context)

type MetricController

type MetricController struct {
	EnableAccesslog      atomic.Bool
	EnableMonitoring     atomic.Bool
	EnableWorkloadMetric atomic.Bool
	// contains filtered or unexported fields
}

func NewMetric

func NewMetric(workloadCache cache.WorkloadCache, serviceCache cache.ServiceCache, enableMonitoring bool) *MetricController

func (*MetricController) Run

func (m *MetricController) Run(ctx context.Context, mapOfTcpInfo *ebpf.Map)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL