observer

package
v0.0.0-...-c34bea4 Latest Latest
Warning

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

Go to latest
Published: May 20, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const AgentEventType_AGENT_EVENT_UNKNOWN = flow.AgentEventType_AGENT_EVENT_UNKNOWN
View Source
const AgentEventType_AGENT_STARTED = flow.AgentEventType_AGENT_STARTED
View Source
const AgentEventType_ENDPOINT_CREATED = flow.AgentEventType_ENDPOINT_CREATED
View Source
const AgentEventType_ENDPOINT_DELETED = flow.AgentEventType_ENDPOINT_DELETED
View Source
const AgentEventType_ENDPOINT_REGENERATE_FAILURE = flow.AgentEventType_ENDPOINT_REGENERATE_FAILURE
View Source
const AgentEventType_ENDPOINT_REGENERATE_SUCCESS = flow.AgentEventType_ENDPOINT_REGENERATE_SUCCESS
View Source
const AgentEventType_IPCACHE_DELETED = flow.AgentEventType_IPCACHE_DELETED
View Source
const AgentEventType_IPCACHE_UPSERTED = flow.AgentEventType_IPCACHE_UPSERTED
View Source
const AgentEventType_POLICY_DELETED = flow.AgentEventType_POLICY_DELETED
View Source
const AgentEventType_POLICY_UPDATED = flow.AgentEventType_POLICY_UPDATED
View Source
const AgentEventType_SERVICE_DELETED = flow.AgentEventType_SERVICE_DELETED
View Source
const AgentEventType_SERVICE_UPSERTED = flow.AgentEventType_SERVICE_UPSERTED
View Source
const DebugCapturePoint_DBG_CAPTURE_AFTER_V46 = flow.DebugCapturePoint_DBG_CAPTURE_AFTER_V46
View Source
const DebugCapturePoint_DBG_CAPTURE_AFTER_V64 = flow.DebugCapturePoint_DBG_CAPTURE_AFTER_V64
View Source
const DebugCapturePoint_DBG_CAPTURE_DELIVERY = flow.DebugCapturePoint_DBG_CAPTURE_DELIVERY
View Source
const DebugCapturePoint_DBG_CAPTURE_FROM_LB = flow.DebugCapturePoint_DBG_CAPTURE_FROM_LB
View Source
const DebugCapturePoint_DBG_CAPTURE_POINT_UNKNOWN = flow.DebugCapturePoint_DBG_CAPTURE_POINT_UNKNOWN
View Source
const DebugCapturePoint_DBG_CAPTURE_PROXY_POST = flow.DebugCapturePoint_DBG_CAPTURE_PROXY_POST
View Source
const DebugCapturePoint_DBG_CAPTURE_PROXY_PRE = flow.DebugCapturePoint_DBG_CAPTURE_PROXY_PRE
View Source
const DebugCapturePoint_DBG_CAPTURE_SNAT_POST = flow.DebugCapturePoint_DBG_CAPTURE_SNAT_POST
View Source
const DebugCapturePoint_DBG_CAPTURE_SNAT_PRE = flow.DebugCapturePoint_DBG_CAPTURE_SNAT_PRE
View Source
const DebugEventType_DBG_CT_CREATED = flow.DebugEventType_DBG_CT_CREATED
View Source
const DebugEventType_DBG_CT_CREATED2 = flow.DebugEventType_DBG_CT_CREATED2
View Source
const DebugEventType_DBG_CT_CREATED4 = flow.DebugEventType_DBG_CT_CREATED4
View Source
const DebugEventType_DBG_CT_CREATED6 = flow.DebugEventType_DBG_CT_CREATED6
View Source
const DebugEventType_DBG_CT_LOOKUP = flow.DebugEventType_DBG_CT_LOOKUP
View Source
const DebugEventType_DBG_CT_LOOKUP4 = flow.DebugEventType_DBG_CT_LOOKUP4
View Source
const DebugEventType_DBG_CT_LOOKUP4_1 = flow.DebugEventType_DBG_CT_LOOKUP4_1
View Source
const DebugEventType_DBG_CT_LOOKUP4_2 = flow.DebugEventType_DBG_CT_LOOKUP4_2
View Source
const DebugEventType_DBG_CT_LOOKUP6_1 = flow.DebugEventType_DBG_CT_LOOKUP6_1
View Source
const DebugEventType_DBG_CT_LOOKUP6_2 = flow.DebugEventType_DBG_CT_LOOKUP6_2
View Source
const DebugEventType_DBG_CT_LOOKUP_REV = flow.DebugEventType_DBG_CT_LOOKUP_REV
View Source
const DebugEventType_DBG_CT_MATCH = flow.DebugEventType_DBG_CT_MATCH
View Source
const DebugEventType_DBG_CT_VERDICT = flow.DebugEventType_DBG_CT_VERDICT
View Source
const DebugEventType_DBG_DECAP = flow.DebugEventType_DBG_DECAP
View Source
const DebugEventType_DBG_ENCAP = flow.DebugEventType_DBG_ENCAP
View Source
const DebugEventType_DBG_ERROR_RET = flow.DebugEventType_DBG_ERROR_RET
View Source
const DebugEventType_DBG_EVENT_UNKNOWN = flow.DebugEventType_DBG_EVENT_UNKNOWN
View Source
const DebugEventType_DBG_GENERIC = flow.DebugEventType_DBG_GENERIC
View Source
const DebugEventType_DBG_ICMP6_HANDLE = flow.DebugEventType_DBG_ICMP6_HANDLE
View Source
const DebugEventType_DBG_ICMP6_NS = flow.DebugEventType_DBG_ICMP6_NS
View Source
const DebugEventType_DBG_ICMP6_REQUEST = flow.DebugEventType_DBG_ICMP6_REQUEST
View Source
const DebugEventType_DBG_ICMP6_TIME_EXCEEDED = flow.DebugEventType_DBG_ICMP6_TIME_EXCEEDED
View Source
const DebugEventType_DBG_INHERIT_IDENTITY = flow.DebugEventType_DBG_INHERIT_IDENTITY
View Source
const DebugEventType_DBG_IP_ID_MAP_FAILED4 = flow.DebugEventType_DBG_IP_ID_MAP_FAILED4
View Source
const DebugEventType_DBG_IP_ID_MAP_FAILED6 = flow.DebugEventType_DBG_IP_ID_MAP_FAILED6
View Source
const DebugEventType_DBG_IP_ID_MAP_SUCCEED4 = flow.DebugEventType_DBG_IP_ID_MAP_SUCCEED4
View Source
const DebugEventType_DBG_IP_ID_MAP_SUCCEED6 = flow.DebugEventType_DBG_IP_ID_MAP_SUCCEED6
View Source
const DebugEventType_DBG_L4_CREATE = flow.DebugEventType_DBG_L4_CREATE
View Source
const DebugEventType_DBG_L4_POLICY = flow.DebugEventType_DBG_L4_POLICY
View Source
const DebugEventType_DBG_LB4_LOOKUP_BACKEND_FAIL = flow.DebugEventType_DBG_LB4_LOOKUP_BACKEND_FAIL
View Source
const DebugEventType_DBG_LB4_LOOKUP_BACKEND_SLOT = flow.DebugEventType_DBG_LB4_LOOKUP_BACKEND_SLOT
View Source
const DebugEventType_DBG_LB4_LOOKUP_BACKEND_SLOT_SUCCESS = flow.DebugEventType_DBG_LB4_LOOKUP_BACKEND_SLOT_SUCCESS
View Source
const DebugEventType_DBG_LB4_LOOKUP_BACKEND_SLOT_V2_FAIL = flow.DebugEventType_DBG_LB4_LOOKUP_BACKEND_SLOT_V2_FAIL
View Source
const DebugEventType_DBG_LB4_LOOKUP_FRONTEND = flow.DebugEventType_DBG_LB4_LOOKUP_FRONTEND
View Source
const DebugEventType_DBG_LB4_LOOKUP_FRONTEND_FAIL = flow.DebugEventType_DBG_LB4_LOOKUP_FRONTEND_FAIL
View Source
const DebugEventType_DBG_LB4_LOOPBACK_SNAT = flow.DebugEventType_DBG_LB4_LOOPBACK_SNAT
View Source
const DebugEventType_DBG_LB4_LOOPBACK_SNAT_REV = flow.DebugEventType_DBG_LB4_LOOPBACK_SNAT_REV
View Source
const DebugEventType_DBG_LB4_REVERSE_NAT = flow.DebugEventType_DBG_LB4_REVERSE_NAT
View Source
const DebugEventType_DBG_LB4_REVERSE_NAT_LOOKUP = flow.DebugEventType_DBG_LB4_REVERSE_NAT_LOOKUP
View Source
const DebugEventType_DBG_LB6_LOOKUP_BACKEND_FAIL = flow.DebugEventType_DBG_LB6_LOOKUP_BACKEND_FAIL
View Source
const DebugEventType_DBG_LB6_LOOKUP_BACKEND_SLOT = flow.DebugEventType_DBG_LB6_LOOKUP_BACKEND_SLOT
View Source
const DebugEventType_DBG_LB6_LOOKUP_BACKEND_SLOT_SUCCESS = flow.DebugEventType_DBG_LB6_LOOKUP_BACKEND_SLOT_SUCCESS
View Source
const DebugEventType_DBG_LB6_LOOKUP_BACKEND_SLOT_V2_FAIL = flow.DebugEventType_DBG_LB6_LOOKUP_BACKEND_SLOT_V2_FAIL
View Source
const DebugEventType_DBG_LB6_LOOKUP_FRONTEND = flow.DebugEventType_DBG_LB6_LOOKUP_FRONTEND
View Source
const DebugEventType_DBG_LB6_LOOKUP_FRONTEND_FAIL = flow.DebugEventType_DBG_LB6_LOOKUP_FRONTEND_FAIL
View Source
const DebugEventType_DBG_LB6_REVERSE_NAT = flow.DebugEventType_DBG_LB6_REVERSE_NAT
View Source
const DebugEventType_DBG_LB6_REVERSE_NAT_LOOKUP = flow.DebugEventType_DBG_LB6_REVERSE_NAT_LOOKUP
View Source
const DebugEventType_DBG_LB_STALE_CT = flow.DebugEventType_DBG_LB_STALE_CT
View Source
const DebugEventType_DBG_LOCAL_DELIVERY = flow.DebugEventType_DBG_LOCAL_DELIVERY
View Source
const DebugEventType_DBG_LXC_FOUND = flow.DebugEventType_DBG_LXC_FOUND
View Source
const DebugEventType_DBG_NETDEV_ENCAP4 = flow.DebugEventType_DBG_NETDEV_ENCAP4
View Source
const DebugEventType_DBG_NETDEV_IN_CLUSTER = flow.DebugEventType_DBG_NETDEV_IN_CLUSTER
View Source
const DebugEventType_DBG_PKT_HASH = flow.DebugEventType_DBG_PKT_HASH
View Source
const DebugEventType_DBG_POLICY_DENIED = flow.DebugEventType_DBG_POLICY_DENIED
View Source
const DebugEventType_DBG_PORT_MAP = flow.DebugEventType_DBG_PORT_MAP
View Source
const DebugEventType_DBG_REV_PROXY_FOUND = flow.DebugEventType_DBG_REV_PROXY_FOUND
View Source
const DebugEventType_DBG_REV_PROXY_LOOKUP = flow.DebugEventType_DBG_REV_PROXY_LOOKUP
View Source
const DebugEventType_DBG_REV_PROXY_UPDATE = flow.DebugEventType_DBG_REV_PROXY_UPDATE
View Source
const DebugEventType_DBG_RR_BACKEND_SLOT_SEL = flow.DebugEventType_DBG_RR_BACKEND_SLOT_SEL
View Source
const DebugEventType_DBG_SKIP_PROXY = flow.DebugEventType_DBG_SKIP_PROXY
View Source
const DebugEventType_DBG_SK_ASSIGN = flow.DebugEventType_DBG_SK_ASSIGN
View Source
const DebugEventType_DBG_SK_LOOKUP4 = flow.DebugEventType_DBG_SK_LOOKUP4
View Source
const DebugEventType_DBG_SK_LOOKUP6 = flow.DebugEventType_DBG_SK_LOOKUP6
View Source
const DebugEventType_DBG_TO_HOST = flow.DebugEventType_DBG_TO_HOST
View Source
const DebugEventType_DBG_TO_STACK = flow.DebugEventType_DBG_TO_STACK
View Source
const DropReason_CT_CANNOT_CREATE_ENTRY_FROM_PACKET = flow.DropReason_CT_CANNOT_CREATE_ENTRY_FROM_PACKET
View Source
const DropReason_CT_MAP_INSERTION_FAILED = flow.DropReason_CT_MAP_INSERTION_FAILED
View Source
const DropReason_CT_MISSING_TCP_ACK_FLAG = flow.DropReason_CT_MISSING_TCP_ACK_FLAG
View Source
const DropReason_CT_TRUNCATED_OR_INVALID_HEADER = flow.DropReason_CT_TRUNCATED_OR_INVALID_HEADER
View Source
const DropReason_CT_UNKNOWN_L4_PROTOCOL = flow.DropReason_CT_UNKNOWN_L4_PROTOCOL
View Source
const DropReason_DENIED_BY_LB_SRC_RANGE_CHECK = flow.DropReason_DENIED_BY_LB_SRC_RANGE_CHECK
View Source
const DropReason_DROP_REASON_UNKNOWN = flow.DropReason_DROP_REASON_UNKNOWN
View Source
const DropReason_ENCAPSULATION_TRAFFIC_IS_PROHIBITED = flow.DropReason_ENCAPSULATION_TRAFFIC_IS_PROHIBITED
View Source
const DropReason_ERROR_RETRIEVING_TUNNEL_KEY = flow.DropReason_ERROR_RETRIEVING_TUNNEL_KEY
View Source
const DropReason_ERROR_RETRIEVING_TUNNEL_OPTIONS = flow.DropReason_ERROR_RETRIEVING_TUNNEL_OPTIONS
View Source
const DropReason_ERROR_WHILE_CORRECTING_L3_CHECKSUM = flow.DropReason_ERROR_WHILE_CORRECTING_L3_CHECKSUM
View Source
const DropReason_ERROR_WHILE_CORRECTING_L4_CHECKSUM = flow.DropReason_ERROR_WHILE_CORRECTING_L4_CHECKSUM
View Source
const DropReason_ERROR_WRITING_TO_PACKET = flow.DropReason_ERROR_WRITING_TO_PACKET
View Source
const DropReason_FAILED_TO_INSERT_INTO_PROXYMAP = flow.DropReason_FAILED_TO_INSERT_INTO_PROXYMAP
View Source
const DropReason_FIB_LOOKUP_FAILED = flow.DropReason_FIB_LOOKUP_FAILED
View Source
const DropReason_FIRST_LOGICAL_DATAGRAM_FRAGMENT_NOT_FOUND = flow.DropReason_FIRST_LOGICAL_DATAGRAM_FRAGMENT_NOT_FOUND
View Source
const DropReason_FORBIDDEN_ICMPV6_MESSAGE = flow.DropReason_FORBIDDEN_ICMPV6_MESSAGE
View Source
const DropReason_INVALID_DESTINATION_MAC = flow.DropReason_INVALID_DESTINATION_MAC
View Source
const DropReason_INVALID_GENEVE_OPTION = flow.DropReason_INVALID_GENEVE_OPTION
View Source
const DropReason_INVALID_IDENTITY = flow.DropReason_INVALID_IDENTITY
View Source
const DropReason_INVALID_IPV6_EXTENSION_HEADER = flow.DropReason_INVALID_IPV6_EXTENSION_HEADER
View Source
const DropReason_INVALID_PACKET_DROPPED = flow.DropReason_INVALID_PACKET_DROPPED
View Source
const DropReason_INVALID_SOURCE_IP = flow.DropReason_INVALID_SOURCE_IP
View Source
const DropReason_INVALID_SOURCE_MAC = flow.DropReason_INVALID_SOURCE_MAC
View Source
const DropReason_IP_FRAGMENTATION_NOT_SUPPORTED = flow.DropReason_IP_FRAGMENTATION_NOT_SUPPORTED
View Source
const DropReason_IS_A_CLUSTERIP = flow.DropReason_IS_A_CLUSTERIP
View Source
const DropReason_LOCAL_HOST_IS_UNREACHABLE = flow.DropReason_LOCAL_HOST_IS_UNREACHABLE
View Source
const DropReason_MISSED_TAIL_CALL = flow.DropReason_MISSED_TAIL_CALL
View Source
const DropReason_NAT_NOT_NEEDED = flow.DropReason_NAT_NOT_NEEDED
View Source
const DropReason_NO_CONFIGURATION_AVAILABLE_TO_PERFORM_POLICY_DECISION = flow.DropReason_NO_CONFIGURATION_AVAILABLE_TO_PERFORM_POLICY_DECISION
View Source
const DropReason_NO_MAPPING_FOR_NAT_MASQUERADE = flow.DropReason_NO_MAPPING_FOR_NAT_MASQUERADE
View Source
const DropReason_NO_MATCHING_LOCAL_CONTAINER_FOUND = flow.DropReason_NO_MATCHING_LOCAL_CONTAINER_FOUND
View Source
const DropReason_NO_TUNNEL_OR_ENCAPSULATION_ENDPOINT = flow.DropReason_NO_TUNNEL_OR_ENCAPSULATION_ENDPOINT
View Source
const DropReason_POLICY_DENIED = flow.DropReason_POLICY_DENIED
View Source
const DropReason_PROXY_REDIRECTION_NOT_SUPPORTED_FOR_PROTOCOL = flow.DropReason_PROXY_REDIRECTION_NOT_SUPPORTED_FOR_PROTOCOL
View Source
const DropReason_REACHED_EDT_RATE_LIMITING_DROP_HORIZON = flow.DropReason_REACHED_EDT_RATE_LIMITING_DROP_HORIZON
View Source
const DropReason_SERVICE_BACKEND_NOT_FOUND = flow.DropReason_SERVICE_BACKEND_NOT_FOUND
View Source
const DropReason_SOCKET_ASSIGN_FAILED = flow.DropReason_SOCKET_ASSIGN_FAILED
View Source
const DropReason_SOCKET_LOOKUP_FAILED = flow.DropReason_SOCKET_LOOKUP_FAILED
View Source
const DropReason_STALE_OR_UNROUTABLE_IP = flow.DropReason_STALE_OR_UNROUTABLE_IP
View Source
const DropReason_UNKNOWN_CONNECTION_TRACKING_STATE = flow.DropReason_UNKNOWN_CONNECTION_TRACKING_STATE
View Source
const DropReason_UNKNOWN_ICMPV4_CODE = flow.DropReason_UNKNOWN_ICMPV4_CODE
View Source
const DropReason_UNKNOWN_ICMPV4_TYPE = flow.DropReason_UNKNOWN_ICMPV4_TYPE
View Source
const DropReason_UNKNOWN_ICMPV6_CODE = flow.DropReason_UNKNOWN_ICMPV6_CODE
View Source
const DropReason_UNKNOWN_ICMPV6_TYPE = flow.DropReason_UNKNOWN_ICMPV6_TYPE
View Source
const DropReason_UNKNOWN_L3_TARGET_ADDRESS = flow.DropReason_UNKNOWN_L3_TARGET_ADDRESS
View Source
const DropReason_UNKNOWN_L4_PROTOCOL = flow.DropReason_UNKNOWN_L4_PROTOCOL
View Source
const DropReason_UNKNOWN_SENDER = flow.DropReason_UNKNOWN_SENDER
View Source
const DropReason_UNSUPPORTED_L2_PROTOCOL = flow.DropReason_UNSUPPORTED_L2_PROTOCOL
View Source
const DropReason_UNSUPPORTED_L3_PROTOCOL = flow.DropReason_UNSUPPORTED_L3_PROTOCOL
View Source
const DropReason_UNSUPPORTED_PROTOCOL_FOR_NAT_MASQUERADE = flow.DropReason_UNSUPPORTED_PROTOCOL_FOR_NAT_MASQUERADE
View Source
const DropReason_VLAN_FILTERED = flow.DropReason_VLAN_FILTERED
View Source
const EventType_EventSample = flow.EventType_EventSample
View Source
const EventType_RecordLost = flow.EventType_RecordLost
View Source
const EventType_UNKNOWN = flow.EventType_UNKNOWN
View Source
const FlowType_L3_L4 = flow.FlowType_L3_L4
View Source
const FlowType_L7 = flow.FlowType_L7
View Source
const FlowType_UNKNOWN_TYPE = flow.FlowType_UNKNOWN_TYPE
View Source
const IPVersion_IP_NOT_USED = flow.IPVersion_IP_NOT_USED
View Source
const IPVersion_IPv4 = flow.IPVersion_IPv4
View Source
const IPVersion_IPv6 = flow.IPVersion_IPv6
View Source
const L7FlowType_REQUEST = flow.L7FlowType_REQUEST
View Source
const L7FlowType_RESPONSE = flow.L7FlowType_RESPONSE
View Source
const L7FlowType_SAMPLE = flow.L7FlowType_SAMPLE
View Source
const L7FlowType_UNKNOWN_L7_TYPE = flow.L7FlowType_UNKNOWN_L7_TYPE
View Source
const LostEventSource_HUBBLE_RING_BUFFER = flow.LostEventSource_HUBBLE_RING_BUFFER
View Source
const LostEventSource_OBSERVER_EVENTS_QUEUE = flow.LostEventSource_OBSERVER_EVENTS_QUEUE
View Source
const LostEventSource_PERF_EVENT_RING_BUFFER = flow.LostEventSource_PERF_EVENT_RING_BUFFER
View Source
const LostEventSource_UNKNOWN_LOST_EVENT_SOURCE = flow.LostEventSource_UNKNOWN_LOST_EVENT_SOURCE
View Source
const TraceObservationPoint_FROM_ENDPOINT = flow.TraceObservationPoint_FROM_ENDPOINT
View Source
const TraceObservationPoint_FROM_HOST = flow.TraceObservationPoint_FROM_HOST
View Source
const TraceObservationPoint_FROM_NETWORK = flow.TraceObservationPoint_FROM_NETWORK
View Source
const TraceObservationPoint_FROM_OVERLAY = flow.TraceObservationPoint_FROM_OVERLAY
View Source
const TraceObservationPoint_FROM_PROXY = flow.TraceObservationPoint_FROM_PROXY
View Source
const TraceObservationPoint_FROM_STACK = flow.TraceObservationPoint_FROM_STACK
View Source
const TraceObservationPoint_TO_ENDPOINT = flow.TraceObservationPoint_TO_ENDPOINT
View Source
const TraceObservationPoint_TO_HOST = flow.TraceObservationPoint_TO_HOST
View Source
const TraceObservationPoint_TO_NETWORK = flow.TraceObservationPoint_TO_NETWORK
View Source
const TraceObservationPoint_TO_OVERLAY = flow.TraceObservationPoint_TO_OVERLAY
View Source
const TraceObservationPoint_TO_PROXY = flow.TraceObservationPoint_TO_PROXY
View Source
const TraceObservationPoint_TO_STACK = flow.TraceObservationPoint_TO_STACK
View Source
const TraceObservationPoint_UNKNOWN_POINT = flow.TraceObservationPoint_UNKNOWN_POINT
View Source
const TrafficDirection_EGRESS = flow.TrafficDirection_EGRESS
View Source
const TrafficDirection_INGRESS = flow.TrafficDirection_INGRESS
View Source
const TrafficDirection_TRAFFIC_DIRECTION_UNKNOWN = flow.TrafficDirection_TRAFFIC_DIRECTION_UNKNOWN
View Source
const Verdict_AUDIT = flow.Verdict_AUDIT
View Source
const Verdict_DROPPED = flow.Verdict_DROPPED
View Source
const Verdict_ERROR = flow.Verdict_ERROR
View Source
const Verdict_FORWARDED = flow.Verdict_FORWARDED
View Source
const Verdict_REDIRECTED = flow.Verdict_REDIRECTED
View Source
const Verdict_VERDICT_UNKNOWN = flow.Verdict_VERDICT_UNKNOWN

