observer

package
v1.16.0-pre.3 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2024 License: Apache-2.0 Imports: 15 Imported by: 28

README

Protocol Documentation

Table of Contents

Top

observer/observer.proto

ExportEvent

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

Field Type Label Description
flow flow.Flow
node_status relay.NodeStatusEvent node_status informs clients about the state of the nodes participating in this particular GetFlows request.
lost_events flow.LostEvent lost_events informs clients about events which got dropped due to a Hubble component being unavailable
agent_event flow.AgentEvent agent_event informs clients about an event received from the Cilium agent.
debug_event flow.DebugEvent debug_event contains Cilium datapath debug events
node_name string Name of the node where this event was observed.
time google.protobuf.Timestamp Timestamp at which this event was observed.

GetAgentEventsRequest
Field Type Label Description
number uint64 Number of flows that should be returned. Incompatible with since/until. Defaults to the most recent (last) number events, unless first is true, then it will return the earliest number events.
first bool first specifies if we should look at the first number events or the last number of events. Incompatible with follow.
follow bool follow sets when the server should continue to stream agent events after printing the last N agent events.
since google.protobuf.Timestamp Since this time for returned agent events. Incompatible with number.
until google.protobuf.Timestamp Until this time for returned agent events. Incompatible with number.

GetAgentEventsResponse

GetAgentEventsResponse contains an event received from the Cilium agent.

Field Type Label Description
agent_event flow.AgentEvent
node_name string Name of the node where this event was observed.
time google.protobuf.Timestamp Timestamp at which this event was observed.

GetDebugEventsRequest
Field Type Label Description
number uint64 Number of events that should be returned. Incompatible with since/until. Defaults to the most recent (last) number events, unless first is true, then it will return the earliest number events.
first bool first specifies if we should look at the first number events or the last number of events. Incompatible with follow.
follow bool follow sets when the server should continue to stream debug events after printing the last N debug events.
since google.protobuf.Timestamp Since this time for returned debug events. Incompatible with number.
until google.protobuf.Timestamp Until this time for returned debug events. Incompatible with number.

GetDebugEventsResponse

GetDebugEventsResponse contains a Cilium datapath debug events.

Field Type Label Description
debug_event flow.DebugEvent
node_name string Name of the node where this event was observed.
time google.protobuf.Timestamp Timestamp at which this event was observed.

GetFlowsRequest
Field Type Label Description
number uint64 Number of flows that should be returned. Incompatible with since/until. Defaults to the most recent (last) number flows, unless first is true, then it will return the earliest number flows.
first bool first specifies if we should look at the first number flows or the last number of flows. Incompatible with follow.
follow bool follow sets when the server should continue to stream flows after printing the last N flows.
blacklist flow.FlowFilter repeated 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.
whitelist flow.FlowFilter repeated 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.
since google.protobuf.Timestamp Since this time for returned flows. Incompatible with number.
until google.protobuf.Timestamp Until this time for returned flows. Incompatible with number.
field_mask google.protobuf.FieldMask FieldMask allows clients to limit flow's fields that will be returned. For example, {paths: ["source.id", "destination.id"]} will return flows with only these two fields set.
experimental GetFlowsRequest.Experimental
extensions google.protobuf.Any extensions can be used to add arbitrary additional metadata to GetFlowsRequest. This can be used to extend functionality for other Hubble compatible APIs, or experiment with new functionality without needing to change the public API.

GetFlowsRequest.Experimental

Experimental contains fields that are not stable yet. Support for experimental features is always optional and subject to change.

Field Type Label Description
field_mask google.protobuf.FieldMask Deprecated. FieldMask allows clients to limit flow's fields that will be returned. For example, {paths: ["source.id", "destination.id"]} will return flows with only these two fields set. Deprecated in favor of top-level field_mask. This field will be removed in v1.17.

GetFlowsResponse

GetFlowsResponse contains either a flow or a protocol message.

Field Type Label Description
flow flow.Flow
node_status relay.NodeStatusEvent node_status informs clients about the state of the nodes participating in this particular GetFlows request.
lost_events flow.LostEvent lost_events informs clients about events which got dropped due to a Hubble component being unavailable
node_name string Name of the node where this event was observed.
time google.protobuf.Timestamp Timestamp at which this event was observed.

