datastore

package

Go to main page

Versions in this module

v0

v0.7.3

Mar 22, 2024

Changes in this version

type BackendDS

+ func (ds *BackendDS) Start()

v0.7.2

Mar 20, 2024

v0.7.1

Mar 19, 2024

v0.7.0

Mar 15, 2024

v0.6.6

Mar 7, 2024

v0.6.5

Feb 25, 2024

v0.6.4

Feb 21, 2024

v0.6.3

Feb 21, 2024

v0.6.2

Feb 20, 2024

v0.6.1

Feb 13, 2024

v0.6.0

Feb 11, 2024

Changes in this version

+ type AliveConnection struct

+ CheckTime int64

+ FromIP string

+ FromPort uint16

+ FromType string

+ FromUID string

+ ToIP string

+ ToPort uint16

+ ToType string

+ ToUID string

type BackendDS

+ func (b *BackendDS) PersistAliveConnection(aliveConn *AliveConnection) error

+ type ConnInfo [9]interface

+ type ConnInfoPayload struct

+ Connections []*ConnInfo

+ Metadata Metadata

type DataStore

+ PersistAliveConnection func(trace *AliveConnection) error

v0.5.2

Feb 7, 2024

v0.5.1

Feb 7, 2024

v0.5.0

Jan 23, 2024

v0.4.0

Jan 11, 2024

Changes in this version

type BackendDS

+ func (b *BackendDS) PersistTraceEvent(trace *l7_req.TraceEvent) error

type DataStore

+ PersistTraceEvent func(trace *l7_req.TraceEvent) error

type MockDataStore

+ func (m *MockDataStore) PersistTraceEvent(trace *l7_req.TraceEvent) error

type Request

+ Seq uint32

+ Tid uint32

+ type TraceInfo [4]interface

+ type TracePayload struct

+ Metadata Metadata

+ Traces []*TraceInfo

v0.3.5

Jan 3, 2024

v0.3.4

Dec 26, 2023

v0.3.3

Dec 21, 2023

v0.3.2

Dec 12, 2023

v0.3.1

Dec 7, 2023

Changes in this version

+ type CloudProvider string

+ const CloudProviderAWS

+ const CloudProviderAzure

+ const CloudProviderDigitalOcean

+ const CloudProviderGCP

+ const CloudProviderUnknown

type HealthCheckPayload

+ Telemetry struct{ ... }

v0.3.0

Nov 28, 2023

v0.2.2

Oct 30, 2023

v0.2.1

Oct 27, 2023

Changes in this version

+ type MockDataStore struct

+ func (m *MockDataStore) PersistContainer(c Container, eventType string) error

+ func (m *MockDataStore) PersistDaemonSet(ds DaemonSet, eventType string) error

+ func (m *MockDataStore) PersistDeployment(d Deployment, eventType string) error

+ func (m *MockDataStore) PersistEndpoints(e Endpoints, eventType string) error

+ func (m *MockDataStore) PersistPod(pod Pod, eventType string) error

+ func (m *MockDataStore) PersistReplicaSet(rs ReplicaSet, eventType string) error

+ func (m *MockDataStore) PersistRequest(request *Request) error

+ func (m *MockDataStore) PersistService(service Service, eventType string) error

v0.2.0

Oct 19, 2023

Changes in this version

type BackendDS

+ func (b *BackendDS) SendHealthCheck(ebpf bool, metrics bool)

+ type HealthCheckPayload struct

+ Info struct{ ... }

+ Metadata Metadata

+ type LeveledLogger struct

+ func (ll LeveledLogger) Debug(msg string, keysAndValues ...interface{})

+ func (ll LeveledLogger) Error(msg string, keysAndValues ...interface{})

+ func (ll LeveledLogger) Info(msg string, keysAndValues ...interface{})

+ func (ll LeveledLogger) Warn(msg string, keysAndValues ...interface{})

+ type Metadata struct

+ AlazVersion string