Variables

View Source
var AgentEventType_name = flow.AgentEventType_name
View Source
var AgentEventType_value = flow.AgentEventType_value
View Source
var DebugCapturePoint_name = flow.DebugCapturePoint_name
View Source
var DebugCapturePoint_value = flow.DebugCapturePoint_value
View Source
var DebugEventType_name = flow.DebugEventType_name
View Source
var DebugEventType_value = flow.DebugEventType_value
View Source
var DropReason_name = flow.DropReason_name
View Source
var DropReason_value = flow.DropReason_value
View Source
var EventType_name = flow.EventType_name
View Source
var EventType_value = flow.EventType_value
View Source
var File_observer_observer_proto protoreflect.FileDescriptor
View Source
var FlowType_name = flow.FlowType_name
View Source
var FlowType_value = flow.FlowType_value
View Source
var IPVersion_name = flow.IPVersion_name
View Source
var IPVersion_value = flow.IPVersion_value
View Source
var L7FlowType_name = flow.L7FlowType_name
View Source
var L7FlowType_value = flow.L7FlowType_value
View Source
var LostEventSource_name = flow.LostEventSource_name
View Source
var LostEventSource_value = flow.LostEventSource_value
View Source
var Observer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "observer.Observer",
	HandlerType: (*ObserverServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetNodes",
			Handler:    _Observer_GetNodes_Handler,
		},
		{
			MethodName: "ServerStatus",
			Handler:    _Observer_ServerStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetFlows",
			Handler:       _Observer_GetFlows_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAgentEvents",
			Handler:       _Observer_GetAgentEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetDebugEvents",
			Handler:       _Observer_GetDebugEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "observer/observer.proto",
}

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