GetNamespacesRequest

GetNamespacesResponse

GetNamespacesResponse contains the list of namespaces.

Field Type Label Description
namespaces Namespace repeated Namespaces is a list of namespaces with flows

GetNodesRequest

GetNodesResponse

GetNodesResponse contains the list of nodes.

Field Type Label Description
nodes Node repeated Nodes is an exhaustive list of nodes.

Namespace
Field Type Label Description
cluster string
namespace string

Node

Node represents a cluster node.

Field Type Label Description
name string Name is the name of the node.
version string Version is the version of Cilium/Hubble as reported by the node.
address string Address is the network address of the API endpoint.
state relay.NodeState State represents the known state of the node.
tls TLS TLS reports TLS related information.
uptime_ns uint64 UptimeNS is the uptime of this instance in nanoseconds
num_flows uint64 number of currently captured flows
max_flows uint64 maximum capacity of the ring buffer
seen_flows uint64 total amount of flows observed since the observer was started

ServerStatusRequest

ServerStatusResponse
Field Type Label Description
num_flows uint64 number of currently captured flows In a multi-node context, this is the cumulative count of all captured flows.
max_flows uint64 maximum capacity of the ring buffer In a multi-node context, this is the aggregation of all ring buffers capacities.
seen_flows uint64 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.
uptime_ns uint64 uptime of this observer instance in nanoseconds In a multi-node context, this field corresponds to the uptime of the longest living instance.
num_connected_nodes google.protobuf.UInt32Value number of nodes for which a connection is established
num_unavailable_nodes google.protobuf.UInt32Value number of nodes for which a connection cannot be established
unavailable_nodes string repeated list of nodes that are unavailable This list may not be exhaustive.
version string Version is the version of Cilium/Hubble.
flows_rate double Approximate rate of flows seen by Hubble per second over the last minute. In a multi-node context, this is the sum of all flows rates.

TLS

TLS represents TLS information.

Field Type Label Description
enabled bool Enabled reports whether TLS is enabled or not.
server_name string ServerName is the TLS server name that can be used as part of the TLS cert validation process.

Observer

Observer returns a stream of Flows depending on which filter the user want to observe.

Method Name Request Type Response Type Description
GetFlows GetFlowsRequest GetFlowsResponse stream GetFlows returning structured data, meant to eventually obsolete GetLastNFlows.
GetAgentEvents GetAgentEventsRequest GetAgentEventsResponse stream GetAgentEvents returns Cilium agent events.
GetDebugEvents GetDebugEventsRequest GetDebugEventsResponse stream GetDebugEvents returns Cilium datapath debug events.
GetNodes GetNodesRequest GetNodesResponse GetNodes returns information about nodes in a cluster.
GetNamespaces GetNamespacesRequest GetNamespacesResponse GetNamespaces returns information about namespaces in a cluster. The namespaces returned are namespaces which have had network flows in the last hour. The namespaces are returned sorted by cluster name and namespace in ascending order.
ServerStatus ServerStatusRequest ServerStatusResponse ServerStatus returns some details about the running hubble server.

Scalar Value Types

