Documentation ¶
Index ¶
- Variables
- type Address
- type AddressIP
- type AddressPort
- type AliveConnection
- type BackendDS
- func (b *BackendDS) DoRequest(req *http.Request) error
- func (b *BackendDS) PersistAliveConnection(aliveConn *AliveConnection) error
- func (b *BackendDS) PersistContainer(c Container, eventType string) error
- func (b *BackendDS) PersistDaemonSet(ds DaemonSet, eventType string) error
- func (b *BackendDS) PersistDeployment(d Deployment, eventType string) error
- func (b *BackendDS) PersistEndpoints(ep Endpoints, eventType string) error
- func (b *BackendDS) PersistPod(pod Pod, eventType string) error
- func (b *BackendDS) PersistReplicaSet(rs ReplicaSet, eventType string) error
- func (b *BackendDS) PersistRequest(request *Request) error
- func (b *BackendDS) PersistService(service Service, eventType string) error
- func (b *BackendDS) PersistTraceEvent(trace *l7_req.TraceEvent) error
- func (b *BackendDS) SendHealthCheck(ebpf bool, metrics bool, dist bool, k8sVersion string)
- func (ds *BackendDS) Start()
- type BackendResponse
- type CloudProvider
- type ConnInfo
- type ConnInfoPayload
- type Container
- type ContainerEvent
- type DaemonSet
- type DataStore
- type DepEvent
- type Deployment
- type DsEvent
- type Endpoints
- type EpEvent
- type EventPayload
- type HealthCheckPayload
- type LeveledLogger
- type Metadata
- type Pod
- type PodEvent
- type ReplicaSet
- type ReqBackendReponse
- type ReqInfo
- type Request
- type RequestsPayload
- type RsEvent
- type Service
- type SvcEvent
- type TraceInfo
- type TracePayload
Constants ¶
This section is empty.
Variables ¶
View Source
var MonitoringID string
View Source
var NodeID string
Functions ¶
This section is empty.
Types ¶
type Address ¶
type Address struct { IPs []AddressIP `json:"ips"` Ports []AddressPort `json:"ports"` }
Subsets
type AddressPort ¶
type AliveConnection ¶ added in v0.6.0
type BackendDS ¶
type BackendDS struct {
// contains filtered or unexported fields
}
BackendDS is a backend datastore
func NewBackendDS ¶
func NewBackendDS(parentCtx context.Context, conf config.BackendDSConfig) *BackendDS
func (*BackendDS) PersistAliveConnection ¶ added in v0.6.0
func (b *BackendDS) PersistAliveConnection(aliveConn *AliveConnection) error
func (*BackendDS) PersistContainer ¶
func (*BackendDS) PersistDaemonSet ¶
func (*BackendDS) PersistDeployment ¶
func (b *BackendDS) PersistDeployment(d Deployment, eventType string) error
func (*BackendDS) PersistEndpoints ¶
func (*BackendDS) PersistReplicaSet ¶
func (b *BackendDS) PersistReplicaSet(rs ReplicaSet, eventType string) error
func (*BackendDS) PersistRequest ¶
func (*BackendDS) PersistService ¶
func (*BackendDS) PersistTraceEvent ¶ added in v0.4.0
func (b *BackendDS) PersistTraceEvent(trace *l7_req.TraceEvent) error
func (*BackendDS) SendHealthCheck ¶ added in v0.2.0
type BackendResponse ¶
type CloudProvider ¶ added in v0.3.1
type CloudProvider string
const ( CloudProviderAWS CloudProvider = "AWS" CloudProviderGCP CloudProvider = "GCP" CloudProviderAzure CloudProvider = "Azure" CloudProviderDigitalOcean CloudProvider = "DigitalOcean" CloudProviderUnknown CloudProvider = "" )
type ConnInfo ¶ added in v0.6.0
type ConnInfo [9]interface{}
0) CheckTime // connection is alive at that time 1) Source IP 2) Source Type 3) Source ID 4) Source Port 5) Destination IP 6) Destination Type 7) Destination ID 8) Destination Port
type ConnInfoPayload ¶ added in v0.6.0
type ContainerEvent ¶
type DataStore ¶
type DataStore interface { PersistPod(pod Pod, eventType string) error PersistService(service Service, eventType string) error PersistReplicaSet(rs ReplicaSet, eventType string) error PersistDeployment(d Deployment, eventType string) error PersistEndpoints(e Endpoints, eventType string) error PersistContainer(c Container, eventType string) error PersistDaemonSet(ds DaemonSet, eventType string) error PersistRequest(request *Request) error PersistTraceEvent(trace *l7_req.TraceEvent) error PersistAliveConnection(trace *AliveConnection) error }
type Deployment ¶
type EventPayload ¶
type EventPayload struct { Metadata Metadata `json:"metadata"` Events []interface{} `json:"events"` }
type HealthCheckPayload ¶ added in v0.2.0
type HealthCheckPayload struct { Metadata Metadata `json:"metadata"` Info struct { EbpfEnabled bool `json:"ebpf"` MetricsEnabled bool `json:"metrics"` DistTracingEnabled bool `json:"traffic"` } `json:"alaz_info"` Telemetry struct { KernelVersion string `json:"kernel_version"` K8sVersion string `json:"k8s_version"` CloudProvider string `json:"cloud_provider"` } `json:"telemetry"` }
type LeveledLogger ¶ added in v0.2.0
type LeveledLogger struct {
// contains filtered or unexported fields
}
func (LeveledLogger) Debug ¶ added in v0.2.0
func (ll LeveledLogger) Debug(msg string, keysAndValues ...interface{})
func (LeveledLogger) Error ¶ added in v0.2.0
func (ll LeveledLogger) Error(msg string, keysAndValues ...interface{})
func (LeveledLogger) Info ¶ added in v0.2.0
func (ll LeveledLogger) Info(msg string, keysAndValues ...interface{})
func (LeveledLogger) Warn ¶ added in v0.2.0
func (ll LeveledLogger) Warn(msg string, keysAndValues ...interface{})
type ReplicaSet ¶
type ReqBackendReponse ¶ added in v0.2.0
type ReqInfo ¶
type ReqInfo [18]interface{}
0) StartTime 1) Latency 2) Source IP 3) Source Type 4) Source ID 5) Source Port 6) Destination IP 7) Destination Type 8) Destination ID 9) Destination Port 10) Protocol 11) Response Status Code 12) Fail Reason // TODO: not used yet 13) Method 14) Path 15) Encrypted (bool) 16) Seq 17) Tid
type Request ¶
type Request struct { StartTime int64 Latency uint64 // in ns FromIP string FromType string FromUID string FromPort uint16 ToIP string ToType string ToUID string ToPort uint16 Protocol string Tls bool Completed bool StatusCode uint32 FailReason string Method string Path string Tid uint32 Seq uint32 }
type RequestsPayload ¶
type SvcEvent ¶
type SvcEvent struct { UID string `json:"uid"` EventType string `json:"event_type"` Name string `json:"name"` Namespace string `json:"namespace"` Type string `json:"type"` ClusterIPs []string `json:"cluster_ips"` Ports []struct { Src int32 `json:"src"` Dest int32 `json:"dest"` Protocol string `json:"protocol"` } `json:"ports"` }
type TraceInfo ¶ added in v0.4.0
type TraceInfo [4]interface{}
0) Timestamp 1) Tcp Seq Num 2) Tid 3) Ingress(true), Egress(false)
type TracePayload ¶ added in v0.4.0
Click to show internal directories.
Click to hide internal directories.