+ IdempotencyKey string

+ MonitoringID string

+ NodeID string

+ type ReqBackendReponse struct

+ Errors []struct{ ... }

+ Msg string

type Request

+ Tls bool

v0.1.4

Sep 7, 2023

Changes in this version

+ var MonitoringID string

+ var NodeID string

+ type Address struct

+ IPs []AddressIP

+ Ports []AddressPort

+ type AddressIP struct

+ ID string

+ IP string

+ Name string

+ Namespace string

+ Type string

+ type AddressPort struct

+ Port int32

+ Protocol string

+ type BackendDS struct

+ func NewBackendDS(parentCtx context.Context, conf config.BackendConfig) *BackendDS

+ func (b *BackendDS) DoRequest(req *http.Request) 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

+ type BackendResponse struct

+ Errors []struct{ ... }

+ Msg string

+ type Container struct

+ Image string

+ Name string

+ Namespace string

+ PodUID string

+ Ports []struct{ ... }

+ type ContainerEvent struct

+ EventType string

+ Image string

+ Name string

+ Namespace string

+ Pod string

+ Ports []struct{ ... }

+ UID string

+ type DaemonSet struct

+ Name string

+ Namespace string

+ UID string

+ type DataStore interface

+ PersistContainer func(c Container, eventType string) error

+ PersistDaemonSet func(ds DaemonSet, eventType string) error

+ PersistDeployment func(d Deployment, eventType string) error

+ PersistEndpoints func(e Endpoints, eventType string) error

+ PersistPod func(pod Pod, eventType string) error

+ PersistReplicaSet func(rs ReplicaSet, eventType string) error

+ PersistRequest func(request Request) error

+ PersistService func(service Service, eventType string) error

+ type DepEvent struct

+ EventType string

+ Name string

+ Namespace string

+ Replicas int32

+ UID string

+ type Deployment struct

+ Name string

+ Namespace string

+ Replicas int32

+ UID string

+ type DsEvent struct

+ EventType string

+ Name string

+ Namespace string

+ UID string

+ type Endpoints struct

+ Addresses []Address

+ Name string

+ Namespace string

+ UID string

+ type EpEvent struct

+ Addresses []Address

+ EventType string

+ Name string

+ Namespace string

+ UID string

+ type EventPayload struct

+ Events []interface{}

+ Metadata struct{ ... }

+ type Pod struct

+ IP string

+ Image string

+ Name string

+ Namespace string

+ OwnerID string

+ OwnerName string

+ OwnerType string

+ UID string

+ type PodEvent struct

+ EventType string

+ IP string

+ Name string

+ Namespace string

+ OwnerID string

+ OwnerName string

+ OwnerType string

+ UID string

+ type ReplicaSet struct

+ Name string

+ Namespace string

+ OwnerID string

+ OwnerName string

+ OwnerType string

+ Replicas int32

+ UID string

+ type ReqInfo [15]interface

+ type Request struct

+ Completed bool

+ FailReason string

+ FromIP string

+ FromPort uint16

+ FromType string

+ FromUID string

+ Latency uint64

+ Method string

+ Path string

+ Protocol string

+ StartTime int64

+ StatusCode uint32

+ ToIP string

+ ToPort uint16

+ ToType string

+ ToUID string

+ type RequestsPayload struct

+ Metadata struct{ ... }

+ Requests []*ReqInfo

+ type RsEvent struct

+ EventType string

+ Name string

+ Namespace string

+ OwnerID string

+ OwnerName string

+ OwnerType string

+ Replicas int32

+ UID string

+ type Service struct

+ ClusterIP string

+ ClusterIPs []string

+ Name string

+ Namespace string

+ Ports []struct{ ... }

+ Type string

+ UID string

+ type SvcEvent struct

+ ClusterIPs []string

+ EventType string

+ Name string

+ Namespace string

+ Ports []struct{ ... }

+ Type string

+ UID string

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