.proto Type Notes C++ Java Python Go C# PHP Ruby
double double double float float64 double float Float
float float float float float32 float float Float
int32 Uses variable-length encoding. Inefficient for encoding negative numbers – if your field is likely to have negative values, use sint32 instead. int32 int int int32 int integer Bignum or Fixnum (as required)
int64 Uses variable-length encoding. Inefficient for encoding negative numbers – if your field is likely to have negative values, use sint64 instead. int64 long int/long int64 long integer/string Bignum
uint32 Uses variable-length encoding. uint32 int int/long uint32 uint integer Bignum or Fixnum (as required)
uint64 Uses variable-length encoding. uint64 long int/long uint64 ulong integer/string Bignum or Fixnum (as required)
sint32 Uses variable-length encoding. Signed int value. These more efficiently encode negative numbers than regular int32s. int32 int int int32 int integer Bignum or Fixnum (as required)
sint64 Uses variable-length encoding. Signed int value. These more efficiently encode negative numbers than regular int64s. int64 long int/long int64 long integer/string Bignum
fixed32 Always four bytes. More efficient than uint32 if values are often greater than 2^28. uint32 int int uint32 uint integer Bignum or Fixnum (as required)
fixed64 Always eight bytes. More efficient than uint64 if values are often greater than 2^56. uint64 long int/long uint64 ulong integer/string Bignum
sfixed32 Always four bytes. int32 int int int32 int integer Bignum or Fixnum (as required)
sfixed64 Always eight bytes. int64 long int/long int64 long integer/string Bignum
bool bool boolean boolean bool bool boolean TrueClass/FalseClass
string A string must always contain UTF-8 encoded or 7-bit ASCII text. string String str/unicode string string string String (UTF-8)
bytes May contain any arbitrary sequence of bytes. string ByteString str []byte ByteString string String (ASCII-8BIT)

Documentation

Index

Constants

View Source 
const (
	Observer_GetFlows_FullMethodName       = "/observer.Observer/GetFlows"
	Observer_GetAgentEvents_FullMethodName = "/observer.Observer/GetAgentEvents"
	Observer_GetDebugEvents_FullMethodName = "/observer.Observer/GetDebugEvents"
	Observer_GetNodes_FullMethodName       = "/observer.Observer/GetNodes"
	Observer_GetNamespaces_FullMethodName  = "/observer.Observer/GetNamespaces"
	Observer_ServerStatus_FullMethodName   = "/observer.Observer/ServerStatus"
)
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 AuthType_DISABLED = flow.AuthType_DISABLED
View Source 
const AuthType_SPIRE = flow.AuthType_SPIRE
View Source 
const AuthType_TEST_ALWAYS_FAIL = flow.AuthType_TEST_ALWAYS_FAIL
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_L7_LB = flow.DebugEventType_DBG_L7_LB
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_POLICY = flow.DebugEventType_DBG_SKIP_POLICY
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_AUTH_REQUIRED = flow.DropReason_AUTH_REQUIRED
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_NO_MAP_FOUND = flow.DropReason_CT_NO_MAP_FOUND
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_EP_NOT_READY = flow.DropReason_DROP_EP_NOT_READY
View Source 
const DropReason_DROP_HOST_NOT_READY = flow.DropReason_DROP_HOST_NOT_READY
View Source 
const DropReason_DROP_RATE_LIMITED = flow.DropReason_DROP_RATE_LIMITED
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_IGMP_HANDLED = flow.DropReason_IGMP_HANDLED
View Source 
const DropReason_IGMP_SUBSCRIBED = flow.DropReason_IGMP_SUBSCRIBED
View Source 
const DropReason_INVALID_CLUSTER_ID = flow.DropReason_INVALID_CLUSTER_ID
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_INVALID_TC_BUFFER = flow.DropReason_INVALID_TC_BUFFER
View Source 
const DropReason_INVALID_VNI = flow.DropReason_INVALID_VNI
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_MISSING_SRV6_STATE = flow.DropReason_MISSING_SRV6_STATE
View Source 
const DropReason_MULTICAST_HANDLED = flow.DropReason_MULTICAST_HANDLED
View Source 
const DropReason_NAT46 = flow.DropReason_NAT46
View Source 
const DropReason_NAT64 = flow.DropReason_NAT64
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_EGRESS_GATEWAY = flow.DropReason_NO_EGRESS_GATEWAY
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_NODE_ID = flow.DropReason_NO_NODE_ID
View Source 
const DropReason_NO_SID = flow.DropReason_NO_SID
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_POLICY_DENY = flow.DropReason_POLICY_DENY
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_SNAT_NO_MAP_FOUND = flow.DropReason_SNAT_NO_MAP_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_TTL_EXCEEDED = flow.DropReason_TTL_EXCEEDED
View Source 
const DropReason_UNENCRYPTED_TRAFFIC = flow.DropReason_UNENCRYPTED_TRAFFIC
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_DSR_ENCAP = flow.DropReason_UNSUPPORTED_PROTOCOL_FOR_DSR_ENCAP
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_SOCK = flow.FlowType_SOCK
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 SocketTranslationPoint_SOCK_XLATE_POINT_POST_DIRECTION_FWD = flow.SocketTranslationPoint_SOCK_XLATE_POINT_POST_DIRECTION_FWD
View Source 
const SocketTranslationPoint_SOCK_XLATE_POINT_POST_DIRECTION_REV = flow.SocketTranslationPoint_SOCK_XLATE_POINT_POST_DIRECTION_REV
View Source 
const SocketTranslationPoint_SOCK_XLATE_POINT_PRE_DIRECTION_FWD = flow.SocketTranslationPoint_SOCK_XLATE_POINT_PRE_DIRECTION_FWD
View Source 
const SocketTranslationPoint_SOCK_XLATE_POINT_PRE_DIRECTION_REV = flow.SocketTranslationPoint_SOCK_XLATE_POINT_PRE_DIRECTION_REV
View Source 
const SocketTranslationPoint_SOCK_XLATE_POINT_UNKNOWN = flow.SocketTranslationPoint_SOCK_XLATE_POINT_UNKNOWN
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 TraceReason_ENCRYPT_OVERLAY = flow.TraceReason_ENCRYPT_OVERLAY
View Source 
const TraceReason_ESTABLISHED = flow.TraceReason_ESTABLISHED
View Source 
const TraceReason_NEW = flow.TraceReason_NEW
View Source 
const TraceReason_RELATED = flow.TraceReason_RELATED
View Source 
const TraceReason_REOPENED = flow.TraceReason_REOPENED
View Source 
const TraceReason_REPLY = flow.TraceReason_REPLY
View Source 
const TraceReason_SRV6_DECAP = flow.TraceReason_SRV6_DECAP
View Source 
const TraceReason_SRV6_ENCAP = flow.TraceReason_SRV6_ENCAP
View Source 
const TraceReason_TRACE_REASON_UNKNOWN = flow.TraceReason_TRACE_REASON_UNKNOWN
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_TRACED = flow.Verdict_TRACED
View Source 
const Verdict_TRANSLATED = flow.Verdict_TRANSLATED
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 AuthType_name = flow.AuthType_name
View Source 
var AuthType_value = flow.AuthType_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: "GetNamespaces",
			Handler:    _Observer_GetNamespaces_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 SocketTranslationPoint_name = flow.SocketTranslationPoint_name
