k8sclustersyncv1

package
v1.1.3 Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	KubernetesInfoService_SendKubernetesResources_FullMethodName    = "/illumio.cloud.k8sclustersync.v1.KubernetesInfoService/SendKubernetesResources"
	KubernetesInfoService_SendKubernetesNetworkFlows_FullMethodName = "/illumio.cloud.k8sclustersync.v1.KubernetesInfoService/SendKubernetesNetworkFlows"
	KubernetesInfoService_SendLogs_FullMethodName                   = "/illumio.cloud.k8sclustersync.v1.KubernetesInfoService/SendLogs"
	KubernetesInfoService_GetConfigurationUpdates_FullMethodName    = "/illumio.cloud.k8sclustersync.v1.KubernetesInfoService/GetConfigurationUpdates"
)

Variables

View Source
var (
	FlowCollector_name = map[int32]string{
		0: "FLOW_COLLECTOR_UNSPECIFIED",
		1: "FLOW_COLLECTOR_DISABLED",
		2: "FLOW_COLLECTOR_CILIUM",
		3: "FLOW_COLLECTOR_FALCO",
	}
	FlowCollector_value = map[string]int32{
		"FLOW_COLLECTOR_UNSPECIFIED": 0,
		"FLOW_COLLECTOR_DISABLED":    1,
		"FLOW_COLLECTOR_CILIUM":      2,
		"FLOW_COLLECTOR_FALCO":       3,
	}
)

Enum value maps for FlowCollector.

View Source
var (
	TrafficDirection_name = map[int32]string{
		0: "TRAFFIC_DIRECTION_TRAFFIC_DIRECTION_UNKNOWN_UNSPECIFIED",
		1: "TRAFFIC_DIRECTION_INGRESS",
		2: "TRAFFIC_DIRECTION_EGRESS",
	}
	TrafficDirection_value = map[string]int32{
		"TRAFFIC_DIRECTION_TRAFFIC_DIRECTION_UNKNOWN_UNSPECIFIED": 0,
		"TRAFFIC_DIRECTION_INGRESS":                               1,
		"TRAFFIC_DIRECTION_EGRESS":                                2,
	}
)

Enum value maps for TrafficDirection.

View Source
var (
	Verdict_name = map[int32]string{
		0: "VERDICT_UNKNOWN_UNSPECIFIED",
		1: "VERDICT_FORWARDED",
		2: "VERDICT_DROPPED",
		3: "VERDICT_ERROR",
		4: "VERDICT_AUDIT",
		5: "VERDICT_REDIRECTED",
		6: "VERDICT_TRACED",
		7: "VERDICT_TRANSLATED",
	}
	Verdict_value = map[string]int32{
		"VERDICT_UNKNOWN_UNSPECIFIED": 0,
		"VERDICT_FORWARDED":           1,
		"VERDICT_DROPPED":             2,
		"VERDICT_ERROR":               3,
		"VERDICT_AUDIT":               4,
		"VERDICT_REDIRECTED":          5,
		"VERDICT_TRACED":              6,
		"VERDICT_TRANSLATED":          7,
	}
)

Enum value maps for Verdict.

View Source
var (
	IPVersion_name = map[int32]string{
		0: "IP_VERSION_IP_NOT_USED_UNSPECIFIED",
		1: "IP_VERSION_IPV4",
		2: "IP_VERSION_IPV6",
	}
	IPVersion_value = map[string]int32{
		"IP_VERSION_IP_NOT_USED_UNSPECIFIED": 0,
		"IP_VERSION_IPV4":                    1,
		"IP_VERSION_IPV6":                    2,
	}
)

Enum value maps for IPVersion.

View Source
var (
	LogLevel_name = map[int32]string{
		0: "LOG_LEVEL_UNSPECIFIED",
		1: "LOG_LEVEL_DEBUG",
		2: "LOG_LEVEL_INFO",
		3: "LOG_LEVEL_WARN",
		4: "LOG_LEVEL_ERROR",
	}
	LogLevel_value = map[string]int32{
		"LOG_LEVEL_UNSPECIFIED": 0,
		"LOG_LEVEL_DEBUG":       1,
		"LOG_LEVEL_INFO":        2,
		"LOG_LEVEL_WARN":        3,
		"LOG_LEVEL_ERROR":       4,
	}
)

Enum value maps for LogLevel.

View Source
var File_illumio_cloud_k8sclustersync_v1_k8s_info_proto protoreflect.FileDescriptor
View Source
var KubernetesInfoService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "illumio.cloud.k8sclustersync.v1.KubernetesInfoService",
	HandlerType: (*KubernetesInfoServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SendKubernetesResources",
			Handler:       _KubernetesInfoService_SendKubernetesResources_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SendKubernetesNetworkFlows",
			Handler:       _KubernetesInfoService_SendKubernetesNetworkFlows_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SendLogs",
			Handler:       _KubernetesInfoService_SendLogs_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "GetConfigurationUpdates",
			Handler:       _KubernetesInfoService_GetConfigurationUpdates_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "illumio/cloud/k8sclustersync/v1/k8s_info.proto",
}

KubernetesInfoService_ServiceDesc is the grpc.ServiceDesc for KubernetesInfoService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterKubernetesInfoServiceServer

func RegisterKubernetesInfoServiceServer(s grpc.ServiceRegistrar, srv KubernetesInfoServiceServer)

Types

type CiliumFlow

type CiliumFlow struct {

	// Time when flow occurred.
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// node_name is the name of the node from which this Flow was captured.
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// traffic_direction distinguishes direction of the connection, e.g. ingress or egress.
	TrafficDirection TrafficDirection `` /* 164-byte string literal not displayed */
	// verdict of the flow, indicating the outcome of the network packet processing.
	Verdict Verdict `protobuf:"varint,4,opt,name=verdict,proto3,enum=illumio.cloud.k8sclustersync.v1.Verdict" json:"verdict,omitempty"`
	// layer3 IP layer, source, destination and ip_version
	Layer3 *IP `protobuf:"bytes,5,opt,name=layer3,proto3" json:"layer3,omitempty"`
	// layer4 contains protocol used
	Layer4 *Layer4 `protobuf:"bytes,6,opt,name=layer4,proto3" json:"layer4,omitempty"`
	// is_reply indicates that this was a packet (L4) or message (L7) in the
	// reply direction. May be absent (in which case it is unknown whether it
	// is a reply or not).
	IsReply *wrapperspb.BoolValue `protobuf:"bytes,7,opt,name=is_reply,json=isReply,proto3" json:"is_reply,omitempty"`
	// endpoint of source ip with metadata
	SourceEndpoint *Endpoint `protobuf:"bytes,8,opt,name=source_endpoint,json=sourceEndpoint,proto3,oneof" json:"source_endpoint,omitempty"`
	// endpoint of destination ip with metadata
	DestinationEndpoint *Endpoint `protobuf:"bytes,9,opt,name=destination_endpoint,json=destinationEndpoint,proto3,oneof" json:"destination_endpoint,omitempty"`
	// destination_service contains the service name of the destination
	DestinationService *Service `protobuf:"bytes,10,opt,name=destination_service,json=destinationService,proto3" json:"destination_service,omitempty"`
	// The CiliumNetworkPolicies allowing the egress of the flow.
	EgressAllowedBy []*Policy `protobuf:"bytes,11,rep,name=egress_allowed_by,json=egressAllowedBy,proto3" json:"egress_allowed_by,omitempty"`
	// The CiliumNetworkPolicies allowing the ingress of the flow.
	IngressAllowedBy []*Policy `protobuf:"bytes,12,rep,name=ingress_allowed_by,json=ingressAllowedBy,proto3" json:"ingress_allowed_by,omitempty"`
	// The CiliumNetworkPolicies denying the egress of the flow.
	EgressDeniedBy []*Policy `protobuf:"bytes,13,rep,name=egress_denied_by,json=egressDeniedBy,proto3" json:"egress_denied_by,omitempty"`
	// The CiliumNetworkPolicies denying the ingress of the flow.
	IngressDeniedBy []*Policy `protobuf:"bytes,14,rep,name=ingress_denied_by,json=ingressDeniedBy,proto3" json:"ingress_denied_by,omitempty"`
	// contains filtered or unexported fields
}

A flow received from Cilium Hubble Relay using the Observer service's GetFlows RPC. https://github.com/cilium/cilium/blob/main/api/v1/observer/observer.proto

func (*CiliumFlow) Descriptor deprecated

func (*CiliumFlow) Descriptor() ([]byte, []int)

Deprecated: Use CiliumFlow.ProtoReflect.Descriptor instead.

func (*CiliumFlow) GetDestinationEndpoint

func (x *CiliumFlow) GetDestinationEndpoint() *Endpoint

func (*CiliumFlow) GetDestinationService

func (x *CiliumFlow) GetDestinationService() *Service

func (*CiliumFlow) GetEgressAllowedBy

func (x *CiliumFlow) GetEgressAllowedBy() []*Policy

func (*CiliumFlow) GetEgressDeniedBy

func (x *CiliumFlow) GetEgressDeniedBy() []*Policy