View Source
var TraceObservationPoint_name = flow.TraceObservationPoint_name
View Source
var TraceObservationPoint_value = flow.TraceObservationPoint_value
View Source
var TrafficDirection_name = flow.TrafficDirection_name
View Source
var TrafficDirection_value = flow.TrafficDirection_value
View Source
var Verdict_name = flow.Verdict_name
View Source
var Verdict_value = flow.Verdict_value

Functions

func RegisterObserverServer

func RegisterObserverServer(s grpc.ServiceRegistrar, srv ObserverServer)

Types

type AgentEvent

type AgentEvent = flow.AgentEvent

type AgentEventType

type AgentEventType = flow.AgentEventType

type AgentEventUnknown

type AgentEventUnknown = flow.AgentEventUnknown

type AgentEvent_AgentStart

type AgentEvent_AgentStart = flow.AgentEvent_AgentStart

type AgentEvent_EndpointRegenerate

type AgentEvent_EndpointRegenerate = flow.AgentEvent_EndpointRegenerate

type AgentEvent_EndpointUpdate

type AgentEvent_EndpointUpdate = flow.AgentEvent_EndpointUpdate

type AgentEvent_IpcacheUpdate

type AgentEvent_IpcacheUpdate = flow.AgentEvent_IpcacheUpdate