View Source 
var SocketTranslationPoint_value = flow.SocketTranslationPoint_value
View Source 
var TraceObservationPoint_name = flow.TraceObservationPoint_name
View Source 
var TraceObservationPoint_value = flow.TraceObservationPoint_value
View Source 
var TraceReason_name = flow.TraceReason_name
View Source 
var TraceReason_value = flow.TraceReason_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 AuthType 

type AuthType = flow.AuthType

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 FlowFilter_Experimental added in v1.16.0 

type FlowFilter_Experimental = flow.FlowFilter_Experimental

type FlowType 

type FlowType = flow.FlowType

type GetAgentEventsRequest 

type GetAgentEventsRequest struct {

	// Number of flows that should be returned. Incompatible with `since/until`.
	// Defaults to the most recent (last) `number` events, unless `first` is
	// true, then it will return the earliest `number` events.
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// first specifies if we should look at the first `number` events or the
	// last `number` of events. Incompatible with `follow`.
	First bool `protobuf:"varint,9,opt,name=first,proto3" json:"first,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) GetFirst 

func (x *GetAgentEventsRequest) GetFirst() bool

func (*GetAgentEventsRequest) GetFollow 

func (x *GetAgentEventsRequest) GetFollow() bool

func (*GetAgentEventsRequest) GetNumber 

func (x *GetAgentEventsRequest) GetNumber() uint64

func (*GetAgentEventsRequest) GetSince 

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

func (*GetAgentEventsRequest) GetUntil 

func (x *GetAgentEventsRequest) GetUntil() *timestamppb.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 *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 (x *GetAgentEventsResponse) GetTime() *timestamppb.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 events that should be returned. Incompatible with `since/until`.
	// Defaults to the most recent (last) `number` events, unless `first` is
	// true, then it will return the earliest `number` events.
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// first specifies if we should look at the first `number` events or the
	// last `number` of events. Incompatible with `follow`.
	First bool `protobuf:"varint,9,opt,name=first,proto3" json:"first,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) GetFirst 

func (x *GetDebugEventsRequest) GetFirst() bool

func (*GetDebugEventsRequest) GetFollow 

func (x *GetDebugEventsRequest) GetFollow() bool

func (*GetDebugEventsRequest) GetNumber 

func (x *GetDebugEventsRequest) GetNumber() uint64

func (*GetDebugEventsRequest) GetSince 

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

func (*GetDebugEventsRequest) GetUntil 

func (x *GetDebugEventsRequest) GetUntil() *timestamppb.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 *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 (x *GetDebugEventsResponse) GetTime() *timestamppb.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`.
	// Defaults to the most recent (last) `number` flows, unless `first` is
	// true, then it will return the earliest `number` flows.
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// first specifies if we should look at the first `number` flows or the
	// last `number` of flows. Incompatible with `follow`.
	First bool `protobuf:"varint,9,opt,name=first,proto3" json:"first,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"`
	// FieldMask allows clients to limit flow's fields that will be returned.
	// For example, {paths: ["source.id", "destination.id"]} will return flows
	// with only these two fields set.
	FieldMask    *fieldmaskpb.FieldMask        `protobuf:"bytes,10,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"`
	Experimental *GetFlowsRequest_Experimental `protobuf:"bytes,999,opt,name=experimental,proto3" json:"experimental,omitempty"`
	// extensions can be used to add arbitrary additional metadata to GetFlowsRequest.
	// This can be used to extend functionality for other Hubble compatible
	// APIs, or experiment with new functionality without needing to change the public API.
	Extensions *anypb.Any `protobuf:"bytes,150000,opt,name=extensions,proto3" json:"extensions,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) GetExperimental 

func (x *GetFlowsRequest) GetExperimental() *GetFlowsRequest_Experimental

func (*GetFlowsRequest) GetExtensions 

func (x *GetFlowsRequest) GetExtensions() *anypb.Any

func (*GetFlowsRequest) GetFieldMask added in v1.16.0 

func (x *GetFlowsRequest) GetFieldMask() *fieldmaskpb.FieldMask

func (*GetFlowsRequest) GetFirst 

func (x *GetFlowsRequest) GetFirst() bool

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 GetFlowsRequest_Experimental 

type GetFlowsRequest_Experimental struct {

	// FieldMask allows clients to limit flow's fields that will be returned.
	// For example, {paths: ["source.id", "destination.id"]} will return flows
	// with only these two fields set.
	// Deprecated in favor of top-level field_mask. This field will be
	// removed in v1.17.
	//
	// Deprecated: Marked as deprecated in observer/observer.proto.
	FieldMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"`
	// contains filtered or unexported fields
}

Experimental contains fields that are not stable yet. Support for experimental features is always optional and subject to change.

func (*GetFlowsRequest_Experimental) Descriptor deprecated 

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

Deprecated: Use GetFlowsRequest_Experimental.ProtoReflect.Descriptor instead.

func (*GetFlowsRequest_Experimental) GetFieldMask deprecated 

func (x *GetFlowsRequest_Experimental) GetFieldMask() *fieldmaskpb.FieldMask

Deprecated: Marked as deprecated in observer/observer.proto.

func (*GetFlowsRequest_Experimental) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*GetFlowsRequest_Experimental) ProtoMessage 

