Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterKubernetesInfoServiceServer(s grpc.ServiceRegistrar, srv KubernetesInfoServiceServer)
- type CiliumFlow
- func (*CiliumFlow) Descriptor() ([]byte, []int)deprecated
- func (x *CiliumFlow) GetDestinationEndpoint() *Endpoint
- func (x *CiliumFlow) GetDestinationService() *Service
- func (x *CiliumFlow) GetEgressAllowedBy() []*Policy
- func (x *CiliumFlow) GetEgressDeniedBy() []*Policy
- func (x *CiliumFlow) GetIngressAllowedBy() []*Policy
- func (x *CiliumFlow) GetIngressDeniedBy() []*Policy
- func (x *CiliumFlow) GetIsReply() *wrapperspb.BoolValue
- func (x *CiliumFlow) GetLayer3() *IP
- func (x *CiliumFlow) GetLayer4() *Layer4
- func (x *CiliumFlow) GetNodeName() string
- func (x *CiliumFlow) GetSourceEndpoint() *Endpoint
- func (x *CiliumFlow) GetTime() *timestamppb.Timestamp
- func (x *CiliumFlow) GetTrafficDirection() TrafficDirection
- func (x *CiliumFlow) GetVerdict() Verdict
- func (flow *CiliumFlow) Key() any
- func (*CiliumFlow) ProtoMessage()
- func (x *CiliumFlow) ProtoReflect() protoreflect.Message
- func (x *CiliumFlow) Reset()
- func (flow *CiliumFlow) StartTimestamp() time.Time
- func (x *CiliumFlow) String() string
- type CiliumFlowKey
- type Endpoint
- func (*Endpoint) Descriptor() ([]byte, []int)deprecated
- func (x *Endpoint) GetClusterName() string
- func (x *Endpoint) GetLabels() []string
- func (x *Endpoint) GetNamespace() string
- func (x *Endpoint) GetPodName() string
- func (x *Endpoint) GetUid() uint32
- func (x *Endpoint) GetWorkloads() []*Workload
- func (*Endpoint) ProtoMessage()
- func (x *Endpoint) ProtoReflect() protoreflect.Message
- func (x *Endpoint) Reset()
- func (x *Endpoint) String() string
- type FiveTupleFlow
- func (*FiveTupleFlow) Descriptor() ([]byte, []int)deprecated
- func (x *FiveTupleFlow) GetLayer3() *IP
- func (x *FiveTupleFlow) GetLayer4() *Layer4
- func (x *FiveTupleFlow) GetTime() stringdeprecated
- func (x *FiveTupleFlow) GetTimestamp() *timestamppb.Timestamp
- func (x *FiveTupleFlow) GetTs() isFiveTupleFlow_Ts
- func (flow *FiveTupleFlow) Key() any
- func (*FiveTupleFlow) ProtoMessage()
- func (x *FiveTupleFlow) ProtoReflect() protoreflect.Message
- func (x *FiveTupleFlow) Reset()
- func (flow *FiveTupleFlow) StartTimestamp() time.Time
- func (x *FiveTupleFlow) String() string
- type FiveTupleFlowKey
- type FiveTupleFlow_Time
- type FiveTupleFlow_Timestamp
- type Flow
- type FlowCollector
- func (FlowCollector) Descriptor() protoreflect.EnumDescriptor
- func (x FlowCollector) Enum() *FlowCollector
- func (FlowCollector) EnumDescriptor() ([]byte, []int)deprecated
- func (x FlowCollector) Number() protoreflect.EnumNumber
- func (x FlowCollector) String() string
- func (FlowCollector) Type() protoreflect.EnumType
- type GetConfigurationUpdatesRequest
- func (*GetConfigurationUpdatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigurationUpdatesRequest) GetKeepalive() *Keepalive
- func (x *GetConfigurationUpdatesRequest) GetRequest() isGetConfigurationUpdatesRequest_Request
- func (*GetConfigurationUpdatesRequest) ProtoMessage()
- func (x *GetConfigurationUpdatesRequest) ProtoReflect() protoreflect.Message
- func (x *GetConfigurationUpdatesRequest) Reset()
- func (x *GetConfigurationUpdatesRequest) String() string
- type GetConfigurationUpdatesRequest_Keepalive
- type GetConfigurationUpdatesResponse
- func (*GetConfigurationUpdatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigurationUpdatesResponse) GetResponse() isGetConfigurationUpdatesResponse_Response
- func (x *GetConfigurationUpdatesResponse) GetUpdateConfiguration() *GetConfigurationUpdatesResponse_Configuration
- func (*GetConfigurationUpdatesResponse) ProtoMessage()
- func (x *GetConfigurationUpdatesResponse) ProtoReflect() protoreflect.Message
- func (x *GetConfigurationUpdatesResponse) Reset()
- func (x *GetConfigurationUpdatesResponse) String() string
- type GetConfigurationUpdatesResponse_Configuration
- func (*GetConfigurationUpdatesResponse_Configuration) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigurationUpdatesResponse_Configuration) GetLogLevel() LogLevel
- func (*GetConfigurationUpdatesResponse_Configuration) ProtoMessage()
- func (x *GetConfigurationUpdatesResponse_Configuration) ProtoReflect() protoreflect.Message
- func (x *GetConfigurationUpdatesResponse_Configuration) Reset()
- func (x *GetConfigurationUpdatesResponse_Configuration) String() string
- type GetConfigurationUpdatesResponse_UpdateConfiguration
- type ICMPv4
- type ICMPv6
- type IP
- type IPBlock
- type IPVersion
- type Keepalive
- type KubernetesClusterMetadata
- func (*KubernetesClusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesClusterMetadata) GetFlowCollector() FlowCollector
- func (x *KubernetesClusterMetadata) GetKubernetesVersion() string
- func (x *KubernetesClusterMetadata) GetOperatorVersion() string
- func (x *KubernetesClusterMetadata) GetUid() string
- func (*KubernetesClusterMetadata) ProtoMessage()
- func (x *KubernetesClusterMetadata) ProtoReflect() protoreflect.Message
- func (x *KubernetesClusterMetadata) Reset()
- func (x *KubernetesClusterMetadata) String() string
- type KubernetesInfoServiceClient
- type KubernetesInfoServiceServer
- type KubernetesInfoService_GetConfigurationUpdatesClient
- type KubernetesInfoService_GetConfigurationUpdatesServer
- type KubernetesInfoService_SendKubernetesNetworkFlowsClient
- type KubernetesInfoService_SendKubernetesNetworkFlowsServer
- type KubernetesInfoService_SendKubernetesResourcesClient
- type KubernetesInfoService_SendKubernetesResourcesServer
- type KubernetesInfoService_SendLogsClient
- type KubernetesInfoService_SendLogsServer
- type KubernetesNetworkPolicyData
- func (*KubernetesNetworkPolicyData) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesNetworkPolicyData) GetEgress() bool
- func (x *KubernetesNetworkPolicyData) GetEgressRules() []*NetworkPolicyRule
- func (x *KubernetesNetworkPolicyData) GetIngress() bool
- func (x *KubernetesNetworkPolicyData) GetIngressRules() []*NetworkPolicyRule
- func (x *KubernetesNetworkPolicyData) GetPodSelector() *LabelSelector
- func (*KubernetesNetworkPolicyData) ProtoMessage()
- func (x *KubernetesNetworkPolicyData) ProtoReflect() protoreflect.Message
- func (x *KubernetesNetworkPolicyData) Reset()
- func (x *KubernetesNetworkPolicyData) String() string
- type KubernetesNodeData
- func (*KubernetesNodeData) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesNodeData) GetIpAddresses() []string
- func (x *KubernetesNodeData) GetProviderId() string
- func (*KubernetesNodeData) ProtoMessage()
- func (x *KubernetesNodeData) ProtoReflect() protoreflect.Message
- func (x *KubernetesNodeData) Reset()
- func (x *KubernetesNodeData) String() string
- type KubernetesObjectData
- func (*KubernetesObjectData) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesObjectData) GetAnnotations() map[string]string
- func (x *KubernetesObjectData) GetCreationTimestamp() *timestamppb.Timestamp
- func (x *KubernetesObjectData) GetKind() string
- func (x *KubernetesObjectData) GetKindSpecific() isKubernetesObjectData_KindSpecific
- func (x *KubernetesObjectData) GetLabels() map[string]string
- func (x *KubernetesObjectData) GetName() string
- func (x *KubernetesObjectData) GetNamespace() string
- func (x *KubernetesObjectData) GetNetworkPolicy() *KubernetesNetworkPolicyData
- func (x *KubernetesObjectData) GetNode() *KubernetesNodeData
- func (x *KubernetesObjectData) GetOwnerReferences() []*KubernetesOwnerReference
- func (x *KubernetesObjectData) GetPod() *KubernetesPodData
- func (x *KubernetesObjectData) GetResourceVersion() string
- func (x *KubernetesObjectData) GetService() *KubernetesServiceData
- func (x *KubernetesObjectData) GetUid() string
- func (*KubernetesObjectData) ProtoMessage()
- func (x *KubernetesObjectData) ProtoReflect() protoreflect.Message
- func (x *KubernetesObjectData) Reset()
- func (x *KubernetesObjectData) String() string
- type KubernetesObjectData_NetworkPolicy
- type KubernetesObjectData_Node
- type KubernetesObjectData_Pod
- type KubernetesObjectData_Service
- type KubernetesOwnerReference
- func (*KubernetesOwnerReference) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesOwnerReference) GetApiVersion() string
- func (x *KubernetesOwnerReference) GetBlockOwnerDeletion() bool
- func (x *KubernetesOwnerReference) GetController() bool
- func (x *KubernetesOwnerReference) GetKind() string
- func (x *KubernetesOwnerReference) GetName() string
- func (x *KubernetesOwnerReference) GetUid() string
- func (*KubernetesOwnerReference) ProtoMessage()
- func (x *KubernetesOwnerReference) ProtoReflect() protoreflect.Message
- func (x *KubernetesOwnerReference) Reset()
- func (x *KubernetesOwnerReference) String() string
- type KubernetesPodData
- func (*KubernetesPodData) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesPodData) GetIpAddresses() []string
- func (*KubernetesPodData) ProtoMessage()
- func (x *KubernetesPodData) ProtoReflect() protoreflect.Message
- func (x *KubernetesPodData) Reset()
- func (x *KubernetesPodData) String() string
- type KubernetesResourceMutation
- func (*KubernetesResourceMutation) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesResourceMutation) GetCreateResource() *KubernetesObjectData
- func (x *KubernetesResourceMutation) GetDeleteResource() *KubernetesObjectData
- func (x *KubernetesResourceMutation) GetMutation() isKubernetesResourceMutation_Mutation
- func (x *KubernetesResourceMutation) GetUpdateResource() *KubernetesObjectData
- func (*KubernetesResourceMutation) ProtoMessage()
- func (x *KubernetesResourceMutation) ProtoReflect() protoreflect.Message
- func (x *KubernetesResourceMutation) Reset()
- func (x *KubernetesResourceMutation) String() string
- type KubernetesResourceMutation_CreateResource
- type KubernetesResourceMutation_DeleteResource
- type KubernetesResourceMutation_UpdateResource
- type KubernetesResourceSnapshotComplete
- func (*KubernetesResourceSnapshotComplete) Descriptor() ([]byte, []int)deprecated
- func (*KubernetesResourceSnapshotComplete) ProtoMessage()
- func (x *KubernetesResourceSnapshotComplete) ProtoReflect() protoreflect.Message
- func (x *KubernetesResourceSnapshotComplete) Reset()
- func (x *KubernetesResourceSnapshotComplete) String() string
- type KubernetesServiceData
- func (*KubernetesServiceData) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesServiceData) GetExternalName() string
- func (x *KubernetesServiceData) GetIpAddresses() []string
- func (x *KubernetesServiceData) GetLoadBalancerClass() string
- func (x *KubernetesServiceData) GetPorts() []*KubernetesServiceData_ServicePort
- func (x *KubernetesServiceData) GetType() string
- func (*KubernetesServiceData) ProtoMessage()
- func (x *KubernetesServiceData) ProtoReflect() protoreflect.Message
- func (x *KubernetesServiceData) Reset()
- func (x *KubernetesServiceData) String() string
- type KubernetesServiceData_ServicePort
- func (*KubernetesServiceData_ServicePort) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesServiceData_ServicePort) GetLoadBalancerPorts() []string
- func (x *KubernetesServiceData_ServicePort) GetNodePort() uint32
- func (x *KubernetesServiceData_ServicePort) GetPort() uint32
- func (x *KubernetesServiceData_ServicePort) GetProtocol() string
- func (*KubernetesServiceData_ServicePort) ProtoMessage()
- func (x *KubernetesServiceData_ServicePort) ProtoReflect() protoreflect.Message
- func (x *KubernetesServiceData_ServicePort) Reset()
- func (x *KubernetesServiceData_ServicePort) String() string
- type LabelSelector
- func (*LabelSelector) Descriptor() ([]byte, []int)deprecated
- func (x *LabelSelector) GetMatchExpressions() []*LabelSelectorRequirement
- func (x *LabelSelector) GetMatchLabels() map[string]string
- func (*LabelSelector) ProtoMessage()
- func (x *LabelSelector) ProtoReflect() protoreflect.Message
- func (x *LabelSelector) Reset()
- func (x *LabelSelector) String() string
- type LabelSelectorRequirement
- func (*LabelSelectorRequirement) Descriptor() ([]byte, []int)deprecated
- func (x *LabelSelectorRequirement) GetKey() string
- func (x *LabelSelectorRequirement) GetOperator() string
- func (x *LabelSelectorRequirement) GetValues() []string
- func (*LabelSelectorRequirement) ProtoMessage()
- func (x *LabelSelectorRequirement) ProtoReflect() protoreflect.Message
- func (x *LabelSelectorRequirement) Reset()
- func (x *LabelSelectorRequirement) String() string
- type Layer4
- func (*Layer4) Descriptor() ([]byte, []int)deprecated
- func (x *Layer4) GetIcmpv4() *ICMPv4
- func (x *Layer4) GetIcmpv6() *ICMPv6
- func (x *Layer4) GetProtocol() isLayer4_Protocol
- func (x *Layer4) GetSctp() *SCTP
- func (x *Layer4) GetTcp() *TCP
- func (x *Layer4) GetUdp() *UDP
- func (*Layer4) ProtoMessage()
- func (x *Layer4) ProtoReflect() protoreflect.Message
- func (x *Layer4) Reset()
- func (x *Layer4) String() string
- type Layer4_Icmpv4
- type Layer4_Icmpv6
- type Layer4_Sctp
- type Layer4_Tcp
- type Layer4_Udp
- type LogEntry
- type LogLevel
- type NetworkPolicyRule
- func (*NetworkPolicyRule) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkPolicyRule) GetPeers() []*Peer
- func (x *NetworkPolicyRule) GetPorts() []*Port
- func (*NetworkPolicyRule) ProtoMessage()
- func (x *NetworkPolicyRule) ProtoReflect() protoreflect.Message
- func (x *NetworkPolicyRule) Reset()
- func (x *NetworkPolicyRule) String() string
- type Peer
- type PeerSelector
- func (*PeerSelector) Descriptor() ([]byte, []int)deprecated
- func (x *PeerSelector) GetNamespaceSelector() *LabelSelector
- func (x *PeerSelector) GetPodSelector() *LabelSelector
- func (*PeerSelector) ProtoMessage()
- func (x *PeerSelector) ProtoReflect() protoreflect.Message
- func (x *PeerSelector) Reset()
- func (x *PeerSelector) String() string
- type Peer_IpBlock
- type Peer_Pods
- type Policy
- func (*Policy) Descriptor() ([]byte, []int)deprecated
- func (x *Policy) GetKind() string
- func (x *Policy) GetLabels() []string
- func (x *Policy) GetName() string
- func (x *Policy) GetNamespace() string
- func (x *Policy) GetRevision() uint64
- func (*Policy) ProtoMessage()
- func (x *Policy) ProtoReflect() protoreflect.Message
- func (x *Policy) Reset()
- func (x *Policy) String() string
- type Port
- type Port_Protocol
- func (Port_Protocol) Descriptor() protoreflect.EnumDescriptor
- func (x Port_Protocol) Enum() *Port_Protocol
- func (Port_Protocol) EnumDescriptor() ([]byte, []int)deprecated
- func (x Port_Protocol) Number() protoreflect.EnumNumber
- func (x Port_Protocol) String() string
- func (Port_Protocol) Type() protoreflect.EnumType
- type SCTP
- type SendKubernetesNetworkFlowsRequest
- func (*SendKubernetesNetworkFlowsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendKubernetesNetworkFlowsRequest) GetCiliumFlow() *CiliumFlow
- func (x *SendKubernetesNetworkFlowsRequest) GetFiveTupleFlow() *FiveTupleFlow
- func (x *SendKubernetesNetworkFlowsRequest) GetKeepalive() *Keepalive
- func (x *SendKubernetesNetworkFlowsRequest) GetRequest() isSendKubernetesNetworkFlowsRequest_Request
- func (*SendKubernetesNetworkFlowsRequest) ProtoMessage()
- func (x *SendKubernetesNetworkFlowsRequest) ProtoReflect() protoreflect.Message
- func (x *SendKubernetesNetworkFlowsRequest) Reset()
- func (x *SendKubernetesNetworkFlowsRequest) String() string
- type SendKubernetesNetworkFlowsRequest_CiliumFlow
- type SendKubernetesNetworkFlowsRequest_FiveTupleFlow
- type SendKubernetesNetworkFlowsRequest_Keepalive
- type SendKubernetesNetworkFlowsResponse
- func (*SendKubernetesNetworkFlowsResponse) Descriptor() ([]byte, []int)deprecated
- func (*SendKubernetesNetworkFlowsResponse) ProtoMessage()
- func (x *SendKubernetesNetworkFlowsResponse) ProtoReflect() protoreflect.Message
- func (x *SendKubernetesNetworkFlowsResponse) Reset()
- func (x *SendKubernetesNetworkFlowsResponse) String() string
- type SendKubernetesResourcesRequest
- func (*SendKubernetesResourcesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendKubernetesResourcesRequest) GetClusterMetadata() *KubernetesClusterMetadata
- func (x *SendKubernetesResourcesRequest) GetKeepalive() *Keepalive
- func (x *SendKubernetesResourcesRequest) GetKubernetesResourceMutation() *KubernetesResourceMutation
- func (x *SendKubernetesResourcesRequest) GetRequest() isSendKubernetesResourcesRequest_Request
- func (x *SendKubernetesResourcesRequest) GetResourceData() *KubernetesObjectData
- func (x *SendKubernetesResourcesRequest) GetResourceSnapshotComplete() *KubernetesResourceSnapshotComplete
- func (*SendKubernetesResourcesRequest) ProtoMessage()
- func (x *SendKubernetesResourcesRequest) ProtoReflect() protoreflect.Message
- func (x *SendKubernetesResourcesRequest) Reset()
- func (x *SendKubernetesResourcesRequest) String() string
- type SendKubernetesResourcesRequest_ClusterMetadata
- type SendKubernetesResourcesRequest_Keepalive
- type SendKubernetesResourcesRequest_KubernetesResourceMutation
- type SendKubernetesResourcesRequest_ResourceData
- type SendKubernetesResourcesRequest_ResourceSnapshotComplete
- type SendKubernetesResourcesResponse
- func (*SendKubernetesResourcesResponse) Descriptor() ([]byte, []int)deprecated
- func (*SendKubernetesResourcesResponse) ProtoMessage()
- func (x *SendKubernetesResourcesResponse) ProtoReflect() protoreflect.Message
- func (x *SendKubernetesResourcesResponse) Reset()
- func (x *SendKubernetesResourcesResponse) String() string
- type SendLogsRequest
- func (*SendLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendLogsRequest) GetKeepalive() *Keepalive
- func (x *SendLogsRequest) GetLogEntry() *LogEntry
- func (x *SendLogsRequest) GetRequest() isSendLogsRequest_Request
- func (*SendLogsRequest) ProtoMessage()
- func (x *SendLogsRequest) ProtoReflect() protoreflect.Message
- func (x *SendLogsRequest) Reset()
- func (x *SendLogsRequest) String() string
- type SendLogsRequest_Keepalive
- type SendLogsRequest_LogEntry
- type SendLogsResponse
- type Service
- type TCP
- type TCPFlags
- func (*TCPFlags) Descriptor() ([]byte, []int)deprecated
- func (x *TCPFlags) GetAck() bool
- func (x *TCPFlags) GetCwr() bool
- func (x *TCPFlags) GetEce() bool
- func (x *TCPFlags) GetFin() bool
- func (x *TCPFlags) GetNs() bool
- func (x *TCPFlags) GetPsh() bool
- func (x *TCPFlags) GetRst() bool
- func (x *TCPFlags) GetSyn() bool
- func (x *TCPFlags) GetUrg() bool
- func (*TCPFlags) ProtoMessage()
- func (x *TCPFlags) ProtoReflect() protoreflect.Message
- func (x *TCPFlags) Reset()
- func (x *TCPFlags) String() string
- type TrafficDirection
- func (TrafficDirection) Descriptor() protoreflect.EnumDescriptor
- func (x TrafficDirection) Enum() *TrafficDirection
- func (TrafficDirection) EnumDescriptor() ([]byte, []int)deprecated
- func (x TrafficDirection) Number() protoreflect.EnumNumber
- func (x TrafficDirection) String() string
- func (TrafficDirection) Type() protoreflect.EnumType
- type UDP
- type UnimplementedKubernetesInfoServiceServer
- func (UnimplementedKubernetesInfoServiceServer) GetConfigurationUpdates(...) error
- func (UnimplementedKubernetesInfoServiceServer) SendKubernetesNetworkFlows(...) error
- func (UnimplementedKubernetesInfoServiceServer) SendKubernetesResources(...) error
- func (UnimplementedKubernetesInfoServiceServer) SendLogs(grpc.BidiStreamingServer[SendLogsRequest, SendLogsResponse]) error
- type UnsafeKubernetesInfoServiceServer
- type Verdict
- type Workload
Constants ¶
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 ¶
var ( FlowCollector_name = map[int32]string{ 0: "FLOW_COLLECTOR_UNSPECIFIED", 1: "FLOW_COLLECTOR_DISABLED", 2: "FLOW_COLLECTOR_CILIUM", 3: "FLOW_COLLECTOR_FALCO", 4: "FLOW_COLLECTOR_OVNK", } FlowCollector_value = map[string]int32{ "FLOW_COLLECTOR_UNSPECIFIED": 0, "FLOW_COLLECTOR_DISABLED": 1, "FLOW_COLLECTOR_CILIUM": 2, "FLOW_COLLECTOR_FALCO": 3, "FLOW_COLLECTOR_OVNK": 4, } )
Enum value maps for FlowCollector.
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.
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.
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.
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.
var ( Port_Protocol_name = map[int32]string{ 0: "PROTOCOL_TCP_UNSPECIFIED", 1: "PROTOCOL_UDP", 2: "PROTOCOL_SCTP", } Port_Protocol_value = map[string]int32{ "PROTOCOL_TCP_UNSPECIFIED": 0, "PROTOCOL_UDP": 1, "PROTOCOL_SCTP": 2, } )
Enum value maps for Port_Protocol.
var File_illumio_cloud_k8sclustersync_v1_k8s_info_proto protoreflect.FileDescriptor
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 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) GetClusterName ¶
func (*Endpoint) GetNamespace ¶
func (*Endpoint) GetPodName ¶
func (*Endpoint) GetWorkloads ¶
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) ProtoReflect ¶
func (x *Endpoint) ProtoReflect() protoreflect.Message
type FiveTupleFlow ¶ added in v1.3.0
type FiveTupleFlow 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:
//
// *FiveTupleFlow_Time
// *FiveTupleFlow_Timestamp
Ts isFiveTupleFlow_Ts `protobuf_oneof:"ts"`
// contains filtered or unexported fields
}
A flow with a simple 5-tuple flow key received from a CNI plugin
func (*FiveTupleFlow) Descriptor
deprecated
added in
v1.3.0
func (*FiveTupleFlow) Descriptor() ([]byte, []int)
Deprecated: Use FiveTupleFlow.ProtoReflect.Descriptor instead.
func (*FiveTupleFlow) GetLayer3 ¶ added in v1.3.0
func (x *FiveTupleFlow) GetLayer3() *IP
func (*FiveTupleFlow) GetLayer4 ¶ added in v1.3.0
func (x *FiveTupleFlow) GetLayer4() *Layer4
func (*FiveTupleFlow) GetTime
deprecated
added in
v1.3.0
func (x *FiveTupleFlow) GetTime() string
Deprecated: Marked as deprecated in illumio/cloud/k8sclustersync/v1/k8s_info.proto.
func (*FiveTupleFlow) GetTimestamp ¶ added in v1.3.0
func (x *FiveTupleFlow) GetTimestamp() *timestamppb.Timestamp
func (*FiveTupleFlow) GetTs ¶ added in v1.3.0
func (x *FiveTupleFlow) GetTs() isFiveTupleFlow_Ts
func (*FiveTupleFlow) Key ¶ added in v1.3.0
func (flow *FiveTupleFlow) Key() any
func (*FiveTupleFlow) ProtoMessage ¶ added in v1.3.0
func (*FiveTupleFlow) ProtoMessage()
func (*FiveTupleFlow) ProtoReflect ¶ added in v1.3.0
func (x *FiveTupleFlow) ProtoReflect() protoreflect.Message
func (*FiveTupleFlow) Reset ¶ added in v1.3.0
func (x *FiveTupleFlow) Reset()
func (*FiveTupleFlow) StartTimestamp ¶ added in v1.3.0
func (flow *FiveTupleFlow) StartTimestamp() time.Time
func (*FiveTupleFlow) String ¶ added in v1.3.0
func (x *FiveTupleFlow) String() string
type FiveTupleFlowKey ¶ added in v1.3.0
type FiveTupleFlow_Time ¶ added in v1.3.0
type FiveTupleFlow_Time struct {
// time contains the unparsed timestamp string received from a CNI plugin; 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 FiveTupleFlow_Timestamp ¶ added in v1.3.0
type FiveTupleFlow_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 // Indicates that OVN-Kubernetes is deployed and configured for collecting network flows. FlowCollector_FLOW_COLLECTOR_OVNK FlowCollector = 4 )
func (FlowCollector) Descriptor ¶ added in v1.1.2
func (FlowCollector) Descriptor() protoreflect.EnumDescriptor
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 (x FlowCollector) Number() protoreflect.EnumNumber
func (FlowCollector) String ¶ added in v1.1.2
func (x FlowCollector) String() string
func (FlowCollector) Type ¶ added in v1.1.2
func (FlowCollector) Type() protoreflect.EnumType
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 (x *GetConfigurationUpdatesRequest) ProtoReflect() protoreflect.Message
func (*GetConfigurationUpdatesRequest) Reset ¶ added in v1.1.2
func (x *GetConfigurationUpdatesRequest) Reset()
func (*GetConfigurationUpdatesRequest) String ¶ added in v1.1.2
func (x *GetConfigurationUpdatesRequest) String() string
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 (x *GetConfigurationUpdatesResponse) GetUpdateConfiguration() *GetConfigurationUpdatesResponse_Configuration
func (*GetConfigurationUpdatesResponse) ProtoMessage ¶ added in v1.1.2
func (*GetConfigurationUpdatesResponse) ProtoMessage()
func (*GetConfigurationUpdatesResponse) ProtoReflect ¶ added in v1.1.2
func (x *GetConfigurationUpdatesResponse) ProtoReflect() protoreflect.Message
func (*GetConfigurationUpdatesResponse) Reset ¶ added in v1.1.2
func (x *GetConfigurationUpdatesResponse) Reset()
func (*GetConfigurationUpdatesResponse) String ¶ added in v1.1.2
func (x *GetConfigurationUpdatesResponse) String() string
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
func (*GetConfigurationUpdatesResponse_Configuration) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigurationUpdatesResponse_Configuration.ProtoReflect.Descriptor instead.
func (*GetConfigurationUpdatesResponse_Configuration) GetLogLevel ¶ added in v1.1.2
func (x *GetConfigurationUpdatesResponse_Configuration) GetLogLevel() LogLevel
func (*GetConfigurationUpdatesResponse_Configuration) ProtoMessage ¶ added in v1.1.2
func (*GetConfigurationUpdatesResponse_Configuration) ProtoMessage()
func (*GetConfigurationUpdatesResponse_Configuration) ProtoReflect ¶ added in v1.1.2
func (x *GetConfigurationUpdatesResponse_Configuration) ProtoReflect() protoreflect.Message
func (*GetConfigurationUpdatesResponse_Configuration) Reset ¶ added in v1.1.2
func (x *GetConfigurationUpdatesResponse_Configuration) Reset()
func (*GetConfigurationUpdatesResponse_Configuration) String ¶ added in v1.1.2
func (x *GetConfigurationUpdatesResponse_Configuration) String() string
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) ProtoMessage ¶
func (*ICMPv4) ProtoMessage()
func (*ICMPv4) ProtoReflect ¶
func (x *ICMPv4) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*ICMPv6) ProtoMessage()
func (*ICMPv6) ProtoReflect ¶
func (x *ICMPv6) ProtoReflect() protoreflect.Message
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) GetDestination ¶
func (*IP) GetIpVersion ¶
func (*IP) ProtoMessage ¶
func (*IP) ProtoMessage()
func (*IP) ProtoReflect ¶
func (x *IP) ProtoReflect() protoreflect.Message
type IPBlock ¶ added in v1.2.0
type IPBlock struct {
Cidr string `protobuf:"bytes,1,opt,name=cidr,proto3" json:"cidr,omitempty"`
Except []string `protobuf:"bytes,2,rep,name=except,proto3" json:"except,omitempty"`
// contains filtered or unexported fields
}
IPBlock defines a particular CIDR (Ex: 10.10.10.0/24).
func (*IPBlock) Descriptor
deprecated
added in
v1.2.0
func (*IPBlock) ProtoMessage ¶ added in v1.2.0
func (*IPBlock) ProtoMessage()
func (*IPBlock) ProtoReflect ¶ added in v1.2.0
func (x *IPBlock) ProtoReflect() protoreflect.Message
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
func (IPVersion) Descriptor ¶
func (IPVersion) Descriptor() protoreflect.EnumDescriptor
func (IPVersion) EnumDescriptor
deprecated
func (IPVersion) Number ¶
func (x IPVersion) Number() protoreflect.EnumNumber
func (IPVersion) Type ¶
func (IPVersion) Type() protoreflect.EnumType
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) ProtoMessage ¶ added in v1.1.0
func (*Keepalive) ProtoMessage()
func (*Keepalive) ProtoReflect ¶ added in v1.1.0
func (x *Keepalive) ProtoReflect() protoreflect.Message
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 (x *KubernetesClusterMetadata) ProtoReflect() protoreflect.Message
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) (grpc.BidiStreamingClient[SendKubernetesResourcesRequest, SendKubernetesResourcesResponse], error)
// Continuously sends network flows exported by the CNI plugin in the cluster to CloudSecure.
SendKubernetesNetworkFlows(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SendKubernetesNetworkFlowsRequest, SendKubernetesNetworkFlowsResponse], error)
// Continuously syncs logs from operator and cluster.
SendLogs(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SendLogsRequest, SendLogsResponse], error)
// Continuously receives configuration updates from CloudSecure.
GetConfigurationUpdates(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[GetConfigurationUpdatesRequest, GetConfigurationUpdatesResponse], 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.
Syncs the inventory of the Kubernetes resources in the cluster into CloudSecure.
func NewKubernetesInfoServiceClient ¶
func NewKubernetesInfoServiceClient(cc grpc.ClientConnInterface) KubernetesInfoServiceClient
type KubernetesInfoServiceServer ¶
type KubernetesInfoServiceServer interface {
// Continuously syncs the inventory of the Kubernetes resources in the cluster into CloudSecure.
SendKubernetesResources(grpc.BidiStreamingServer[SendKubernetesResourcesRequest, SendKubernetesResourcesResponse]) error
// Continuously sends network flows exported by the CNI plugin in the cluster to CloudSecure.
SendKubernetesNetworkFlows(grpc.BidiStreamingServer[SendKubernetesNetworkFlowsRequest, SendKubernetesNetworkFlowsResponse]) error
// Continuously syncs logs from operator and cluster.
SendLogs(grpc.BidiStreamingServer[SendLogsRequest, SendLogsResponse]) error
// Continuously receives configuration updates from CloudSecure.
GetConfigurationUpdates(grpc.BidiStreamingServer[GetConfigurationUpdatesRequest, GetConfigurationUpdatesResponse]) error
// contains filtered or unexported methods
}
KubernetesInfoServiceServer is the server API for KubernetesInfoService service. All implementations must embed UnimplementedKubernetesInfoServiceServer for forward compatibility.
Syncs the inventory of the Kubernetes resources in the cluster into CloudSecure.
type KubernetesInfoService_GetConfigurationUpdatesClient ¶ added in v1.1.2
type KubernetesInfoService_GetConfigurationUpdatesClient = grpc.BidiStreamingClient[GetConfigurationUpdatesRequest, GetConfigurationUpdatesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KubernetesInfoService_GetConfigurationUpdatesServer ¶ added in v1.1.2
type KubernetesInfoService_GetConfigurationUpdatesServer = grpc.BidiStreamingServer[GetConfigurationUpdatesRequest, GetConfigurationUpdatesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KubernetesInfoService_SendKubernetesNetworkFlowsClient ¶
type KubernetesInfoService_SendKubernetesNetworkFlowsClient = grpc.BidiStreamingClient[SendKubernetesNetworkFlowsRequest, SendKubernetesNetworkFlowsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KubernetesInfoService_SendKubernetesNetworkFlowsServer ¶
type KubernetesInfoService_SendKubernetesNetworkFlowsServer = grpc.BidiStreamingServer[SendKubernetesNetworkFlowsRequest, SendKubernetesNetworkFlowsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KubernetesInfoService_SendKubernetesResourcesClient ¶
type KubernetesInfoService_SendKubernetesResourcesClient = grpc.BidiStreamingClient[SendKubernetesResourcesRequest, SendKubernetesResourcesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KubernetesInfoService_SendKubernetesResourcesServer ¶
type KubernetesInfoService_SendKubernetesResourcesServer = grpc.BidiStreamingServer[SendKubernetesResourcesRequest, SendKubernetesResourcesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KubernetesInfoService_SendLogsClient ¶
type KubernetesInfoService_SendLogsClient = grpc.BidiStreamingClient[SendLogsRequest, SendLogsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KubernetesInfoService_SendLogsServer ¶
type KubernetesInfoService_SendLogsServer = grpc.BidiStreamingServer[SendLogsRequest, SendLogsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KubernetesNetworkPolicyData ¶ added in v1.2.0
type KubernetesNetworkPolicyData struct {
Ingress bool `protobuf:"varint,1,opt,name=ingress,proto3" json:"ingress,omitempty"` // True if Ingress policy is enabled
Egress bool `protobuf:"varint,2,opt,name=egress,proto3" json:"egress,omitempty"` // True if Egress policy is enabled
PodSelector *LabelSelector `protobuf:"bytes,3,opt,name=pod_selector,json=podSelector,proto3" json:"pod_selector,omitempty"` // Pod selector for the policy
IngressRules []*NetworkPolicyRule `protobuf:"bytes,4,rep,name=ingress_rules,json=ingressRules,proto3" json:"ingress_rules,omitempty"` // Ingress rules for the policy
EgressRules []*NetworkPolicyRule `protobuf:"bytes,5,rep,name=egress_rules,json=egressRules,proto3" json:"egress_rules,omitempty"` // Egress rules for the policy
// contains filtered or unexported fields
}
KubernetesNetworkPolicyData contains information specific to a NetworkPolicy object.
func (*KubernetesNetworkPolicyData) Descriptor
deprecated
added in
v1.2.0
func (*KubernetesNetworkPolicyData) Descriptor() ([]byte, []int)
Deprecated: Use KubernetesNetworkPolicyData.ProtoReflect.Descriptor instead.
func (*KubernetesNetworkPolicyData) GetEgress ¶ added in v1.2.0
func (x *KubernetesNetworkPolicyData) GetEgress() bool
func (*KubernetesNetworkPolicyData) GetEgressRules ¶ added in v1.2.0
func (x *KubernetesNetworkPolicyData) GetEgressRules() []*NetworkPolicyRule
func (*KubernetesNetworkPolicyData) GetIngress ¶ added in v1.2.0
func (x *KubernetesNetworkPolicyData) GetIngress() bool
func (*KubernetesNetworkPolicyData) GetIngressRules ¶ added in v1.2.0
func (x *KubernetesNetworkPolicyData) GetIngressRules() []*NetworkPolicyRule
func (*KubernetesNetworkPolicyData) GetPodSelector ¶ added in v1.2.0
func (x *KubernetesNetworkPolicyData) GetPodSelector() *LabelSelector
func (*KubernetesNetworkPolicyData) ProtoMessage ¶ added in v1.2.0
func (*KubernetesNetworkPolicyData) ProtoMessage()
func (*KubernetesNetworkPolicyData) ProtoReflect ¶ added in v1.2.0
func (x *KubernetesNetworkPolicyData) ProtoReflect() protoreflect.Message
func (*KubernetesNetworkPolicyData) Reset ¶ added in v1.2.0
func (x *KubernetesNetworkPolicyData) Reset()
func (*KubernetesNetworkPolicyData) String ¶ added in v1.2.0
func (x *KubernetesNetworkPolicyData) String() string
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
// *KubernetesObjectData_NetworkPolicy
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) GetNetworkPolicy ¶ added in v1.2.0
func (x *KubernetesObjectData) GetNetworkPolicy() *KubernetesNetworkPolicyData
func (*KubernetesObjectData) GetNode ¶ added in v0.0.11
func (x *KubernetesObjectData) GetNode() *KubernetesNodeData
func (*KubernetesObjectData) GetOwnerReferences ¶ added in v0.0.6
func (x *KubernetesObjectData) GetOwnerReferences() []*KubernetesOwnerReference
func (*KubernetesObjectData) GetPod ¶ added in v0.0.6
func (x *KubernetesObjectData) GetPod() *KubernetesPodData
func (*KubernetesObjectData) GetResourceVersion ¶ added in v0.0.6
func (x *KubernetesObjectData) GetResourceVersion() string
func (*KubernetesObjectData) GetService ¶ added in v1.0.1
func (x *KubernetesObjectData) GetService() *KubernetesServiceData
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_NetworkPolicy ¶ added in v1.2.0
type KubernetesObjectData_NetworkPolicy struct {
NetworkPolicy *KubernetesNetworkPolicyData `protobuf:"bytes,103,opt,name=network_policy,json=networkPolicy,proto3,oneof"`
}
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 (x *KubernetesResourceMutation) ProtoReflect() protoreflect.Message
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 (x *KubernetesResourceSnapshotComplete) ProtoReflect() protoreflect.Message
func (*KubernetesResourceSnapshotComplete) Reset ¶
func (x *KubernetesResourceSnapshotComplete) Reset()
func (*KubernetesResourceSnapshotComplete) String ¶
func (x *KubernetesResourceSnapshotComplete) String() 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 (x *KubernetesServiceData) GetPorts() []*KubernetesServiceData_ServicePort
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 (x *KubernetesServiceData_ServicePort) GetPort() uint32
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 (x *KubernetesServiceData_ServicePort) ProtoReflect() protoreflect.Message
func (*KubernetesServiceData_ServicePort) Reset ¶ added in v1.0.1
func (x *KubernetesServiceData_ServicePort) Reset()
func (*KubernetesServiceData_ServicePort) String ¶ added in v1.0.1
func (x *KubernetesServiceData_ServicePort) String() string
type LabelSelector ¶ added in v1.2.0
type LabelSelector struct {
MatchLabels map[string]string `` /* 168-byte string literal not displayed */
MatchExpressions []*LabelSelectorRequirement `protobuf:"bytes,2,rep,name=match_expressions,json=matchExpressions,proto3" json:"match_expressions,omitempty"`
// contains filtered or unexported fields
}
LabelSelector selects a k8s resource (e.g., a pod or namespace) by its labels.
func (*LabelSelector) Descriptor
deprecated
added in
v1.2.0
func (*LabelSelector) Descriptor() ([]byte, []int)
Deprecated: Use LabelSelector.ProtoReflect.Descriptor instead.
func (*LabelSelector) GetMatchExpressions ¶ added in v1.2.0
func (x *LabelSelector) GetMatchExpressions() []*LabelSelectorRequirement
func (*LabelSelector) GetMatchLabels ¶ added in v1.2.0
func (x *LabelSelector) GetMatchLabels() map[string]string
func (*LabelSelector) ProtoMessage ¶ added in v1.2.0
func (*LabelSelector) ProtoMessage()
func (*LabelSelector) ProtoReflect ¶ added in v1.2.0
func (x *LabelSelector) ProtoReflect() protoreflect.Message
func (*LabelSelector) Reset ¶ added in v1.2.0
func (x *LabelSelector) Reset()
func (*LabelSelector) String ¶ added in v1.2.0
func (x *LabelSelector) String() string
type LabelSelectorRequirement ¶ added in v1.2.0
type LabelSelectorRequirement struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// operator represents a key's relationship to a set of values. Valid operators are In, NotIn, Exists and DoesNotExist.
Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
Values []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
LabelSelectorRequirement is a selector that contains values, a key, and an operator that relates the key and values.
func (*LabelSelectorRequirement) Descriptor
deprecated
added in
v1.2.0
func (*LabelSelectorRequirement) Descriptor() ([]byte, []int)
Deprecated: Use LabelSelectorRequirement.ProtoReflect.Descriptor instead.
func (*LabelSelectorRequirement) GetKey ¶ added in v1.2.0
func (x *LabelSelectorRequirement) GetKey() string
func (*LabelSelectorRequirement) GetOperator ¶ added in v1.2.0
func (x *LabelSelectorRequirement) GetOperator() string
func (*LabelSelectorRequirement) GetValues ¶ added in v1.2.0
func (x *LabelSelectorRequirement) GetValues() []string
func (*LabelSelectorRequirement) ProtoMessage ¶ added in v1.2.0
func (*LabelSelectorRequirement) ProtoMessage()
func (*LabelSelectorRequirement) ProtoReflect ¶ added in v1.2.0
func (x *LabelSelectorRequirement) ProtoReflect() protoreflect.Message
func (*LabelSelectorRequirement) Reset ¶ added in v1.2.0
func (x *LabelSelectorRequirement) Reset()
func (*LabelSelectorRequirement) String ¶ added in v1.2.0
func (x *LabelSelectorRequirement) String() string
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) GetProtocol ¶
func (x *Layer4) GetProtocol() isLayer4_Protocol
func (*Layer4) ProtoMessage ¶
func (*Layer4) ProtoMessage()
func (*Layer4) ProtoReflect ¶
func (x *Layer4) ProtoReflect() protoreflect.Message
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) GetJsonMessage ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) ProtoReflect ¶
func (x *LogEntry) ProtoReflect() protoreflect.Message
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) EnumDescriptor
deprecated
func (LogLevel) Number ¶
func (x LogLevel) Number() protoreflect.EnumNumber
func (LogLevel) Type ¶
func (LogLevel) Type() protoreflect.EnumType
type NetworkPolicyRule ¶ added in v1.2.0
type NetworkPolicyRule struct {
Peers []*Peer `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
Ports []*Port `protobuf:"bytes,2,rep,name=ports,proto3" json:"ports,omitempty"`
// contains filtered or unexported fields
}
NetworkPolicyRule defines a single ingress or egress rule.
func (*NetworkPolicyRule) Descriptor
deprecated
added in
v1.2.0
func (*NetworkPolicyRule) Descriptor() ([]byte, []int)
Deprecated: Use NetworkPolicyRule.ProtoReflect.Descriptor instead.
func (*NetworkPolicyRule) GetPeers ¶ added in v1.2.0
func (x *NetworkPolicyRule) GetPeers() []*Peer
func (*NetworkPolicyRule) GetPorts ¶ added in v1.2.0
func (x *NetworkPolicyRule) GetPorts() []*Port
func (*NetworkPolicyRule) ProtoMessage ¶ added in v1.2.0
func (*NetworkPolicyRule) ProtoMessage()
func (*NetworkPolicyRule) ProtoReflect ¶ added in v1.2.0
func (x *NetworkPolicyRule) ProtoReflect() protoreflect.Message
func (*NetworkPolicyRule) Reset ¶ added in v1.2.0
func (x *NetworkPolicyRule) Reset()
func (*NetworkPolicyRule) String ¶ added in v1.2.0
func (x *NetworkPolicyRule) String() string
type Peer ¶ added in v1.2.0
type Peer struct {
// Types that are valid to be assigned to Peer:
//
// *Peer_IpBlock
// *Peer_Pods
Peer isPeer_Peer `protobuf_oneof:"peer"`
// contains filtered or unexported fields
}
Peer defines a network peer as a set of IP addresses or a set of pods.
func (*Peer) Descriptor
deprecated
added in
v1.2.0
func (*Peer) GetIpBlock ¶ added in v1.2.0
func (*Peer) GetPods ¶ added in v1.2.0
func (x *Peer) GetPods() *PeerSelector
func (*Peer) ProtoMessage ¶ added in v1.2.0
func (*Peer) ProtoMessage()
func (*Peer) ProtoReflect ¶ added in v1.2.0
func (x *Peer) ProtoReflect() protoreflect.Message
type PeerSelector ¶ added in v1.2.0
type PeerSelector struct {
// Selects namespaces using cluster-scoped labels.
// An empty selector selects all namespaces.
NamespaceSelector *LabelSelector `protobuf:"bytes,1,opt,name=namespace_selector,json=namespaceSelector,proto3,oneof" json:"namespace_selector,omitempty"`
// Selects pods in the selected namespaces using pod labels.
// An empty selectors selects all pods.
PodSelector *LabelSelector `protobuf:"bytes,2,opt,name=pod_selector,json=podSelector,proto3,oneof" json:"pod_selector,omitempty"`
// contains filtered or unexported fields
}
PeerSelector selects a set of pods.
func (*PeerSelector) Descriptor
deprecated
added in
v1.2.0
func (*PeerSelector) Descriptor() ([]byte, []int)
Deprecated: Use PeerSelector.ProtoReflect.Descriptor instead.
func (*PeerSelector) GetNamespaceSelector ¶ added in v1.2.0
func (x *PeerSelector) GetNamespaceSelector() *LabelSelector
func (*PeerSelector) GetPodSelector ¶ added in v1.2.0
func (x *PeerSelector) GetPodSelector() *LabelSelector
func (*PeerSelector) ProtoMessage ¶ added in v1.2.0
func (*PeerSelector) ProtoMessage()
func (*PeerSelector) ProtoReflect ¶ added in v1.2.0
func (x *PeerSelector) ProtoReflect() protoreflect.Message
func (*PeerSelector) Reset ¶ added in v1.2.0
func (x *PeerSelector) Reset()
func (*PeerSelector) String ¶ added in v1.2.0
func (x *PeerSelector) String() string
type Peer_IpBlock ¶ added in v1.2.0
type Peer_IpBlock struct {
IpBlock *IPBlock `protobuf:"bytes,1,opt,name=ip_block,json=ipBlock,proto3,oneof"`
}
type Peer_Pods ¶ added in v1.2.0
type Peer_Pods struct {
Pods *PeerSelector `protobuf:"bytes,2,opt,name=pods,proto3,oneof"`
}
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"`
Kind string `protobuf:"bytes,5,opt,name=kind,proto3" json:"kind,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) GetNamespace ¶
func (*Policy) GetRevision ¶
func (*Policy) ProtoMessage ¶
func (*Policy) ProtoMessage()
func (*Policy) ProtoReflect ¶
func (x *Policy) ProtoReflect() protoreflect.Message
type Port ¶ added in v1.2.0
type Port struct {
Protocol Port_Protocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=illumio.cloud.k8sclustersync.v1.Port_Protocol" json:"protocol,omitempty"`
Port *string `protobuf:"bytes,2,opt,name=port,proto3,oneof" json:"port,omitempty"`
EndPort *int32 `protobuf:"varint,3,opt,name=end_port,json=endPort,proto3,oneof" json:"end_port,omitempty"`
// contains filtered or unexported fields
}
Port defines a network port.
func (*Port) Descriptor
deprecated
added in
v1.2.0
func (*Port) GetEndPort ¶ added in v1.2.0
func (*Port) GetProtocol ¶ added in v1.2.0
func (x *Port) GetProtocol() Port_Protocol
func (*Port) ProtoMessage ¶ added in v1.2.0
func (*Port) ProtoMessage()
func (*Port) ProtoReflect ¶ added in v1.2.0
func (x *Port) ProtoReflect() protoreflect.Message
type Port_Protocol ¶ added in v1.2.0
type Port_Protocol int32
const ( Port_PROTOCOL_TCP_UNSPECIFIED Port_Protocol = 0 // Default value in Kubernetes Port_PROTOCOL_UDP Port_Protocol = 1 Port_PROTOCOL_SCTP Port_Protocol = 2 )
func (Port_Protocol) Descriptor ¶ added in v1.2.0
func (Port_Protocol) Descriptor() protoreflect.EnumDescriptor
func (Port_Protocol) Enum ¶ added in v1.2.0
func (x Port_Protocol) Enum() *Port_Protocol
func (Port_Protocol) EnumDescriptor
deprecated
added in
v1.2.0
func (Port_Protocol) EnumDescriptor() ([]byte, []int)
Deprecated: Use Port_Protocol.Descriptor instead.
func (Port_Protocol) Number ¶ added in v1.2.0
func (x Port_Protocol) Number() protoreflect.EnumNumber
func (Port_Protocol) String ¶ added in v1.2.0
func (x Port_Protocol) String() string
func (Port_Protocol) Type ¶ added in v1.2.0
func (Port_Protocol) Type() protoreflect.EnumType
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) GetDestinationPort ¶
func (*SCTP) GetSourcePort ¶
func (*SCTP) ProtoMessage ¶
func (*SCTP) ProtoMessage()
func (*SCTP) ProtoReflect ¶
func (x *SCTP) ProtoReflect() protoreflect.Message
type SendKubernetesNetworkFlowsRequest ¶
type SendKubernetesNetworkFlowsRequest struct {
// Types that are valid to be assigned to Request:
//
// *SendKubernetesNetworkFlowsRequest_Keepalive
// *SendKubernetesNetworkFlowsRequest_CiliumFlow
// *SendKubernetesNetworkFlowsRequest_FiveTupleFlow
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) GetFiveTupleFlow ¶ added in v1.3.0
func (x *SendKubernetesNetworkFlowsRequest) GetFiveTupleFlow() *FiveTupleFlow
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 (x *SendKubernetesNetworkFlowsRequest) ProtoReflect() protoreflect.Message
func (*SendKubernetesNetworkFlowsRequest) Reset ¶
func (x *SendKubernetesNetworkFlowsRequest) Reset()
func (*SendKubernetesNetworkFlowsRequest) String ¶
func (x *SendKubernetesNetworkFlowsRequest) String() string
type SendKubernetesNetworkFlowsRequest_CiliumFlow ¶
type SendKubernetesNetworkFlowsRequest_CiliumFlow struct {
CiliumFlow *CiliumFlow `protobuf:"bytes,1,opt,name=cilium_flow,json=ciliumFlow,proto3,oneof"`
}
type SendKubernetesNetworkFlowsRequest_FiveTupleFlow ¶ added in v1.3.0
type SendKubernetesNetworkFlowsRequest_FiveTupleFlow struct {
FiveTupleFlow *FiveTupleFlow `protobuf:"bytes,2,opt,name=five_tuple_flow,json=fiveTupleFlow,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 (x *SendKubernetesNetworkFlowsResponse) ProtoReflect() protoreflect.Message
func (*SendKubernetesNetworkFlowsResponse) Reset ¶
func (x *SendKubernetesNetworkFlowsResponse) Reset()
func (*SendKubernetesNetworkFlowsResponse) String ¶
func (x *SendKubernetesNetworkFlowsResponse) String() 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 (x *SendKubernetesResourcesRequest) GetClusterMetadata() *KubernetesClusterMetadata
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 (x *SendKubernetesResourcesRequest) GetResourceData() *KubernetesObjectData
func (*SendKubernetesResourcesRequest) GetResourceSnapshotComplete ¶
func (x *SendKubernetesResourcesRequest) GetResourceSnapshotComplete() *KubernetesResourceSnapshotComplete
func (*SendKubernetesResourcesRequest) ProtoMessage ¶
func (*SendKubernetesResourcesRequest) ProtoMessage()
func (*SendKubernetesResourcesRequest) ProtoReflect ¶
func (x *SendKubernetesResourcesRequest) ProtoReflect() protoreflect.Message
func (*SendKubernetesResourcesRequest) Reset ¶
func (x *SendKubernetesResourcesRequest) Reset()
func (*SendKubernetesResourcesRequest) String ¶
func (x *SendKubernetesResourcesRequest) String() 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 (x *SendKubernetesResourcesResponse) ProtoReflect() protoreflect.Message
func (*SendKubernetesResourcesResponse) Reset ¶
func (x *SendKubernetesResourcesResponse) Reset()
func (*SendKubernetesResourcesResponse) String ¶
func (x *SendKubernetesResourcesResponse) String() 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) GetNamespace ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
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) GetDestinationPort ¶
func (*TCP) GetSourcePort ¶
func (*TCP) ProtoMessage ¶
func (*TCP) ProtoMessage()
func (*TCP) ProtoReflect ¶
func (x *TCP) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*TCPFlags) ProtoMessage()
func (*TCPFlags) ProtoReflect ¶
func (x *TCPFlags) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
func (TrafficDirection) Enum ¶
func (x TrafficDirection) Enum() *TrafficDirection
func (TrafficDirection) EnumDescriptor
deprecated
func (TrafficDirection) EnumDescriptor() ([]byte, []int)
Deprecated: Use TrafficDirection.Descriptor instead.
func (TrafficDirection) Number ¶
func (x TrafficDirection) Number() protoreflect.EnumNumber
func (TrafficDirection) String ¶
func (x TrafficDirection) String() string
func (TrafficDirection) Type ¶
func (TrafficDirection) Type() protoreflect.EnumType
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) GetDestinationPort ¶
func (*UDP) GetSourcePort ¶
func (*UDP) ProtoMessage ¶
func (*UDP) ProtoMessage()
func (*UDP) ProtoReflect ¶
func (x *UDP) ProtoReflect() protoreflect.Message
type UnimplementedKubernetesInfoServiceServer ¶
type UnimplementedKubernetesInfoServiceServer struct{}
UnimplementedKubernetesInfoServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedKubernetesInfoServiceServer) GetConfigurationUpdates ¶ added in v1.1.2
func (UnimplementedKubernetesInfoServiceServer) GetConfigurationUpdates(grpc.BidiStreamingServer[GetConfigurationUpdatesRequest, GetConfigurationUpdatesResponse]) error
func (UnimplementedKubernetesInfoServiceServer) SendKubernetesNetworkFlows ¶
func (UnimplementedKubernetesInfoServiceServer) SendKubernetesNetworkFlows(grpc.BidiStreamingServer[SendKubernetesNetworkFlowsRequest, SendKubernetesNetworkFlowsResponse]) error
func (UnimplementedKubernetesInfoServiceServer) SendKubernetesResources ¶
func (UnimplementedKubernetesInfoServiceServer) SendKubernetesResources(grpc.BidiStreamingServer[SendKubernetesResourcesRequest, SendKubernetesResourcesResponse]) error
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) EnumDescriptor
deprecated
func (Verdict) Number ¶
func (x Verdict) Number() protoreflect.EnumNumber
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) ProtoMessage ¶
func (*Workload) ProtoMessage()
func (*Workload) ProtoReflect ¶
func (x *Workload) ProtoReflect() protoreflect.Message