telemetry

Documentation

Index

• Constants
• func DeleteServiceMetric(serviceName string)
• func DeleteWorkloadMetric(workload *workloadapi.Workload)
• func OutputAccesslog(data requestMetric, accesslog logInfo)
• func RunPrometheusClient(ctx context.Context)
• type MetricController
  • func NewMetric(workloadCache cache.WorkloadCache, enableAccesslog bool) *MetricController
  • func (m *MetricController) Run(ctx context.Context, mapOfTcpInfo *ebpf.Map)

Constants

const (
	TCP_ESTABLISHED = uint32(1)
	TCP_CLOSTED     = uint32(7)

	MSG_LEN = 112
)

Functions

func DeleteServiceMetric

func DeleteServiceMetric(serviceName string)

func DeleteWorkloadMetric

func DeleteWorkloadMetric(workload *workloadapi.Workload)

func OutputAccesslog

func OutputAccesslog(data requestMetric, accesslog logInfo)

func RunPrometheusClient

func RunPrometheusClient(ctx context.Context)

Types

type MetricController

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

func NewMetric

func NewMetric(workloadCache cache.WorkloadCache, enableAccesslog bool) *MetricController

func (*MetricController) Run

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