func (*GetFlowsRequest_Experimental) ProtoMessage()

func (*GetFlowsRequest_Experimental) ProtoReflect 

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

func (*GetFlowsRequest_Experimental) Reset 

func (x *GetFlowsRequest_Experimental) Reset()

func (*GetFlowsRequest_Experimental) String 

func (x *GetFlowsRequest_Experimental) String() string

func (*GetFlowsRequest_Experimental) UnmarshalJSON 

func (msg *GetFlowsRequest_Experimental) 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 GetNamespacesRequest 

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

func (*GetNamespacesRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespacesRequest.ProtoReflect.Descriptor instead.

func (*GetNamespacesRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*GetNamespacesRequest) ProtoMessage 

func (*GetNamespacesRequest) ProtoMessage()

func (*GetNamespacesRequest) ProtoReflect 

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

func (*GetNamespacesRequest) Reset 

func (x *GetNamespacesRequest) Reset()

func (*GetNamespacesRequest) String 

func (x *GetNamespacesRequest) String() string

func (*GetNamespacesRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

type GetNamespacesResponse 

type GetNamespacesResponse struct {

	// Namespaces is a list of namespaces with flows
	Namespaces []*Namespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

GetNamespacesResponse contains the list of namespaces.

func (*GetNamespacesResponse) Descriptor deprecated 

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

Deprecated: Use GetNamespacesResponse.ProtoReflect.Descriptor instead.

func (*GetNamespacesResponse) GetNamespaces 

func (x *GetNamespacesResponse) GetNamespaces() []*Namespace

func (*GetNamespacesResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*GetNamespacesResponse) ProtoMessage 

func (*GetNamespacesResponse) ProtoMessage()

func (*GetNamespacesResponse) ProtoReflect 

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

func (*GetNamespacesResponse) Reset 

func (x *GetNamespacesResponse) Reset()

func (*GetNamespacesResponse) String 

func (x *GetNamespacesResponse) String() string

func (*GetNamespacesResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

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_SCTP 

type Layer4_SCTP = flow.Layer4_SCTP

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 Namespace 

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

func (*Namespace) Descriptor deprecated 

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

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetCluster 

func (x *Namespace) GetCluster() string

func (*Namespace) GetNamespace 

func (x *Namespace) GetNamespace() string

func (*Namespace) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect 

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

func (*Namespace) Reset 

func (x *Namespace) Reset()

func (*Namespace) String 

func (x *Namespace) String() string

func (*Namespace) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

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)
	// GetNamespaces returns information about namespaces in a cluster.
	// The namespaces returned are namespaces which have had network flows in
	// the last hour. The namespaces are returned sorted by cluster name and
	// namespace in ascending order.
	GetNamespaces(ctx context.Context, in *GetNamespacesRequest, opts ...grpc.CallOption) (*GetNamespacesResponse, 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.

Observer returns a stream of Flows depending on which filter the user want to observe.

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)
	// GetNamespaces returns information about namespaces in a cluster.
	// The namespaces returned are namespaces which have had network flows in
	// the last hour. The namespaces are returned sorted by cluster name and
	// namespace in ascending order.
	GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, 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

Observer returns a stream of Flows depending on which filter the user want to observe.

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 Policy added in v1.15.0 

type Policy = flow.Policy

type PolicyUpdateNotification 

type PolicyUpdateNotification = flow.PolicyUpdateNotification

type SCTP 

type SCTP = flow.SCTP

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"`
	// Approximate rate of flows seen by Hubble per second over the last minute.
	// In a multi-node context, this is the sum of all flows rates.
	FlowsRate float64 `protobuf:"fixed64,9,opt,name=flows_rate,json=flowsRate,proto3" json:"flows_rate,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerStatusResponse) Descriptor deprecated 

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

Deprecated: Use ServerStatusResponse.ProtoReflect.Descriptor instead.

func (*ServerStatusResponse) GetFlowsRate added in v1.15.0 

func (x *ServerStatusResponse) GetFlowsRate() float64

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 SocketTranslationPoint 

type SocketTranslationPoint = flow.SocketTranslationPoint

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 TraceContext 

type TraceContext = flow.TraceContext

type TraceObservationPoint 

type TraceObservationPoint = flow.TraceObservationPoint

type TraceParent 

type TraceParent = flow.TraceParent

type TraceReason added in v1.16.0 

type TraceReason = flow.TraceReason

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) GetNamespaces 

func (UnimplementedObserverServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)

func (UnimplementedObserverServer) GetNodes 

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

func (UnimplementedObserverServer) ServerStatus 

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

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

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.