func (*CiliumFlow) GetIngressAllowedBy

func (x *CiliumFlow) GetIngressAllowedBy() []*Policy

func (*CiliumFlow) GetIngressDeniedBy

func (x *CiliumFlow) GetIngressDeniedBy() []*Policy

func (*CiliumFlow) GetIsReply

func (x *CiliumFlow) GetIsReply() *wrapperspb.BoolValue

func (*CiliumFlow) GetLayer3

func (x *CiliumFlow) GetLayer3() *IP

func (*CiliumFlow) GetLayer4

func (x *CiliumFlow) GetLayer4() *Layer4

func (*CiliumFlow) GetNodeName

func (x *CiliumFlow) GetNodeName() string

func (*CiliumFlow) GetSourceEndpoint

func (x *CiliumFlow) GetSourceEndpoint() *Endpoint

func (*CiliumFlow) GetTime

func (x *CiliumFlow) GetTime() *timestamppb.Timestamp

func (*CiliumFlow) GetTrafficDirection

func (x *CiliumFlow) GetTrafficDirection() TrafficDirection

func (*CiliumFlow) GetVerdict

func (x *CiliumFlow) GetVerdict() Verdict

func (*CiliumFlow) Key added in v1.1.3

func (flow *CiliumFlow) Key() any

func (*CiliumFlow) ProtoMessage

func (*CiliumFlow) ProtoMessage()

func (*CiliumFlow) ProtoReflect

func (x *CiliumFlow) ProtoReflect() protoreflect.Message

func (*CiliumFlow) Reset

func (x *CiliumFlow) Reset()

func (*CiliumFlow) StartTimestamp added in v1.1.3

func (flow *CiliumFlow) StartTimestamp() time.Time

func (*CiliumFlow) String

func (x *CiliumFlow) String() string

type CiliumFlowKey added in v1.1.3

type CiliumFlowKey struct {
	SourceIP           string
	DestinationIP      string
	SourcePort         int
	DestinationPort    int
	Protocol           string
	SourceK8sMeta      uint32
	DestinationK8sMeta uint32
}

type Endpoint

type Endpoint struct {
	Uid         uint32      `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	ClusterName string      `protobuf:"bytes,7,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Namespace   string      `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels      []string    `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`
	PodName     string      `protobuf:"bytes,5,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	Workloads   []*Workload `protobuf:"bytes,6,rep,name=workloads,proto3" json:"workloads,omitempty"`
	// contains filtered or unexported fields
}

Endpoint contains the Endpoint header fields of a flow https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-endpoint

func (*Endpoint) Descriptor deprecated

func (*Endpoint) Descriptor() ([]byte, []int)

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetClusterName

func (x *Endpoint) GetClusterName() string

func (*Endpoint) GetLabels

func (x *Endpoint) GetLabels() []string

func (*Endpoint) GetNamespace

func (x *Endpoint) GetNamespace() string

func (*Endpoint) GetPodName

func (x *Endpoint) GetPodName() string

func (*Endpoint) GetUid

func (x *Endpoint) GetUid() uint32

func (*Endpoint) GetWorkloads

func (x *Endpoint) GetWorkloads() []*Workload

func (*Endpoint) ProtoMessage

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect

func (x *Endpoint) ProtoReflect() protoreflect.Message

func (*Endpoint) Reset

func (x *Endpoint) Reset()

func (*Endpoint) String

func (x *Endpoint) String() string

type FalcoFlow added in v0.0.8

type FalcoFlow struct {

	// layer3 IP layer, source, destination and ip_version
	Layer3 *IP `protobuf:"bytes,1,opt,name=layer3,proto3" json:"layer3,omitempty"`
	// Proto contains protocol used
	Layer4 *Layer4 `protobuf:"bytes,2,opt,name=layer4,proto3" json:"layer4,omitempty"`
	// Types that are valid to be assigned to Ts:
	//
	//	*FalcoFlow_Time
	//	*FalcoFlow_Timestamp
	Ts isFalcoFlow_Ts `protobuf_oneof:"ts"`
	// contains filtered or unexported fields
}

A flow received from Falco using custom rules

func (*FalcoFlow) Descriptor deprecated added in v0.0.8

func (*FalcoFlow) Descriptor() ([]byte, []int)

Deprecated: Use FalcoFlow.ProtoReflect.Descriptor instead.

func (*FalcoFlow) GetLayer3 added in v0.0.8

func (x *FalcoFlow) GetLayer3() *IP

func (*FalcoFlow) GetLayer4 added in v0.0.8

func (x *FalcoFlow) GetLayer4() *Layer4

func (*FalcoFlow) GetTime deprecated added in v0.0.10

func (x *FalcoFlow) GetTime() string

Deprecated: Marked as deprecated in illumio/cloud/k8sclustersync/v1/k8s_info.proto.

func (*FalcoFlow) GetTimestamp added in v1.1.0

func (x *FalcoFlow) GetTimestamp() *timestamppb.Timestamp

func (*FalcoFlow) GetTs added in v1.1.0

func (x *FalcoFlow) GetTs() isFalcoFlow_Ts

func (*FalcoFlow) Key added in v1.1.3

func (flow *FalcoFlow) Key() any

func (*FalcoFlow) ProtoMessage added in v0.0.8

func (*FalcoFlow) ProtoMessage()

func (*FalcoFlow) ProtoReflect added in v0.0.8

func (x *FalcoFlow) ProtoReflect() protoreflect.Message

func (*FalcoFlow) Reset added in v0.0.8

func (x *FalcoFlow) Reset()

func (*FalcoFlow) StartTimestamp added in v1.1.3

func (flow *FalcoFlow) StartTimestamp() time.Time

func (*FalcoFlow) String added in v0.0.8

func (x *FalcoFlow) String() string

type FalcoFlowKey added in v1.1.3

type FalcoFlowKey struct {
	SourceIP        string
	DestinationIP   string
	SourcePort      int
	DestinationPort int
	Protocol        string
}

type FalcoFlow_Time added in v1.1.0

type FalcoFlow_Time struct {
	// time contains the unparsed timestamp string received from Falco; parse it and set timestamp instead
	//
	// Deprecated: Marked as deprecated in illumio/cloud/k8sclustersync/v1/k8s_info.proto.
	Time string `protobuf:"bytes,3,opt,name=time,proto3,oneof"`
}

type FalcoFlow_Timestamp added in v1.1.0

type FalcoFlow_Timestamp struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3,oneof"`
}

type Flow added in v1.1.3

type Flow interface {
	// StartTimestamp is the start timestamp of this flow.
	StartTimestamp() time.Time
	// Key is this flow's flow key. The returned value is Comparable.
	Key() any
}

Flow is a network flow that is collected or exported.

type FlowCollector added in v1.1.2

type FlowCollector int32

Network flow collection mechanism configured in the operator.

const (
	// Default value. This value is unused and should not be set.
	FlowCollector_FLOW_COLLECTOR_UNSPECIFIED FlowCollector = 0
	// Indicates that no suitable network flow collection mechanism is available in the k8s cluster.
	FlowCollector_FLOW_COLLECTOR_DISABLED FlowCollector = 1
	// Indicates that the Cilium CNI plugin is deployed with Hubble Relay and is used for collecting network flows.
	FlowCollector_FLOW_COLLECTOR_CILIUM FlowCollector = 2
	// Indicates that Falco is deployed and configured for collecting network flows.
	FlowCollector_FLOW_COLLECTOR_FALCO FlowCollector = 3
)

func (FlowCollector) Descriptor added in v1.1.2

func (FlowCollector) Enum added in v1.1.2

func (x FlowCollector) Enum() *FlowCollector

func (FlowCollector) EnumDescriptor deprecated added in v1.1.2

func (FlowCollector) EnumDescriptor() ([]byte, []int)

Deprecated: Use FlowCollector.Descriptor instead.

func (FlowCollector) Number added in v1.1.2

func (FlowCollector) String added in v1.1.2

func (x FlowCollector) String() string

func (FlowCollector) Type added in v1.1.2

type GetConfigurationUpdatesRequest added in v1.1.2

type GetConfigurationUpdatesRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*GetConfigurationUpdatesRequest_Keepalive
	Request isGetConfigurationUpdatesRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

Message to encapsulate a request to send configuration updates.

func (*GetConfigurationUpdatesRequest) Descriptor deprecated added in v1.1.2

func (*GetConfigurationUpdatesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigurationUpdatesRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationUpdatesRequest) GetKeepalive added in v1.1.2

func (x *GetConfigurationUpdatesRequest) GetKeepalive() *Keepalive

func (*GetConfigurationUpdatesRequest) GetRequest added in v1.1.2

func (x *GetConfigurationUpdatesRequest) GetRequest() isGetConfigurationUpdatesRequest_Request

func (*GetConfigurationUpdatesRequest) ProtoMessage added in v1.1.2

func (*GetConfigurationUpdatesRequest) ProtoMessage()

func (*GetConfigurationUpdatesRequest) ProtoReflect added in v1.1.2

func (*GetConfigurationUpdatesRequest) Reset added in v1.1.2