type AgentEvent_PolicyUpdate

type AgentEvent_PolicyUpdate = flow.AgentEvent_PolicyUpdate

type AgentEvent_ServiceDelete

type AgentEvent_ServiceDelete = flow.AgentEvent_ServiceDelete

type AgentEvent_ServiceUpsert

type AgentEvent_ServiceUpsert = flow.AgentEvent_ServiceUpsert

type AgentEvent_Unknown

type AgentEvent_Unknown = flow.AgentEvent_Unknown

type CiliumEventType

type CiliumEventType = flow.CiliumEventType

type DNS

type DNS = flow.DNS

type DebugCapturePoint

type DebugCapturePoint = flow.DebugCapturePoint

type DebugEvent

type DebugEvent = flow.DebugEvent

type DebugEventType

type DebugEventType = flow.DebugEventType

type DropReason

type DropReason = flow.DropReason

type Endpoint

type Endpoint = flow.Endpoint

type EndpointRegenNotification

type EndpointRegenNotification = flow.EndpointRegenNotification

type EndpointUpdateNotification

type EndpointUpdateNotification = flow.EndpointUpdateNotification

type Ethernet

type Ethernet = flow.Ethernet

type EventType

type EventType = flow.EventType

type EventTypeFilter

type EventTypeFilter = flow.EventTypeFilter

type ExportEvent

