observer

package
v1.10.7 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2022 License: Apache-2.0 Imports: 15 Imported by: 33

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 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 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.Server, 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 *timestamp.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() *timestamp.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 *timestamp.Timestamp `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"`
	// Until this time for returned agent events. Incompatible with `number`.
	Until *timestamp.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 (x *GetAgentEventsRequest) GetSince() *timestamp.Timestamp

func (*GetAgentEventsRequest) GetUntil 

func (x *GetAgentEventsRequest) GetUntil() *timestamp.Timestamp

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 *timestamp.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 (x *GetAgentEventsResponse) GetTime() *timestamp.Timestamp

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 *timestamp.Timestamp `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"`
	// Until this time for returned debug events. Incompatible with `number`.
	Until *timestamp.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 (x *GetDebugEventsRequest) GetSince() *timestamp.Timestamp

func (*GetDebugEventsRequest) GetUntil 

func (x *GetDebugEventsRequest) GetUntil() *timestamp.Timestamp

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 *timestamp.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 (x *GetDebugEventsResponse) GetTime() *timestamp.Timestamp

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 *timestamp.Timestamp `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"`
	// Until this time for returned flows. Incompatible with `number`.
	Until *timestamp.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() *timestamp.Timestamp

func (*GetFlowsRequest) GetUntil 

func (x *GetFlowsRequest) GetUntil() *timestamp.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 *timestamp.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() *timestamp.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 *wrappers.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 *wrappers.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() *wrappers.UInt32Value

func (*ServerStatusResponse) GetNumFlows 

func (x *ServerStatusResponse) GetNumFlows() uint64

func (*ServerStatusResponse) GetNumUnavailableNodes 

func (x *ServerStatusResponse) GetNumUnavailableNodes() *wrappers.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) GetAgentEvents(*GetAgentEventsRequest, Observer_GetAgentEventsServer) error

func (*UnimplementedObserverServer) GetDebugEvents 

func (*UnimplementedObserverServer) GetDebugEvents(*GetDebugEventsRequest, Observer_GetDebugEventsServer) error

func (*UnimplementedObserverServer) GetFlows 

func (*UnimplementedObserverServer) GetFlows(*GetFlowsRequest, Observer_GetFlowsServer) error

func (*UnimplementedObserverServer) GetNodes 

func (*UnimplementedObserverServer) GetNodes(context.Context, *GetNodesRequest) (*GetNodesResponse, error)

func (*UnimplementedObserverServer) ServerStatus 

func (*UnimplementedObserverServer) ServerStatus(context.Context, *ServerStatusRequest) (*ServerStatusResponse, error)

type Verdict 

type Verdict = flow.Verdict

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.