func (x *GetConfigurationUpdatesRequest) Reset()

func (*GetConfigurationUpdatesRequest) String added in v1.1.2

type GetConfigurationUpdatesRequest_Keepalive added in v1.1.2

type GetConfigurationUpdatesRequest_Keepalive struct {
	Keepalive *Keepalive `protobuf:"bytes,1,opt,name=keepalive,proto3,oneof"`
}

type GetConfigurationUpdatesResponse added in v1.1.2

type GetConfigurationUpdatesResponse struct {

	// Types that are valid to be assigned to Response:
	//
	//	*GetConfigurationUpdatesResponse_UpdateConfiguration
	Response isGetConfigurationUpdatesResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

Message to encapsulate the response for configuration update requests.

func (*GetConfigurationUpdatesResponse) Descriptor deprecated added in v1.1.2

func (*GetConfigurationUpdatesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigurationUpdatesResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationUpdatesResponse) GetResponse added in v1.1.2

func (x *GetConfigurationUpdatesResponse) GetResponse() isGetConfigurationUpdatesResponse_Response

func (*GetConfigurationUpdatesResponse) GetUpdateConfiguration added in v1.1.2

func (*GetConfigurationUpdatesResponse) ProtoMessage added in v1.1.2

func (*GetConfigurationUpdatesResponse) ProtoMessage()

func (*GetConfigurationUpdatesResponse) ProtoReflect added in v1.1.2

func (*GetConfigurationUpdatesResponse) Reset added in v1.1.2

func (*GetConfigurationUpdatesResponse) String added in v1.1.2

type GetConfigurationUpdatesResponse_Configuration added in v1.1.2

type GetConfigurationUpdatesResponse_Configuration struct {

	// The operator's log level.
	LogLevel LogLevel `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetConfigurationUpdatesResponse_Configuration) Descriptor deprecated added in v1.1.2

Deprecated: Use GetConfigurationUpdatesResponse_Configuration.ProtoReflect.Descriptor instead.

func (*GetConfigurationUpdatesResponse_Configuration) GetLogLevel added in v1.1.2

func (*GetConfigurationUpdatesResponse_Configuration) ProtoMessage added in v1.1.2

func (*GetConfigurationUpdatesResponse_Configuration) ProtoReflect added in v1.1.2

func (*GetConfigurationUpdatesResponse_Configuration) Reset added in v1.1.2

func (*GetConfigurationUpdatesResponse_Configuration) String added in v1.1.2

type GetConfigurationUpdatesResponse_UpdateConfiguration added in v1.1.2

type GetConfigurationUpdatesResponse_UpdateConfiguration struct {
	// Updates the operator's configuration.
	UpdateConfiguration *GetConfigurationUpdatesResponse_Configuration `protobuf:"bytes,1,opt,name=update_configuration,json=updateConfiguration,proto3,oneof"`
}

type ICMPv4

type ICMPv4 struct {
	Type uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

ICMPv4 contains the ICMPv4 header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-icmpv4

func (*ICMPv4) Descriptor deprecated

func (*ICMPv4) Descriptor() ([]byte, []int)

Deprecated: Use ICMPv4.ProtoReflect.Descriptor instead.

func (*ICMPv4) GetCode

func (x *ICMPv4) GetCode() uint32

func (*ICMPv4) GetType

func (x *ICMPv4) GetType() uint32

func (*ICMPv4) ProtoMessage

func (*ICMPv4) ProtoMessage()

func (*ICMPv4) ProtoReflect

func (x *ICMPv4) ProtoReflect() protoreflect.Message

func (*ICMPv4) Reset

func (x *ICMPv4) Reset()

func (*ICMPv4) String

func (x *ICMPv4) String() string

type ICMPv6

type ICMPv6 struct {
	Type uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

ICMPv6 contains the ICMPv6 header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-icmpv6

func (*ICMPv6) Descriptor deprecated

func (*ICMPv6) Descriptor() ([]byte, []int)

Deprecated: Use ICMPv6.ProtoReflect.Descriptor instead.

func (*ICMPv6) GetCode

func (x *ICMPv6) GetCode() uint32

func (*ICMPv6) GetType

func (x *ICMPv6) GetType() uint32

func (*ICMPv6) ProtoMessage

func (*ICMPv6) ProtoMessage()

func (*ICMPv6) ProtoReflect

func (x *ICMPv6) ProtoReflect() protoreflect.Message

func (*ICMPv6) Reset

func (x *ICMPv6) Reset()

func (*ICMPv6) String

func (x *ICMPv6) String() string

type IP

type IP struct {
	Source      string    `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination string    `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	IpVersion   IPVersion `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

IP contains the IP header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-ip

func (*IP) Descriptor deprecated

func (*IP) Descriptor() ([]byte, []int)

Deprecated: Use IP.ProtoReflect.Descriptor instead.

func (*IP) GetDestination

func (x *IP) GetDestination() string

func (*IP) GetIpVersion

func (x *IP) GetIpVersion() IPVersion

func (*IP) GetSource

func (x *IP) GetSource() string

func (*IP) ProtoMessage

func (*IP) ProtoMessage()

func (*IP) ProtoReflect

func (x *IP) ProtoReflect() protoreflect.Message

func (*IP) Reset

func (x *IP) Reset()

func (*IP) String

func (x *IP) String() string

type IPVersion

type IPVersion int32

IPVersion contains the IPVersion header flags of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-ipversion

const (
	IPVersion_IP_VERSION_IP_NOT_USED_UNSPECIFIED IPVersion = 0
	IPVersion_IP_VERSION_IPV4                    IPVersion = 1
	IPVersion_IP_VERSION_IPV6                    IPVersion = 2
)

func (IPVersion) Descriptor

func (IPVersion) Descriptor() protoreflect.EnumDescriptor

func (IPVersion) Enum

func (x IPVersion) Enum() *IPVersion

func (IPVersion) EnumDescriptor deprecated

func (IPVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use IPVersion.Descriptor instead.

func (IPVersion) Number

func (x IPVersion) Number() protoreflect.EnumNumber

func (IPVersion) String

func (x IPVersion) String() string

func (IPVersion) Type

type Keepalive added in v1.1.0

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

Application-level keepalives. While gRPC already has an HTTP-level keepalive mechanism, we have seen deployments where the server lives behind an ingress. The gRPC system-level keepalive (represented by the `-`s in the diagram) terminates at the ingress, and thus doesn't work end-to-end. This is solved with an application level keepalive (represented by the `=`s in the diagram)

+----------------+ +---------+ +--------+ | +------>+ + + | | cloud-operator + + ingress + + server | | +======>+ +=========>+ | +----------------+ +---------+ +--------+

Keepalives are important to us, because when the server restarts, the connection may be closed between the Ingress and the server - but not between the cloud-operator and the Ingress. Application-level keepalives will re-establish connections to the server faster than if we wait for reasons to send data over the channel

func (*Keepalive) Descriptor deprecated added in v1.1.0

func (*Keepalive) Descriptor() ([]byte, []int)

Deprecated: Use Keepalive.ProtoReflect.Descriptor instead.

func (*Keepalive) ProtoMessage added in v1.1.0

func (*Keepalive) ProtoMessage()

func (*Keepalive) ProtoReflect added in v1.1.0

func (x *Keepalive) ProtoReflect() protoreflect.Message

func (*Keepalive) Reset added in v1.1.0

func (x *Keepalive) Reset()

func (*Keepalive) String added in v1.1.0

func (x *Keepalive) String() string

type KubernetesClusterMetadata

type KubernetesClusterMetadata struct {

	// Unique ID of the client operator's Kubernetes cluster.
	// This is the UID of the cluster's kube-system namespace, which is considered globally unique.
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// Kubernetes version of the operator's cluster.
	// https://pkg.go.dev/k8s.io/client-go/discovery#DiscoveryClient.ServerVersion
	KubernetesVersion string `protobuf:"bytes,2,opt,name=kubernetes_version,json=kubernetesVersion,proto3" json:"kubernetes_version,omitempty"`
	// Version of the operator. This version is following the Semver 2.0.0 format, e.g. "1.2.0".
	// https://semver.org/spec/v2.0.0.html
	OperatorVersion string `protobuf:"bytes,3,opt,name=operator_version,json=operatorVersion,proto3" json:"operator_version,omitempty"`
	// The network flow collection mechanism configured in the operator's cluster
	FlowCollector FlowCollector `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

Metadata about the client operator and Kubernetes cluster. Sent as the first message in each KubernetesResources RPC request stream.

func (*KubernetesClusterMetadata) Descriptor deprecated

func (*KubernetesClusterMetadata) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesClusterMetadata.ProtoReflect.Descriptor instead.

func (*KubernetesClusterMetadata) GetFlowCollector added in v1.1.2

func (x *KubernetesClusterMetadata) GetFlowCollector() FlowCollector

func (*KubernetesClusterMetadata) GetKubernetesVersion

func (x *KubernetesClusterMetadata) GetKubernetesVersion() string

func (*KubernetesClusterMetadata) GetOperatorVersion

func (x *KubernetesClusterMetadata) GetOperatorVersion() string

func (*KubernetesClusterMetadata) GetUid

func (x *KubernetesClusterMetadata) GetUid() string

func (*KubernetesClusterMetadata) ProtoMessage

func (*KubernetesClusterMetadata) ProtoMessage()

func (*KubernetesClusterMetadata) ProtoReflect

func (*KubernetesClusterMetadata) Reset

func (x *KubernetesClusterMetadata) Reset()

func (*KubernetesClusterMetadata) String

func (x *KubernetesClusterMetadata) String() string

type KubernetesInfoServiceClient

type KubernetesInfoServiceClient interface {
	// Continuously syncs the inventory of the Kubernetes resources in the cluster into CloudSecure.
	SendKubernetesResources(ctx context.Context, opts ...grpc.CallOption) (KubernetesInfoService_SendKubernetesResourcesClient, error)
	// Continuously sends network flows exported by the CNI plugin in the cluster to CloudSecure.
	SendKubernetesNetworkFlows(ctx context.Context, opts ...grpc.CallOption) (KubernetesInfoService_SendKubernetesNetworkFlowsClient, error)
	// Continuously syncs logs from operator and cluster.
	SendLogs(ctx context.Context, opts ...grpc.CallOption) (KubernetesInfoService_SendLogsClient, error)
	// Continuously receives configuration updates from CloudSecure.
	GetConfigurationUpdates(ctx context.Context, opts ...grpc.CallOption) (KubernetesInfoService_GetConfigurationUpdatesClient, error)
}

KubernetesInfoServiceClient is the client API for KubernetesInfoService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type KubernetesInfoServiceServer

type KubernetesInfoServiceServer interface {
	// Continuously syncs the inventory of the Kubernetes resources in the cluster into CloudSecure.
	SendKubernetesResources(KubernetesInfoService_SendKubernetesResourcesServer) error
	// Continuously sends network flows exported by the CNI plugin in the cluster to CloudSecure.
	SendKubernetesNetworkFlows(KubernetesInfoService_SendKubernetesNetworkFlowsServer) error
	// Continuously syncs logs from operator and cluster.
	SendLogs(KubernetesInfoService_SendLogsServer) error
	// Continuously receives configuration updates from CloudSecure.
	GetConfigurationUpdates(KubernetesInfoService_GetConfigurationUpdatesServer) error
	// contains filtered or unexported methods
}

KubernetesInfoServiceServer is the server API for KubernetesInfoService service. All implementations must embed UnimplementedKubernetesInfoServiceServer for forward compatibility

type KubernetesInfoService_GetConfigurationUpdatesClient added in v1.1.2

type KubernetesInfoService_GetConfigurationUpdatesClient interface {
	Send(*GetConfigurationUpdatesRequest) error
	Recv() (*GetConfigurationUpdatesResponse, error)
	grpc.ClientStream
}

type KubernetesInfoService_GetConfigurationUpdatesServer added in v1.1.2

type KubernetesInfoService_GetConfigurationUpdatesServer interface {
	Send(*GetConfigurationUpdatesResponse) error
	Recv() (*GetConfigurationUpdatesRequest, error)
	grpc.ServerStream
}

type KubernetesInfoService_SendKubernetesNetworkFlowsClient

type KubernetesInfoService_SendKubernetesNetworkFlowsClient interface {
	Send(*SendKubernetesNetworkFlowsRequest) error
	Recv() (*SendKubernetesNetworkFlowsResponse, error)
	grpc.ClientStream
}

type KubernetesInfoService_SendKubernetesNetworkFlowsServer

type KubernetesInfoService_SendKubernetesNetworkFlowsServer interface {
	Send(*SendKubernetesNetworkFlowsResponse) error
	Recv() (*SendKubernetesNetworkFlowsRequest, error)
	grpc.ServerStream
}

type KubernetesInfoService_SendKubernetesResourcesClient

type KubernetesInfoService_SendKubernetesResourcesClient interface {
	Send(*SendKubernetesResourcesRequest) error
	Recv() (*SendKubernetesResourcesResponse, error)
	grpc.ClientStream
}

type KubernetesInfoService_SendKubernetesResourcesServer

type KubernetesInfoService_SendKubernetesResourcesServer interface {
	Send(*SendKubernetesResourcesResponse) error
	Recv() (*SendKubernetesResourcesRequest, error)
	grpc.ServerStream
}

type KubernetesInfoService_SendLogsClient

type KubernetesInfoService_SendLogsClient interface {
	Send(*SendLogsRequest) error
	Recv() (*SendLogsResponse, error)
	grpc.ClientStream
}

type KubernetesInfoService_SendLogsServer

type KubernetesInfoService_SendLogsServer interface {
	Send(*SendLogsResponse) error
	Recv() (*SendLogsRequest, error)
	grpc.ServerStream
}

type KubernetesNodeData added in v0.0.11

type KubernetesNodeData struct {

	// Node.spec.providerID
	ProviderId string `protobuf:"bytes,1,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
	// List of ip addresses that are tied to Node so we can resolve them as workloads
	IpAddresses []string `protobuf:"bytes,2,rep,name=ip_addresses,json=ipAddresses,proto3" json:"ip_addresses,omitempty"`
	// contains filtered or unexported fields
}

KubernetesNodeData contains information specific to a Node Object.

func (*KubernetesNodeData) Descriptor deprecated added in v0.0.11

func (*KubernetesNodeData) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesNodeData.ProtoReflect.Descriptor instead.

func (*KubernetesNodeData) GetIpAddresses added in v1.0.5

func (x *KubernetesNodeData) GetIpAddresses() []string

func (*KubernetesNodeData) GetProviderId added in v0.0.11

func (x *KubernetesNodeData) GetProviderId() string

func (*KubernetesNodeData) ProtoMessage added in v0.0.11

func (*KubernetesNodeData) ProtoMessage()

func (*KubernetesNodeData) ProtoReflect added in v0.0.11

func (x *KubernetesNodeData) ProtoReflect() protoreflect.Message

func (*KubernetesNodeData) Reset added in v0.0.11

func (x *KubernetesNodeData) Reset()

func (*KubernetesNodeData) String added in v0.0.11

func (x *KubernetesNodeData) String() string

type KubernetesObjectData added in v0.0.6

type KubernetesObjectData struct {
	Annotations       map[string]string           `` /* 149-byte string literal not displayed */
	CreationTimestamp *timestamppb.Timestamp      `protobuf:"bytes,2,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	Kind              string                      `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	Labels            map[string]string           `` /* 139-byte string literal not displayed */
	Name              string                      `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Namespace         string                      `protobuf:"bytes,6,opt,name=namespace,proto3" json:"namespace,omitempty"`
	OwnerReferences   []*KubernetesOwnerReference `protobuf:"bytes,7,rep,name=owner_references,json=ownerReferences,proto3" json:"owner_references,omitempty"`
	ResourceVersion   string                      `protobuf:"bytes,8,opt,name=resource_version,json=resourceVersion,proto3" json:"resource_version,omitempty"`
	Uid               string                      `protobuf:"bytes,9,opt,name=uid,proto3" json:"uid,omitempty"`
	// Types that are valid to be assigned to KindSpecific:
	//
	//	*KubernetesObjectData_Pod
	//	*KubernetesObjectData_Node
	//	*KubernetesObjectData_Service
	KindSpecific isKubernetesObjectData_KindSpecific `protobuf_oneof:"kind_specific"`
	// contains filtered or unexported fields
}

Metadata associated with a Kubernetes resource. https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.29/#objectmeta-v1-meta

func (*KubernetesObjectData) Descriptor deprecated added in v0.0.6

func (*KubernetesObjectData) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesObjectData.ProtoReflect.Descriptor instead.

func (*KubernetesObjectData) GetAnnotations added in v0.0.6

func (x *KubernetesObjectData) GetAnnotations() map[string]string

func (*KubernetesObjectData) GetCreationTimestamp added in v0.0.6

func (x *KubernetesObjectData) GetCreationTimestamp() *timestamppb.Timestamp

func (*KubernetesObjectData) GetKind added in v0.0.6

func (x *KubernetesObjectData) GetKind() string

func (*KubernetesObjectData) GetKindSpecific added in v0.0.6

func (x *KubernetesObjectData) GetKindSpecific() isKubernetesObjectData_KindSpecific

func (*KubernetesObjectData) GetLabels added in v0.0.6

func (x *KubernetesObjectData) GetLabels() map[string]string

func (*KubernetesObjectData) GetName added in v0.0.6

func (x *KubernetesObjectData) GetName() string

func (*KubernetesObjectData) GetNamespace added in v0.0.6

func (x *KubernetesObjectData) GetNamespace() string

func (*KubernetesObjectData) GetNode added in v0.0.11

func (*KubernetesObjectData) GetOwnerReferences added in v0.0.6

func (x *KubernetesObjectData) GetOwnerReferences() []*KubernetesOwnerReference

func (*KubernetesObjectData) GetPod added in v0.0.6

func (*KubernetesObjectData) GetResourceVersion added in v0.0.6

func (x *KubernetesObjectData) GetResourceVersion() string

func (*KubernetesObjectData) GetService added in v1.0.1

func (*KubernetesObjectData) GetUid added in v0.0.6

func (x *KubernetesObjectData) GetUid() string

func (*KubernetesObjectData) ProtoMessage added in v0.0.6

func (*KubernetesObjectData) ProtoMessage()

func (*KubernetesObjectData) ProtoReflect added in v0.0.6

func (x *KubernetesObjectData) ProtoReflect() protoreflect.Message

func (*KubernetesObjectData) Reset added in v0.0.6

func (x *KubernetesObjectData) Reset()

func (*KubernetesObjectData) String added in v0.0.6

func (x *KubernetesObjectData) String() string

type KubernetesObjectData_Node added in v0.0.11

type KubernetesObjectData_Node struct {
	Node *KubernetesNodeData `protobuf:"bytes,101,opt,name=node,proto3,oneof"`
}

type KubernetesObjectData_Pod added in v0.0.6

type KubernetesObjectData_Pod struct {
	Pod *KubernetesPodData `protobuf:"bytes,100,opt,name=pod,proto3,oneof"`
}

type KubernetesObjectData_Service added in v1.0.1

type KubernetesObjectData_Service struct {
	Service *KubernetesServiceData `protobuf:"bytes,102,opt,name=service,proto3,oneof"`
}

type KubernetesOwnerReference

type KubernetesOwnerReference struct {
	ApiVersion         string `protobuf:"bytes,1,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	BlockOwnerDeletion bool   `protobuf:"varint,2,opt,name=block_owner_deletion,json=blockOwnerDeletion,proto3" json:"block_owner_deletion,omitempty"`
	Controller         bool   `protobuf:"varint,3,opt,name=controller,proto3" json:"controller,omitempty"`
	Kind               string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	Name               string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Uid                string `protobuf:"bytes,6,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

Information identifying an object owning a Kubernetes resource. https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.29/#ownerreference-v1-meta

func (*KubernetesOwnerReference) Descriptor deprecated

func (*KubernetesOwnerReference) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesOwnerReference.ProtoReflect.Descriptor instead.

func (*KubernetesOwnerReference) GetApiVersion

func (x *KubernetesOwnerReference) GetApiVersion() string

func (*KubernetesOwnerReference) GetBlockOwnerDeletion

func (x *KubernetesOwnerReference) GetBlockOwnerDeletion() bool

func (*KubernetesOwnerReference) GetController

func (x *KubernetesOwnerReference) GetController() bool

func (*KubernetesOwnerReference) GetKind

func (x *KubernetesOwnerReference) GetKind() string

func (*KubernetesOwnerReference) GetName

func (x *KubernetesOwnerReference) GetName() string

func (*KubernetesOwnerReference) GetUid

func (x *KubernetesOwnerReference) GetUid() string

func (*KubernetesOwnerReference) ProtoMessage

func (*KubernetesOwnerReference) ProtoMessage()

func (*KubernetesOwnerReference) ProtoReflect

func (x *KubernetesOwnerReference) ProtoReflect() protoreflect.Message

func (*KubernetesOwnerReference) Reset

func (x *KubernetesOwnerReference) Reset()

func (*KubernetesOwnerReference) String

func (x *KubernetesOwnerReference) String() string

type KubernetesPodData added in v0.0.6

type KubernetesPodData struct {
	IpAddresses []string `protobuf:"bytes,1,rep,name=ip_addresses,json=ipAddresses,proto3" json:"ip_addresses,omitempty"`
	// contains filtered or unexported fields
}

KubernetesPodData contains information specific to a Pod object. It currently holds the IP addresses allocated to a pod. If this field is specified, the 0th entry must match the podIP field. A Pod may be allocated at most 1 value for each of IPv4 and IPv6. This list is empty if no IPs have been allocated yet.

func (*KubernetesPodData) Descriptor deprecated added in v0.0.6

func (*KubernetesPodData) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesPodData.ProtoReflect.Descriptor instead.

func (*KubernetesPodData) GetIpAddresses added in v0.0.6

func (x *KubernetesPodData) GetIpAddresses() []string

func (*KubernetesPodData) ProtoMessage added in v0.0.6

func (*KubernetesPodData) ProtoMessage()

func (*KubernetesPodData) ProtoReflect added in v0.0.6

func (x *KubernetesPodData) ProtoReflect() protoreflect.Message

func (*KubernetesPodData) Reset added in v0.0.6

func (x *KubernetesPodData) Reset()

func (*KubernetesPodData) String added in v0.0.6

func (x *KubernetesPodData) String() string

type KubernetesResourceMutation

type KubernetesResourceMutation struct {

	// Send any of these "mutation" messages that can contain any of
	// The documented types
	//
	// Types that are valid to be assigned to Mutation:
	//
	//	*KubernetesResourceMutation_CreateResource
	//	*KubernetesResourceMutation_UpdateResource
	//	*KubernetesResourceMutation_DeleteResource
	Mutation isKubernetesResourceMutation_Mutation `protobuf_oneof:"mutation"`
	// contains filtered or unexported fields
}

A mutation to a Kubernetes resource in the cluster. Each mutation contains the full resource metadata after mutation (on create or update) or before mutation (on delete).

func (*KubernetesResourceMutation) Descriptor deprecated

func (*KubernetesResourceMutation) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesResourceMutation.ProtoReflect.Descriptor instead.

func (*KubernetesResourceMutation) GetCreateResource

func (x *KubernetesResourceMutation) GetCreateResource() *KubernetesObjectData

func (*KubernetesResourceMutation) GetDeleteResource

func (x *KubernetesResourceMutation) GetDeleteResource() *KubernetesObjectData

func (*KubernetesResourceMutation) GetMutation

func (x *KubernetesResourceMutation) GetMutation() isKubernetesResourceMutation_Mutation

func (*KubernetesResourceMutation) GetUpdateResource

func (x *KubernetesResourceMutation) GetUpdateResource() *KubernetesObjectData

func (*KubernetesResourceMutation) ProtoMessage

func (*KubernetesResourceMutation) ProtoMessage()

func (*KubernetesResourceMutation) ProtoReflect

func (*KubernetesResourceMutation) Reset

func (x *KubernetesResourceMutation) Reset()

func (*KubernetesResourceMutation) String

func (x *KubernetesResourceMutation) String() string

type KubernetesResourceMutation_CreateResource

type KubernetesResourceMutation_CreateResource struct {
	// Metadata of a newly created Kubernetes resource.
	CreateResource *KubernetesObjectData `protobuf:"bytes,1,opt,name=create_resource,json=createResource,proto3,oneof"`
}

type KubernetesResourceMutation_DeleteResource

type KubernetesResourceMutation_DeleteResource struct {
	// Metadata of a deleted Kubernetes resource, before deletion.
	DeleteResource *KubernetesObjectData `protobuf:"bytes,3,opt,name=delete_resource,json=deleteResource,proto3,oneof"`
}

type KubernetesResourceMutation_UpdateResource

type KubernetesResourceMutation_UpdateResource struct {
	// Metadata of an updated Kubernetes resource, after update.
	UpdateResource *KubernetesObjectData `protobuf:"bytes,2,opt,name=update_resource,json=updateResource,proto3,oneof"`
}

type KubernetesResourceSnapshotComplete

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

Empty on purpose since this type is just expected when snapshot stream is done.

func (*KubernetesResourceSnapshotComplete) Descriptor deprecated

func (*KubernetesResourceSnapshotComplete) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesResourceSnapshotComplete.ProtoReflect.Descriptor instead.

func (*KubernetesResourceSnapshotComplete) ProtoMessage

func (*KubernetesResourceSnapshotComplete) ProtoMessage()

func (*KubernetesResourceSnapshotComplete) ProtoReflect

func (*KubernetesResourceSnapshotComplete) Reset

func (*KubernetesResourceSnapshotComplete) String

type KubernetesServiceData added in v1.0.1

type KubernetesServiceData struct {

	// List of IP addresses associated with the Kubernetes service
	IpAddresses []string `protobuf:"bytes,1,rep,name=ip_addresses,json=ipAddresses,proto3" json:"ip_addresses,omitempty"`
	// List of service ports details
	Ports []*KubernetesServiceData_ServicePort `protobuf:"bytes,2,rep,name=ports,proto3" json:"ports,omitempty"`
	// Type of Kubernetes service (e.g., ClusterIP, NodePort, LoadBalancer, etc.)
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// The external reference that discovery mechanisms will
	// return as an alias for this service
	ExternalName *string `protobuf:"bytes,4,opt,name=external_name,json=externalName,proto3,oneof" json:"external_name,omitempty"`
	// The class of the load balancer implementation this Service belongs to
	LoadBalancerClass *string `protobuf:"bytes,5,opt,name=load_balancer_class,json=loadBalancerClass,proto3,oneof" json:"load_balancer_class,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesServiceData) Descriptor deprecated added in v1.0.1

func (*KubernetesServiceData) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesServiceData.ProtoReflect.Descriptor instead.

func (*KubernetesServiceData) GetExternalName added in v1.0.1

func (x *KubernetesServiceData) GetExternalName() string

func (*KubernetesServiceData) GetIpAddresses added in v1.0.1

func (x *KubernetesServiceData) GetIpAddresses() []string

func (*KubernetesServiceData) GetLoadBalancerClass added in v1.0.1

func (x *KubernetesServiceData) GetLoadBalancerClass() string

func (*KubernetesServiceData) GetPorts added in v1.0.1

func (*KubernetesServiceData) GetType added in v1.0.1

func (x *KubernetesServiceData) GetType() string

func (*KubernetesServiceData) ProtoMessage added in v1.0.1

func (*KubernetesServiceData) ProtoMessage()

func (*KubernetesServiceData) ProtoReflect added in v1.0.1

func (x *KubernetesServiceData) ProtoReflect() protoreflect.Message

func (*KubernetesServiceData) Reset added in v1.0.1

func (x *KubernetesServiceData) Reset()

func (*KubernetesServiceData) String added in v1.0.1

func (x *KubernetesServiceData) String() string

type KubernetesServiceData_ServicePort added in v1.0.1

type KubernetesServiceData_ServicePort struct {

	// The port on each node on which this service is exposed
	NodePort *uint32 `protobuf:"varint,1,opt,name=node_port,json=nodePort,proto3,oneof" json:"node_port,omitempty"`
	// The port that will be exposed by this service
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// The IP protocol for this port, supports "TCP", "UDP", and "SCTP"
	Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// List of ports exposing the service via a load balancer
	LoadBalancerPorts []string `protobuf:"bytes,4,rep,name=load_balancer_ports,json=loadBalancerPorts,proto3" json:"load_balancer_ports,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesServiceData_ServicePort) Descriptor deprecated added in v1.0.1

func (*KubernetesServiceData_ServicePort) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesServiceData_ServicePort.ProtoReflect.Descriptor instead.

func (*KubernetesServiceData_ServicePort) GetLoadBalancerPorts added in v1.0.1

func (x *KubernetesServiceData_ServicePort) GetLoadBalancerPorts() []string

func (*KubernetesServiceData_ServicePort) GetNodePort added in v1.0.1

func (x *KubernetesServiceData_ServicePort) GetNodePort() uint32

func (*KubernetesServiceData_ServicePort) GetPort added in v1.0.1

func (*KubernetesServiceData_ServicePort) GetProtocol added in v1.0.1

func (x *KubernetesServiceData_ServicePort) GetProtocol() string

func (*KubernetesServiceData_ServicePort) ProtoMessage added in v1.0.1

func (*KubernetesServiceData_ServicePort) ProtoMessage()

func (*KubernetesServiceData_ServicePort) ProtoReflect added in v1.0.1

func (*KubernetesServiceData_ServicePort) Reset added in v1.0.1

func (*KubernetesServiceData_ServicePort) String added in v1.0.1

type Layer4

type Layer4 struct {

	// Types that are valid to be assigned to Protocol:
	//
	//	*Layer4_Tcp
	//	*Layer4_Udp
	//	*Layer4_Icmpv4
	//	*Layer4_Icmpv6
	//	*Layer4_Sctp
	Protocol isLayer4_Protocol `protobuf_oneof:"protocol"`
	// contains filtered or unexported fields
}

Layer4 contains the Layer-4 header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-layer4

func (*Layer4) Descriptor deprecated

func (*Layer4) Descriptor() ([]byte, []int)

Deprecated: Use Layer4.ProtoReflect.Descriptor instead.

func (*Layer4) GetIcmpv4

func (x *Layer4) GetIcmpv4() *ICMPv4

func (*Layer4) GetIcmpv6

func (x *Layer4) GetIcmpv6() *ICMPv6

func (*Layer4) GetProtocol

func (x *Layer4) GetProtocol() isLayer4_Protocol

func (*Layer4) GetSctp

func (x *Layer4) GetSctp() *SCTP

func (*Layer4) GetTcp

func (x *Layer4) GetTcp() *TCP

func (*Layer4) GetUdp

func (x *Layer4) GetUdp() *UDP

func (*Layer4) ProtoMessage

func (*Layer4) ProtoMessage()

func (*Layer4) ProtoReflect

func (x *Layer4) ProtoReflect() protoreflect.Message

func (*Layer4) Reset

func (x *Layer4) Reset()

func (*Layer4) String

func (x *Layer4) String() string

type Layer4_Icmpv4

type Layer4_Icmpv4 struct {
	// ICMP is technically not L4, but mutually exclusive with the above.
	Icmpv4 *ICMPv4 `protobuf:"bytes,3,opt,name=icmpv4,proto3,oneof"`
}

type Layer4_Icmpv6

type Layer4_Icmpv6 struct {
	Icmpv6 *ICMPv6 `protobuf:"bytes,4,opt,name=icmpv6,proto3,oneof"`
}

type Layer4_Sctp

type Layer4_Sctp struct {
	Sctp *SCTP `protobuf:"bytes,5,opt,name=sctp,proto3,oneof"`
}

type Layer4_Tcp

type Layer4_Tcp struct {
	Tcp *TCP `protobuf:"bytes,1,opt,name=tcp,proto3,oneof"`
}

type Layer4_Udp

type Layer4_Udp struct {
	Udp *UDP `protobuf:"bytes,2,opt,name=udp,proto3,oneof"`
}

type LogEntry

type LogEntry struct {

	// The actual log message contents, as a JSON object.
	JsonMessage string `protobuf:"bytes,3,opt,name=json_message,json=jsonMessage,proto3" json:"json_message,omitempty"`
	// contains filtered or unexported fields
}

Message representing a log entry.

func (*LogEntry) Descriptor deprecated

func (*LogEntry) Descriptor() ([]byte, []int)

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetJsonMessage

func (x *LogEntry) GetJsonMessage() string

func (*LogEntry) ProtoMessage

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect

func (x *LogEntry) ProtoReflect() protoreflect.Message

func (*LogEntry) Reset

func (x *LogEntry) Reset()

func (*LogEntry) String

func (x *LogEntry) String() string

type LogLevel

type LogLevel int32

Enumeration to define the different levels of logging.

const (
	// Default unspecified log level.
	LogLevel_LOG_LEVEL_UNSPECIFIED LogLevel = 0
	// Debug log level, useful for development and troubleshooting.
	LogLevel_LOG_LEVEL_DEBUG LogLevel = 1
	// Informational log level for general application information.
	LogLevel_LOG_LEVEL_INFO LogLevel = 2
	// Warning log level for potentially problematic situations.
	LogLevel_LOG_LEVEL_WARN LogLevel = 3
	// Error log level indicating something went wrong.
	LogLevel_LOG_LEVEL_ERROR LogLevel = 4
)

func (LogLevel) Descriptor

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated

func (LogLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String

func (x LogLevel) String() string

func (LogLevel) Type

type Policy

type Policy struct {
	Name      string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels    []string `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	Revision  uint64   `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

Policy contains the Policy header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-policy

func (*Policy) Descriptor deprecated

func (*Policy) Descriptor() ([]byte, []int)

Deprecated: Use Policy.ProtoReflect.Descriptor instead.

func (*Policy) GetLabels

func (x *Policy) GetLabels() []string

func (*Policy) GetName

func (x *Policy) GetName() string

func (*Policy) GetNamespace

func (x *Policy) GetNamespace() string

func (*Policy) GetRevision

func (x *Policy) GetRevision() uint64

func (*Policy) ProtoMessage

func (*Policy) ProtoMessage()

func (*Policy) ProtoReflect

func (x *Policy) ProtoReflect() protoreflect.Message

func (*Policy) Reset

func (x *Policy) Reset()

func (*Policy) String

func (x *Policy) String() string

type SCTP

type SCTP struct {
	SourcePort      uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	DestinationPort uint32 `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	// contains filtered or unexported fields
}

SCTP contains the SCTP header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-sctp

func (*SCTP) Descriptor deprecated

func (*SCTP) Descriptor() ([]byte, []int)

Deprecated: Use SCTP.ProtoReflect.Descriptor instead.

func (*SCTP) GetDestinationPort

func (x *SCTP) GetDestinationPort() uint32

func (*SCTP) GetSourcePort

func (x *SCTP) GetSourcePort() uint32

func (*SCTP) ProtoMessage

func (*SCTP) ProtoMessage()

func (*SCTP) ProtoReflect

func (x *SCTP) ProtoReflect() protoreflect.Message

func (*SCTP) Reset

func (x *SCTP) Reset()

func (*SCTP) String

func (x *SCTP) String() string

type SendKubernetesNetworkFlowsRequest

type SendKubernetesNetworkFlowsRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*SendKubernetesNetworkFlowsRequest_Keepalive
	//	*SendKubernetesNetworkFlowsRequest_CiliumFlow
	//	*SendKubernetesNetworkFlowsRequest_FalcoFlow
	Request isSendKubernetesNetworkFlowsRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

Flow exported by the CNI plugin in the cluster.

func (*SendKubernetesNetworkFlowsRequest) Descriptor deprecated

func (*SendKubernetesNetworkFlowsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendKubernetesNetworkFlowsRequest.ProtoReflect.Descriptor instead.

func (*SendKubernetesNetworkFlowsRequest) GetCiliumFlow

func (x *SendKubernetesNetworkFlowsRequest) GetCiliumFlow() *CiliumFlow

func (*SendKubernetesNetworkFlowsRequest) GetFalcoFlow added in v0.0.8

func (x *SendKubernetesNetworkFlowsRequest) GetFalcoFlow() *FalcoFlow

func (*SendKubernetesNetworkFlowsRequest) GetKeepalive added in v1.1.0

func (x *SendKubernetesNetworkFlowsRequest) GetKeepalive() *Keepalive

func (*SendKubernetesNetworkFlowsRequest) GetRequest

func (x *SendKubernetesNetworkFlowsRequest) GetRequest() isSendKubernetesNetworkFlowsRequest_Request

func (*SendKubernetesNetworkFlowsRequest) ProtoMessage

func (*SendKubernetesNetworkFlowsRequest) ProtoMessage()

func (*SendKubernetesNetworkFlowsRequest) ProtoReflect

func (*SendKubernetesNetworkFlowsRequest) Reset

func (*SendKubernetesNetworkFlowsRequest) String

type SendKubernetesNetworkFlowsRequest_CiliumFlow

type SendKubernetesNetworkFlowsRequest_CiliumFlow struct {
	CiliumFlow *CiliumFlow `protobuf:"bytes,1,opt,name=cilium_flow,json=ciliumFlow,proto3,oneof"`
}

type SendKubernetesNetworkFlowsRequest_FalcoFlow added in v0.0.8

type SendKubernetesNetworkFlowsRequest_FalcoFlow struct {
	FalcoFlow *FalcoFlow `protobuf:"bytes,2,opt,name=falco_flow,json=falcoFlow,proto3,oneof"`
}

type SendKubernetesNetworkFlowsRequest_Keepalive added in v1.1.0

type SendKubernetesNetworkFlowsRequest_Keepalive struct {
	Keepalive *Keepalive `protobuf:"bytes,3,opt,name=keepalive,proto3,oneof"`
}

type SendKubernetesNetworkFlowsResponse

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

Message sent to the operator in a SendKubernetesNetworkFlows response stream.

func (*SendKubernetesNetworkFlowsResponse) Descriptor deprecated

func (*SendKubernetesNetworkFlowsResponse) Descriptor() ([]byte, []int)

Deprecated: Use SendKubernetesNetworkFlowsResponse.ProtoReflect.Descriptor instead.

func (*SendKubernetesNetworkFlowsResponse) ProtoMessage

func (*SendKubernetesNetworkFlowsResponse) ProtoMessage()

func (*SendKubernetesNetworkFlowsResponse) ProtoReflect

func (*SendKubernetesNetworkFlowsResponse) Reset

func (*SendKubernetesNetworkFlowsResponse) String

type SendKubernetesResourcesRequest

type SendKubernetesResourcesRequest struct {

	// Send any of these "request" messages that can contain any of the documented types.
	//
	// Types that are valid to be assigned to Request:
	//
	//	*SendKubernetesResourcesRequest_Keepalive
	//	*SendKubernetesResourcesRequest_ClusterMetadata
	//	*SendKubernetesResourcesRequest_ResourceData
	//	*SendKubernetesResourcesRequest_ResourceSnapshotComplete
	//	*SendKubernetesResourcesRequest_KubernetesResourceMutation
	Request isSendKubernetesResourcesRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

Message sent by the operator in a KubernetesResources request stream. Message subtypes are sent in this order in each stream: 1. (1) cluster_metadata, to identify the client cluster and operator. 2. (0+) resource_metadata, one message for each resource in the cluster. 3. (1) resource_snapshot_complete, to indicate the initial snapshot of all resources in the cluster is complete. 4. (0+) resource_mutation, one message for each resource creation/update/deletion in the cluster.

func (*SendKubernetesResourcesRequest) Descriptor deprecated

func (*SendKubernetesResourcesRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendKubernetesResourcesRequest.ProtoReflect.Descriptor instead.

func (*SendKubernetesResourcesRequest) GetClusterMetadata

func (*SendKubernetesResourcesRequest) GetKeepalive added in v1.1.0

func (x *SendKubernetesResourcesRequest) GetKeepalive() *Keepalive

func (*SendKubernetesResourcesRequest) GetKubernetesResourceMutation

func (x *SendKubernetesResourcesRequest) GetKubernetesResourceMutation() *KubernetesResourceMutation

func (*SendKubernetesResourcesRequest) GetRequest

func (x *SendKubernetesResourcesRequest) GetRequest() isSendKubernetesResourcesRequest_Request

func (*SendKubernetesResourcesRequest) GetResourceData added in v0.0.6

func (*SendKubernetesResourcesRequest) GetResourceSnapshotComplete

func (x *SendKubernetesResourcesRequest) GetResourceSnapshotComplete() *KubernetesResourceSnapshotComplete

func (*SendKubernetesResourcesRequest) ProtoMessage

func (*SendKubernetesResourcesRequest) ProtoMessage()

func (*SendKubernetesResourcesRequest) ProtoReflect

func (*SendKubernetesResourcesRequest) Reset

func (x *SendKubernetesResourcesRequest) Reset()

func (*SendKubernetesResourcesRequest) String

type SendKubernetesResourcesRequest_ClusterMetadata

type SendKubernetesResourcesRequest_ClusterMetadata struct {
	// Metadata about the cluster and operator.
	ClusterMetadata *KubernetesClusterMetadata `protobuf:"bytes,1,opt,name=cluster_metadata,json=clusterMetadata,proto3,oneof"`
}

type SendKubernetesResourcesRequest_Keepalive added in v1.1.0

type SendKubernetesResourcesRequest_Keepalive struct {
	Keepalive *Keepalive `protobuf:"bytes,5,opt,name=keepalive,proto3,oneof"`
}

type SendKubernetesResourcesRequest_KubernetesResourceMutation

type SendKubernetesResourcesRequest_KubernetesResourceMutation struct {
	// A mutation to a Kubernetes resource in the cluster.
	KubernetesResourceMutation *KubernetesResourceMutation `protobuf:"bytes,4,opt,name=kubernetes_resource_mutation,json=kubernetesResourceMutation,proto3,oneof"`
}

type SendKubernetesResourcesRequest_ResourceData added in v0.0.6

type SendKubernetesResourcesRequest_ResourceData struct {
	// Metadata about a Kubernetes resource in the cluster.
	ResourceData *KubernetesObjectData `protobuf:"bytes,2,opt,name=resource_data,json=resourceData,proto3,oneof"`
}

type SendKubernetesResourcesRequest_ResourceSnapshotComplete

type SendKubernetesResourcesRequest_ResourceSnapshotComplete struct {
	// Indicates that all resource_metadata have been sent to report all the resources in the cluster in the initial snapshot.
	ResourceSnapshotComplete *KubernetesResourceSnapshotComplete `protobuf:"bytes,3,opt,name=resource_snapshot_complete,json=resourceSnapshotComplete,proto3,oneof"`
}

type SendKubernetesResourcesResponse

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

Message sent to the operator in a KubernetesResources response stream.

func (*SendKubernetesResourcesResponse) Descriptor deprecated

func (*SendKubernetesResourcesResponse) Descriptor() ([]byte, []int)

Deprecated: Use SendKubernetesResourcesResponse.ProtoReflect.Descriptor instead.

func (*SendKubernetesResourcesResponse) ProtoMessage

func (*SendKubernetesResourcesResponse) ProtoMessage()

func (*SendKubernetesResourcesResponse) ProtoReflect

func (*SendKubernetesResourcesResponse) Reset

func (*SendKubernetesResourcesResponse) String

type SendLogsRequest

type SendLogsRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*SendLogsRequest_Keepalive
	//	*SendLogsRequest_LogEntry
	Request isSendLogsRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

Message to encapsulate a request to send logs.

func (*SendLogsRequest) Descriptor deprecated

func (*SendLogsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendLogsRequest.ProtoReflect.Descriptor instead.

func (*SendLogsRequest) GetKeepalive added in v1.1.0

func (x *SendLogsRequest) GetKeepalive() *Keepalive

func (*SendLogsRequest) GetLogEntry

func (x *SendLogsRequest) GetLogEntry() *LogEntry

func (*SendLogsRequest) GetRequest

func (x *SendLogsRequest) GetRequest() isSendLogsRequest_Request

func (*SendLogsRequest) ProtoMessage

func (*SendLogsRequest) ProtoMessage()

func (*SendLogsRequest) ProtoReflect

func (x *SendLogsRequest) ProtoReflect() protoreflect.Message

func (*SendLogsRequest) Reset

func (x *SendLogsRequest) Reset()

func (*SendLogsRequest) String

func (x *SendLogsRequest) String() string

type SendLogsRequest_Keepalive added in v1.1.0

type SendLogsRequest_Keepalive struct {
	Keepalive *Keepalive `protobuf:"bytes,2,opt,name=keepalive,proto3,oneof"`
}

type SendLogsRequest_LogEntry

type SendLogsRequest_LogEntry struct {
	// A single log entry to be sent.
	LogEntry *LogEntry `protobuf:"bytes,1,opt,name=log_entry,json=logEntry,proto3,oneof"`
}

type SendLogsResponse

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

Message to encapsulate the response for sending logs.

func (*SendLogsResponse) Descriptor deprecated

func (*SendLogsResponse) Descriptor() ([]byte, []int)

Deprecated: Use SendLogsResponse.ProtoReflect.Descriptor instead.

func (*SendLogsResponse) ProtoMessage

func (*SendLogsResponse) ProtoMessage()

func (*SendLogsResponse) ProtoReflect

func (x *SendLogsResponse) ProtoReflect() protoreflect.Message

func (*SendLogsResponse) Reset

func (x *SendLogsResponse) Reset()

func (*SendLogsResponse) String

func (x *SendLogsResponse) String() string

type Service

type Service struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

Service contains Service header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#Service

func (*Service) Descriptor deprecated

func (*Service) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetName

func (x *Service) GetName() string

func (*Service) GetNamespace

func (x *Service) GetNamespace() string

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

func (x *Service) ProtoReflect() protoreflect.Message

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

type TCP

type TCP struct {
	SourcePort      uint32    `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	DestinationPort uint32    `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	Flags           *TCPFlags `protobuf:"bytes,3,opt,name=flags,proto3" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

TCP contains the TCP header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-tcp

func (*TCP) Descriptor deprecated

func (*TCP) Descriptor() ([]byte, []int)

Deprecated: Use TCP.ProtoReflect.Descriptor instead.

func (*TCP) GetDestinationPort

func (x *TCP) GetDestinationPort() uint32

func (*TCP) GetFlags

func (x *TCP) GetFlags() *TCPFlags

func (*TCP) GetSourcePort

func (x *TCP) GetSourcePort() uint32

func (*TCP) ProtoMessage

func (*TCP) ProtoMessage()

func (*TCP) ProtoReflect

func (x *TCP) ProtoReflect() protoreflect.Message

func (*TCP) Reset

func (x *TCP) Reset()

func (*TCP) String

func (x *TCP) String() string

type TCPFlags

type TCPFlags struct {
	Fin bool `protobuf:"varint,1,opt,name=fin,proto3" json:"fin,omitempty"`
	Syn bool `protobuf:"varint,2,opt,name=syn,proto3" json:"syn,omitempty"`
	Rst bool `protobuf:"varint,3,opt,name=rst,proto3" json:"rst,omitempty"`
	Psh bool `protobuf:"varint,4,opt,name=psh,proto3" json:"psh,omitempty"`
	Ack bool `protobuf:"varint,5,opt,name=ack,proto3" json:"ack,omitempty"`
	Urg bool `protobuf:"varint,6,opt,name=urg,proto3" json:"urg,omitempty"`
	Ece bool `protobuf:"varint,7,opt,name=ece,proto3" json:"ece,omitempty"`
	Cwr bool `protobuf:"varint,8,opt,name=cwr,proto3" json:"cwr,omitempty"`
	Ns  bool `protobuf:"varint,9,opt,name=ns,proto3" json:"ns,omitempty"`
	// contains filtered or unexported fields
}

TCPFlags is the mask of TCP header flags observed in TCP packets in a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-tcpflags

func (*TCPFlags) Descriptor deprecated

func (*TCPFlags) Descriptor() ([]byte, []int)

Deprecated: Use TCPFlags.ProtoReflect.Descriptor instead.

func (*TCPFlags) GetAck

func (x *TCPFlags) GetAck() bool

func (*TCPFlags) GetCwr

func (x *TCPFlags) GetCwr() bool

func (*TCPFlags) GetEce

func (x *TCPFlags) GetEce() bool

func (*TCPFlags) GetFin

func (x *TCPFlags) GetFin() bool

func (*TCPFlags) GetNs

func (x *TCPFlags) GetNs() bool

func (*TCPFlags) GetPsh

func (x *TCPFlags) GetPsh() bool

func (*TCPFlags) GetRst

func (x *TCPFlags) GetRst() bool

func (*TCPFlags) GetSyn

func (x *TCPFlags) GetSyn() bool

func (*TCPFlags) GetUrg

func (x *TCPFlags) GetUrg() bool

func (*TCPFlags) ProtoMessage

func (*TCPFlags) ProtoMessage()

func (*TCPFlags) ProtoReflect

func (x *TCPFlags) ProtoReflect() protoreflect.Message

func (*TCPFlags) Reset

func (x *TCPFlags) Reset()

func (*TCPFlags) String

func (x *TCPFlags) String() string

type TrafficDirection

type TrafficDirection int32

TrafficDirection contains TrafficDirectopm header flags of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-trafficdirection

const (
	TrafficDirection_TRAFFIC_DIRECTION_TRAFFIC_DIRECTION_UNKNOWN_UNSPECIFIED TrafficDirection = 0
	TrafficDirection_TRAFFIC_DIRECTION_INGRESS                               TrafficDirection = 1
	TrafficDirection_TRAFFIC_DIRECTION_EGRESS                                TrafficDirection = 2
)

func (TrafficDirection) Descriptor

func (TrafficDirection) Enum

func (TrafficDirection) EnumDescriptor deprecated

func (TrafficDirection) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrafficDirection.Descriptor instead.

func (TrafficDirection) Number

func (TrafficDirection) String

func (x TrafficDirection) String() string

func (TrafficDirection) Type

type UDP

type UDP struct {
	SourcePort      uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	DestinationPort uint32 `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	// contains filtered or unexported fields
}

UDP contains the UDP header fields of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-udp

func (*UDP) Descriptor deprecated

func (*UDP) Descriptor() ([]byte, []int)

Deprecated: Use UDP.ProtoReflect.Descriptor instead.

func (*UDP) GetDestinationPort

func (x *UDP) GetDestinationPort() uint32

func (*UDP) GetSourcePort

func (x *UDP) GetSourcePort() uint32

func (*UDP) ProtoMessage

func (*UDP) ProtoMessage()

func (*UDP) ProtoReflect

func (x *UDP) ProtoReflect() protoreflect.Message

func (*UDP) Reset

func (x *UDP) Reset()

func (*UDP) String

func (x *UDP) String() string

type UnimplementedKubernetesInfoServiceServer

type UnimplementedKubernetesInfoServiceServer struct {
}

UnimplementedKubernetesInfoServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedKubernetesInfoServiceServer) GetConfigurationUpdates added in v1.1.2

func (UnimplementedKubernetesInfoServiceServer) SendKubernetesNetworkFlows

func (UnimplementedKubernetesInfoServiceServer) SendKubernetesResources

func (UnimplementedKubernetesInfoServiceServer) SendLogs

type UnsafeKubernetesInfoServiceServer

type UnsafeKubernetesInfoServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeKubernetesInfoServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KubernetesInfoServiceServer will result in compilation errors.

type Verdict

type Verdict int32

Verdict contains Verdict header flags of a flow. https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-verdict

const (
	Verdict_VERDICT_UNKNOWN_UNSPECIFIED Verdict = 0
	Verdict_VERDICT_FORWARDED           Verdict = 1
	Verdict_VERDICT_DROPPED             Verdict = 2
	Verdict_VERDICT_ERROR               Verdict = 3
	Verdict_VERDICT_AUDIT               Verdict = 4
	Verdict_VERDICT_REDIRECTED          Verdict = 5
	Verdict_VERDICT_TRACED              Verdict = 6
	Verdict_VERDICT_TRANSLATED          Verdict = 7
)

func (Verdict) Descriptor

func (Verdict) Descriptor() protoreflect.EnumDescriptor

func (Verdict) Enum

func (x Verdict) Enum() *Verdict

func (Verdict) EnumDescriptor deprecated

func (Verdict) EnumDescriptor() ([]byte, []int)

Deprecated: Use Verdict.Descriptor instead.

func (Verdict) Number

func (x Verdict) Number() protoreflect.EnumNumber

func (Verdict) String

func (x Verdict) String() string

func (Verdict) Type

func (Verdict) Type() protoreflect.EnumType

type Workload

type Workload struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

Workload contains the Workload header fields of a flow https://pkg.go.dev/github.com/cilium/cilium/api/v1/flow#readme-workload

func (*Workload) Descriptor deprecated

func (*Workload) Descriptor() ([]byte, []int)

Deprecated: Use Workload.ProtoReflect.Descriptor instead.

func (*Workload) GetKind

func (x *Workload) GetKind() string

func (*Workload) GetName

func (x *Workload) GetName() string

func (*Workload) ProtoMessage

func (*Workload) ProtoMessage()

func (*Workload) ProtoReflect

func (x *Workload) ProtoReflect() protoreflect.Message

func (*Workload) Reset

func (x *Workload) Reset()

func (*Workload) String

func (x *Workload) String() string

Jump to

Keyboard shortcuts

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