type ExportEvent struct {

	// Types that are assignable to ResponseTypes:
	//	*ExportEvent_Flow
	//	*ExportEvent_NodeStatus
	//	*ExportEvent_LostEvents
	//	*ExportEvent_AgentEvent
	//	*ExportEvent_DebugEvent
	ResponseTypes isExportEvent_ResponseTypes `protobuf_oneof:"response_types"`
	// Name of the node where this event was observed.
	NodeName string `protobuf:"bytes,1000,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Timestamp at which this event was observed.
	Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

ExportEvent contains an event to be exported. Not to be used outside of the exporter feature.

func (*ExportEvent) Descriptor deprecated

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

Deprecated: Use ExportEvent.ProtoReflect.Descriptor instead.

func (*ExportEvent) GetAgentEvent

func (x *ExportEvent) GetAgentEvent() *flow.AgentEvent

func (*ExportEvent) GetDebugEvent

func (x *ExportEvent) GetDebugEvent() *flow.DebugEvent

func (*ExportEvent) GetFlow

func (x *ExportEvent) GetFlow() *flow.Flow

func (*ExportEvent) GetLostEvents

func (x *ExportEvent) GetLostEvents() *flow.LostEvent

func (*ExportEvent) GetNodeName

func (x *ExportEvent) GetNodeName() string

func (*ExportEvent) GetNodeStatus

func (x *ExportEvent) GetNodeStatus() *relay.NodeStatusEvent

func (*ExportEvent) GetResponseTypes

func (m *ExportEvent) GetResponseTypes() isExportEvent_ResponseTypes

func (*ExportEvent) GetTime

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

func (*ExportEvent) MarshalJSON

func (msg *ExportEvent) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ExportEvent) ProtoMessage

func (*ExportEvent) ProtoMessage()

func (*ExportEvent) ProtoReflect

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

func (*ExportEvent) Reset

func (x *ExportEvent) Reset()

func (*ExportEvent) String

func (x *ExportEvent) String() string

func (*ExportEvent) UnmarshalJSON

func (msg *ExportEvent) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type ExportEvent_AgentEvent

type ExportEvent_AgentEvent struct {
	// agent_event informs clients about an event received from the Cilium
	// agent.
	AgentEvent *flow.AgentEvent `protobuf:"bytes,4,opt,name=agent_event,json=agentEvent,proto3,oneof"`
}

type ExportEvent_DebugEvent

type ExportEvent_DebugEvent struct {
	// debug_event contains Cilium datapath debug events
	DebugEvent *flow.DebugEvent `protobuf:"bytes,5,opt,name=debug_event,json=debugEvent,proto3,oneof"`
}

type ExportEvent_Flow

type ExportEvent_Flow struct {
	Flow *flow.Flow `protobuf:"bytes,1,opt,name=flow,proto3,oneof"`
}

type ExportEvent_LostEvents

type ExportEvent_LostEvents struct {
	// lost_events informs clients about events which got dropped due to
	// a Hubble component being unavailable
	LostEvents *flow.LostEvent `protobuf:"bytes,3,opt,name=lost_events,json=lostEvents,proto3,oneof"`
}

type ExportEvent_NodeStatus

type ExportEvent_NodeStatus struct {
	// node_status informs clients about the state of the nodes
	// participating in this particular GetFlows request.
	NodeStatus *relay.NodeStatusEvent `protobuf:"bytes,2,opt,name=node_status,json=nodeStatus,proto3,oneof"`
}

type Flow

type Flow = flow.Flow

type FlowFilter

type FlowFilter = flow.FlowFilter

type FlowType

type FlowType = flow.FlowType

type GetAgentEventsRequest

type GetAgentEventsRequest struct {

	// Number of agent events that should be returned. Incompatible with
	// `since/until`.
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// follow sets when the server should continue to stream agent events after
	// printing the last N agent events.
	Follow bool `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	// Since this time for returned agent events. Incompatible with `number`.
	Since *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"`
	// Until this time for returned agent events. Incompatible with `number`.
	Until *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=until,proto3" json:"until,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAgentEventsRequest) Descriptor deprecated

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

Deprecated: Use GetAgentEventsRequest.ProtoReflect.Descriptor instead.

func (*GetAgentEventsRequest) GetFollow

func (x *GetAgentEventsRequest) GetFollow() bool

func (*GetAgentEventsRequest) GetNumber

func (x *GetAgentEventsRequest) GetNumber() uint64

func (*GetAgentEventsRequest) GetSince

func (*GetAgentEventsRequest) GetUntil

func (*GetAgentEventsRequest) MarshalJSON

func (msg *GetAgentEventsRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetAgentEventsRequest) ProtoMessage

func (*GetAgentEventsRequest) ProtoMessage()

func (*GetAgentEventsRequest) ProtoReflect

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

func (*GetAgentEventsRequest) Reset

func (x *GetAgentEventsRequest) Reset()

func (*GetAgentEventsRequest) String

func (x *GetAgentEventsRequest) String() string

func (*GetAgentEventsRequest) UnmarshalJSON

func (msg *GetAgentEventsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetAgentEventsResponse

type GetAgentEventsResponse struct {
	AgentEvent *flow.AgentEvent `protobuf:"bytes,1,opt,name=agent_event,json=agentEvent,proto3" json:"agent_event,omitempty"`
	// Name of the node where this event was observed.
	NodeName string `protobuf:"bytes,1000,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Timestamp at which this event was observed.
	Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

GetAgentEventsResponse contains an event received from the Cilium agent.

func (*GetAgentEventsResponse) Descriptor deprecated

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

Deprecated: Use GetAgentEventsResponse.ProtoReflect.Descriptor instead.

func (*GetAgentEventsResponse) GetAgentEvent

func (x *GetAgentEventsResponse) GetAgentEvent() *flow.AgentEvent

func (*GetAgentEventsResponse) GetNodeName

func (x *GetAgentEventsResponse) GetNodeName() string

func (*GetAgentEventsResponse) GetTime

func (*GetAgentEventsResponse) MarshalJSON

func (msg *GetAgentEventsResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetAgentEventsResponse) ProtoMessage

func (*GetAgentEventsResponse) ProtoMessage()

func (*GetAgentEventsResponse) ProtoReflect

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

func (*GetAgentEventsResponse) Reset

func (x *GetAgentEventsResponse) Reset()

func (*GetAgentEventsResponse) String

func (x *GetAgentEventsResponse) String() string

func (*GetAgentEventsResponse) UnmarshalJSON

func (msg *GetAgentEventsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetDebugEventsRequest

type GetDebugEventsRequest struct {

	// Number of debug events that should be returned. Incompatible with
	// `since/until`.
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// follow sets when the server should continue to stream debug events after
	// printing the last N debug events.
	Follow bool `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	// Since this time for returned debug events. Incompatible with `number`.
	Since *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"`
	// Until this time for returned debug events. Incompatible with `number`.
	Until *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=until,proto3" json:"until,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDebugEventsRequest) Descriptor deprecated

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

Deprecated: Use GetDebugEventsRequest.ProtoReflect.Descriptor instead.

func (*GetDebugEventsRequest) GetFollow

func (x *GetDebugEventsRequest) GetFollow() bool

func (*GetDebugEventsRequest) GetNumber

func (x *GetDebugEventsRequest) GetNumber() uint64

func (*GetDebugEventsRequest) GetSince

func (*GetDebugEventsRequest) GetUntil

func (*GetDebugEventsRequest) MarshalJSON

func (msg *GetDebugEventsRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetDebugEventsRequest) ProtoMessage

func (*GetDebugEventsRequest) ProtoMessage()

func (*GetDebugEventsRequest) ProtoReflect

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

func (*GetDebugEventsRequest) Reset

func (x *GetDebugEventsRequest) Reset()

func (*GetDebugEventsRequest) String

func (x *GetDebugEventsRequest) String() string

func (*GetDebugEventsRequest) UnmarshalJSON

func (msg *GetDebugEventsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetDebugEventsResponse

type GetDebugEventsResponse struct {
	DebugEvent *flow.DebugEvent `protobuf:"bytes,1,opt,name=debug_event,json=debugEvent,proto3" json:"debug_event,omitempty"`
	// Name of the node where this event was observed.
	NodeName string `protobuf:"bytes,1000,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Timestamp at which this event was observed.
	Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

GetDebugEventsResponse contains a Cilium datapath debug events.

func (*GetDebugEventsResponse) Descriptor deprecated

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

Deprecated: Use GetDebugEventsResponse.ProtoReflect.Descriptor instead.

func (*GetDebugEventsResponse) GetDebugEvent

func (x *GetDebugEventsResponse) GetDebugEvent() *flow.DebugEvent

func (*GetDebugEventsResponse) GetNodeName

func (x *GetDebugEventsResponse) GetNodeName() string

func (*GetDebugEventsResponse) GetTime

func (*GetDebugEventsResponse) MarshalJSON

func (msg *GetDebugEventsResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetDebugEventsResponse) ProtoMessage

func (*GetDebugEventsResponse) ProtoMessage()

func (*GetDebugEventsResponse) ProtoReflect

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

func (*GetDebugEventsResponse) Reset

func (x *GetDebugEventsResponse) Reset()

func (*GetDebugEventsResponse) String

func (x *GetDebugEventsResponse) String() string

func (*GetDebugEventsResponse) UnmarshalJSON

func (msg *GetDebugEventsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetFlowsRequest

type GetFlowsRequest struct {

	// Number of flows that should be returned. Incompatible with `since/until`.
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// follow sets when the server should continue to stream flows after
	// printing the last N flows.
	Follow bool `protobuf:"varint,3,opt,name=follow,proto3" json:"follow,omitempty"`
	// blacklist defines a list of filters which have to match for a flow to be
	// excluded from the result.
	// If multiple blacklist filters are specified, only one of them has to
	// match for a flow to be excluded.
	Blacklist []*flow.FlowFilter `protobuf:"bytes,5,rep,name=blacklist,proto3" json:"blacklist,omitempty"`
	// whitelist defines a list of filters which have to match for a flow to be
	// included in the result.
	// If multiple whitelist filters are specified, only one of them has to
	// match for a flow to be included.
	// The whitelist and blacklist can both be specified. In such cases, the
	// set of the returned flows is the set difference `whitelist - blacklist`.
	// In other words, the result will contain all flows matched by the
	// whitelist that are not also simultaneously matched by the blacklist.
	Whitelist []*flow.FlowFilter `protobuf:"bytes,6,rep,name=whitelist,proto3" json:"whitelist,omitempty"`
	// Since this time for returned flows. Incompatible with `number`.
	Since *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"`
	// Until this time for returned flows. Incompatible with `number`.
	Until *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=until,proto3" json:"until,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFlowsRequest) Descriptor deprecated

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

Deprecated: Use GetFlowsRequest.ProtoReflect.Descriptor instead.

func (*GetFlowsRequest) GetBlacklist

func (x *GetFlowsRequest) GetBlacklist() []*flow.FlowFilter

func (*GetFlowsRequest) GetFollow

func (x *GetFlowsRequest) GetFollow() bool

func (*GetFlowsRequest) GetNumber

func (x *GetFlowsRequest) GetNumber() uint64

func (*GetFlowsRequest) GetSince

func (x *GetFlowsRequest) GetSince() *timestamppb.Timestamp

func (*GetFlowsRequest) GetUntil

func (x *GetFlowsRequest) GetUntil() *timestamppb.Timestamp

func (*GetFlowsRequest) GetWhitelist

func (x *GetFlowsRequest) GetWhitelist() []*flow.FlowFilter

func (*GetFlowsRequest) MarshalJSON

func (msg *GetFlowsRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetFlowsRequest) ProtoMessage

func (*GetFlowsRequest) ProtoMessage()

func (*GetFlowsRequest) ProtoReflect

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

func (*GetFlowsRequest) Reset

func (x *GetFlowsRequest) Reset()

func (*GetFlowsRequest) String

func (x *GetFlowsRequest) String() string

func (*GetFlowsRequest) UnmarshalJSON

func (msg *GetFlowsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetFlowsResponse

type GetFlowsResponse struct {

	// Types that are assignable to ResponseTypes:
	//	*GetFlowsResponse_Flow
	//	*GetFlowsResponse_NodeStatus
	//	*GetFlowsResponse_LostEvents
	ResponseTypes isGetFlowsResponse_ResponseTypes `protobuf_oneof:"response_types"`
	// Name of the node where this event was observed.
	NodeName string `protobuf:"bytes,1000,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Timestamp at which this event was observed.
	Time *timestamppb.Timestamp `protobuf:"bytes,1001,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

GetFlowsResponse contains either a flow or a protocol message.

func (*GetFlowsResponse) Descriptor deprecated

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

Deprecated: Use GetFlowsResponse.ProtoReflect.Descriptor instead.

func (*GetFlowsResponse) GetFlow

func (x *GetFlowsResponse) GetFlow() *flow.Flow

func (*GetFlowsResponse) GetLostEvents

func (x *GetFlowsResponse) GetLostEvents() *flow.LostEvent

func (*GetFlowsResponse) GetNodeName

func (x *GetFlowsResponse) GetNodeName() string

func (*GetFlowsResponse) GetNodeStatus

func (x *GetFlowsResponse) GetNodeStatus() *relay.NodeStatusEvent

func (*GetFlowsResponse) GetResponseTypes

func (m *GetFlowsResponse) GetResponseTypes() isGetFlowsResponse_ResponseTypes

func (*GetFlowsResponse) GetTime

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

func (*GetFlowsResponse) MarshalJSON

func (msg *GetFlowsResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetFlowsResponse) ProtoMessage

func (*GetFlowsResponse) ProtoMessage()

func (*GetFlowsResponse) ProtoReflect

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

func (*GetFlowsResponse) Reset

func (x *GetFlowsResponse) Reset()

func (*GetFlowsResponse) String

func (x *GetFlowsResponse) String() string

func (*GetFlowsResponse) UnmarshalJSON

func (msg *GetFlowsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetFlowsResponse_Flow

type GetFlowsResponse_Flow struct {
	Flow *flow.Flow `protobuf:"bytes,1,opt,name=flow,proto3,oneof"`
}

type GetFlowsResponse_LostEvents

type GetFlowsResponse_LostEvents struct {
	// lost_events informs clients about events which got dropped due to
	// a Hubble component being unavailable
	LostEvents *flow.LostEvent `protobuf:"bytes,3,opt,name=lost_events,json=lostEvents,proto3,oneof"`
}

type GetFlowsResponse_NodeStatus

type GetFlowsResponse_NodeStatus struct {
	// node_status informs clients about the state of the nodes
	// participating in this particular GetFlows request.
	NodeStatus *relay.NodeStatusEvent `protobuf:"bytes,2,opt,name=node_status,json=nodeStatus,proto3,oneof"`
}

type GetNodesRequest

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

func (*GetNodesRequest) Descriptor deprecated

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

Deprecated: Use GetNodesRequest.ProtoReflect.Descriptor instead.

func (*GetNodesRequest) MarshalJSON

func (msg *GetNodesRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetNodesRequest) ProtoMessage

func (*GetNodesRequest) ProtoMessage()

func (*GetNodesRequest) ProtoReflect

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

func (*GetNodesRequest) Reset

func (x *GetNodesRequest) Reset()

func (*GetNodesRequest) String

func (x *GetNodesRequest) String() string

func (*GetNodesRequest) UnmarshalJSON

func (msg *GetNodesRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetNodesResponse

type GetNodesResponse struct {

	// Nodes is an exhaustive list of nodes.
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

GetNodesResponse contains the list of nodes.

func (*GetNodesResponse) Descriptor deprecated

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

Deprecated: Use GetNodesResponse.ProtoReflect.Descriptor instead.

func (*GetNodesResponse) GetNodes

func (x *GetNodesResponse) GetNodes() []*Node

func (*GetNodesResponse) MarshalJSON

func (msg *GetNodesResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetNodesResponse) ProtoMessage

func (*GetNodesResponse) ProtoMessage()

func (*GetNodesResponse) ProtoReflect

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

func (*GetNodesResponse) Reset

func (x *GetNodesResponse) Reset()

func (*GetNodesResponse) String

func (x *GetNodesResponse) String() string

func (*GetNodesResponse) UnmarshalJSON

func (msg *GetNodesResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type HTTP

type HTTP = flow.HTTP

type HTTPHeader

type HTTPHeader = flow.HTTPHeader

type ICMPv4

type ICMPv4 = flow.ICMPv4

type ICMPv6

type ICMPv6 = flow.ICMPv6

type IP

type IP = flow.IP

type IPCacheNotification

type IPCacheNotification = flow.IPCacheNotification

type IPVersion

type IPVersion = flow.IPVersion

type Kafka

type Kafka = flow.Kafka

type L7FlowType

type L7FlowType = flow.L7FlowType

type Layer4

type Layer4 = flow.Layer4

type Layer4_ICMPv4

type Layer4_ICMPv4 = flow.Layer4_ICMPv4

type Layer4_ICMPv6

type Layer4_ICMPv6 = flow.Layer4_ICMPv6

type Layer4_TCP

type Layer4_TCP = flow.Layer4_TCP

type Layer4_UDP

type Layer4_UDP = flow.Layer4_UDP

type Layer7

type Layer7 = flow.Layer7

type Layer7_Dns

type Layer7_Dns = flow.Layer7_Dns

type Layer7_Http

type Layer7_Http = flow.Layer7_Http

type Layer7_Kafka

type Layer7_Kafka = flow.Layer7_Kafka

type LostEvent

type LostEvent = flow.LostEvent

type LostEventSource

type LostEventSource = flow.LostEventSource

type NetworkInterface

type NetworkInterface = flow.NetworkInterface

type Node

type Node struct {

	// Name is the name of the node.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Version is the version of Cilium/Hubble as reported by the node.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Address is the network address of the API endpoint.
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// State represents the known state of the node.
	State relay.NodeState `protobuf:"varint,4,opt,name=state,proto3,enum=relay.NodeState" json:"state,omitempty"`
	// TLS reports TLS related information.
	Tls *TLS `protobuf:"bytes,5,opt,name=tls,proto3" json:"tls,omitempty"`
	// UptimeNS is the uptime of this instance in nanoseconds
	UptimeNs uint64 `protobuf:"varint,6,opt,name=uptime_ns,json=uptimeNs,proto3" json:"uptime_ns,omitempty"`
	// number of currently captured flows
	NumFlows uint64 `protobuf:"varint,7,opt,name=num_flows,json=numFlows,proto3" json:"num_flows,omitempty"`
	// maximum capacity of the ring buffer
	MaxFlows uint64 `protobuf:"varint,8,opt,name=max_flows,json=maxFlows,proto3" json:"max_flows,omitempty"`
	// total amount of flows observed since the observer was started
	SeenFlows uint64 `protobuf:"varint,9,opt,name=seen_flows,json=seenFlows,proto3" json:"seen_flows,omitempty"`
	// contains filtered or unexported fields
}

Node represents a cluster node.

func (*Node) Descriptor deprecated

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAddress

func (x *Node) GetAddress() string

func (*Node) GetMaxFlows

func (x *Node) GetMaxFlows() uint64

func (*Node) GetName

func (x *Node) GetName() string

func (*Node) GetNumFlows

func (x *Node) GetNumFlows() uint64

func (*Node) GetSeenFlows

func (x *Node) GetSeenFlows() uint64

func (*Node) GetState

func (x *Node) GetState() relay.NodeState

func (*Node) GetTls

func (x *Node) GetTls() *TLS

func (*Node) GetUptimeNs

func (x *Node) GetUptimeNs() uint64

func (*Node) GetVersion

func (x *Node) GetVersion() string

func (*Node) MarshalJSON

func (msg *Node) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) ProtoReflect

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

func (*Node) Reset

func (x *Node) Reset()

func (*Node) String

func (x *Node) String() string

func (*Node) UnmarshalJSON

func (msg *Node) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type ObserverClient

type ObserverClient interface {
	// GetFlows returning structured data, meant to eventually obsolete GetLastNFlows.
	GetFlows(ctx context.Context, in *GetFlowsRequest, opts ...grpc.CallOption) (Observer_GetFlowsClient, error)
	// GetAgentEvents returns Cilium agent events.
	GetAgentEvents(ctx context.Context, in *GetAgentEventsRequest, opts ...grpc.CallOption) (Observer_GetAgentEventsClient, error)
	// GetDebugEvents returns Cilium datapath debug events.
	GetDebugEvents(ctx context.Context, in *GetDebugEventsRequest, opts ...grpc.CallOption) (Observer_GetDebugEventsClient, error)
	// GetNodes returns information about nodes in a cluster.
	GetNodes(ctx context.Context, in *GetNodesRequest, opts ...grpc.CallOption) (*GetNodesResponse, error)
	// ServerStatus returns some details about the running hubble server.
	ServerStatus(ctx context.Context, in *ServerStatusRequest, opts ...grpc.CallOption) (*ServerStatusResponse, error)
}

ObserverClient is the client API for Observer 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.

func NewObserverClient

func NewObserverClient(cc grpc.ClientConnInterface) ObserverClient

type ObserverServer

type ObserverServer interface {
	// GetFlows returning structured data, meant to eventually obsolete GetLastNFlows.
	GetFlows(*GetFlowsRequest, Observer_GetFlowsServer) error
	// GetAgentEvents returns Cilium agent events.
	GetAgentEvents(*GetAgentEventsRequest, Observer_GetAgentEventsServer) error
	// GetDebugEvents returns Cilium datapath debug events.
	GetDebugEvents(*GetDebugEventsRequest, Observer_GetDebugEventsServer) error
	// GetNodes returns information about nodes in a cluster.
	GetNodes(context.Context, *GetNodesRequest) (*GetNodesResponse, error)
	// ServerStatus returns some details about the running hubble server.
	ServerStatus(context.Context, *ServerStatusRequest) (*ServerStatusResponse, error)
}

ObserverServer is the server API for Observer service. All implementations should embed UnimplementedObserverServer for forward compatibility

type Observer_GetAgentEventsClient

type Observer_GetAgentEventsClient interface {
	Recv() (*GetAgentEventsResponse, error)
	grpc.ClientStream
}

type Observer_GetAgentEventsServer

type Observer_GetAgentEventsServer interface {
	Send(*GetAgentEventsResponse) error
	grpc.ServerStream
}

type Observer_GetDebugEventsClient

type Observer_GetDebugEventsClient interface {
	Recv() (*GetDebugEventsResponse, error)
	grpc.ClientStream
}

type Observer_GetDebugEventsServer

type Observer_GetDebugEventsServer interface {
	Send(*GetDebugEventsResponse) error
	grpc.ServerStream
}

type Observer_GetFlowsClient

type Observer_GetFlowsClient interface {
	Recv() (*GetFlowsResponse, error)
	grpc.ClientStream
}

type Observer_GetFlowsServer

type Observer_GetFlowsServer interface {
	Send(*GetFlowsResponse) error
	grpc.ServerStream
}

type PolicyUpdateNotification

type PolicyUpdateNotification = flow.PolicyUpdateNotification

type ServerStatusRequest

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

func (*ServerStatusRequest) Descriptor deprecated

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

Deprecated: Use ServerStatusRequest.ProtoReflect.Descriptor instead.

func (*ServerStatusRequest) MarshalJSON

func (msg *ServerStatusRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ServerStatusRequest) ProtoMessage

func (*ServerStatusRequest) ProtoMessage()

func (*ServerStatusRequest) ProtoReflect

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

func (*ServerStatusRequest) Reset

func (x *ServerStatusRequest) Reset()

func (*ServerStatusRequest) String

func (x *ServerStatusRequest) String() string

func (*ServerStatusRequest) UnmarshalJSON

func (msg *ServerStatusRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type ServerStatusResponse

type ServerStatusResponse struct {

	// number of currently captured flows
	// In a multi-node context, this is the cumulative count of all captured
	// flows.
	NumFlows uint64 `protobuf:"varint,1,opt,name=num_flows,json=numFlows,proto3" json:"num_flows,omitempty"`
	// maximum capacity of the ring buffer
	// In a multi-node context, this is the aggregation of all ring buffers
	// capacities.
	MaxFlows uint64 `protobuf:"varint,2,opt,name=max_flows,json=maxFlows,proto3" json:"max_flows,omitempty"`
	// total amount of flows observed since the observer was started
	// In a multi-node context, this is the aggregation of all flows that have
	// been seen.
	SeenFlows uint64 `protobuf:"varint,3,opt,name=seen_flows,json=seenFlows,proto3" json:"seen_flows,omitempty"`
	// uptime of this observer instance in nanoseconds
	// In a multi-node context, this field corresponds to the uptime of the
	// longest living instance.
	UptimeNs uint64 `protobuf:"varint,4,opt,name=uptime_ns,json=uptimeNs,proto3" json:"uptime_ns,omitempty"`
	// number of nodes for which a connection is established
	NumConnectedNodes *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=num_connected_nodes,json=numConnectedNodes,proto3" json:"num_connected_nodes,omitempty"`
	// number of nodes for which a connection cannot be established
	NumUnavailableNodes *wrapperspb.UInt32Value `protobuf:"bytes,6,opt,name=num_unavailable_nodes,json=numUnavailableNodes,proto3" json:"num_unavailable_nodes,omitempty"`
	// list of nodes that are unavailable
	// This list may not be exhaustive.
	UnavailableNodes []string `protobuf:"bytes,7,rep,name=unavailable_nodes,json=unavailableNodes,proto3" json:"unavailable_nodes,omitempty"`
	// Version is the version of Cilium/Hubble.
	Version string `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerStatusResponse) Descriptor deprecated

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

Deprecated: Use ServerStatusResponse.ProtoReflect.Descriptor instead.

func (*ServerStatusResponse) GetMaxFlows

func (x *ServerStatusResponse) GetMaxFlows() uint64

func (*ServerStatusResponse) GetNumConnectedNodes

func (x *ServerStatusResponse) GetNumConnectedNodes() *wrapperspb.UInt32Value

func (*ServerStatusResponse) GetNumFlows

func (x *ServerStatusResponse) GetNumFlows() uint64

func (*ServerStatusResponse) GetNumUnavailableNodes

func (x *ServerStatusResponse) GetNumUnavailableNodes() *wrapperspb.UInt32Value

func (*ServerStatusResponse) GetSeenFlows

func (x *ServerStatusResponse) GetSeenFlows() uint64

func (*ServerStatusResponse) GetUnavailableNodes

func (x *ServerStatusResponse) GetUnavailableNodes() []string

func (*ServerStatusResponse) GetUptimeNs

func (x *ServerStatusResponse) GetUptimeNs() uint64

func (*ServerStatusResponse) GetVersion

func (x *ServerStatusResponse) GetVersion() string

func (*ServerStatusResponse) MarshalJSON

func (msg *ServerStatusResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ServerStatusResponse) ProtoMessage

func (*ServerStatusResponse) ProtoMessage()

func (*ServerStatusResponse) ProtoReflect

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

func (*ServerStatusResponse) Reset

func (x *ServerStatusResponse) Reset()

func (*ServerStatusResponse) String

func (x *ServerStatusResponse) String() string

func (*ServerStatusResponse) UnmarshalJSON

func (msg *ServerStatusResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type Service

type Service = flow.Service

type ServiceDeleteNotification

type ServiceDeleteNotification = flow.ServiceDeleteNotification

type ServiceUpsertNotification

type ServiceUpsertNotification = flow.ServiceUpsertNotification

type ServiceUpsertNotificationAddr

type ServiceUpsertNotificationAddr = flow.ServiceUpsertNotificationAddr

type TCP

type TCP = flow.TCP

type TCPFlags

type TCPFlags = flow.TCPFlags

type TLS

type TLS struct {

	// Enabled reports whether TLS is enabled or not.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// ServerName is the TLS server name that can be used as part of the TLS
	// cert validation process.
	ServerName string `protobuf:"bytes,2,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	// contains filtered or unexported fields
}

TLS represents TLS information.

func (*TLS) Descriptor deprecated

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

Deprecated: Use TLS.ProtoReflect.Descriptor instead.

func (*TLS) GetEnabled

func (x *TLS) GetEnabled() bool

func (*TLS) GetServerName

func (x *TLS) GetServerName() string

func (*TLS) MarshalJSON

func (msg *TLS) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*TLS) ProtoMessage

func (*TLS) ProtoMessage()

func (*TLS) ProtoReflect

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

func (*TLS) Reset

func (x *TLS) Reset()

func (*TLS) String

func (x *TLS) String() string

func (*TLS) UnmarshalJSON

func (msg *TLS) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type TimeNotification

type TimeNotification = flow.TimeNotification

type TraceObservationPoint

type TraceObservationPoint = flow.TraceObservationPoint

type TrafficDirection

type TrafficDirection = flow.TrafficDirection

type UDP

type UDP = flow.UDP

type UnimplementedObserverServer

type UnimplementedObserverServer struct {
}

UnimplementedObserverServer should be embedded to have forward compatible implementations.

func (UnimplementedObserverServer) GetAgentEvents

func (UnimplementedObserverServer) GetDebugEvents

func (UnimplementedObserverServer) GetFlows

func (UnimplementedObserverServer) GetNodes

func (UnimplementedObserverServer) ServerStatus

type UnsafeObserverServer

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

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

type Verdict

type Verdict = flow.Verdict

type Workload

type Workload = flow.Workload

Jump to

Keyboard shortcuts

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