observer

package
v1.9.15 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2022 License: Apache-2.0 Imports: 15 Imported by: 29

Documentation

Index

Constants

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_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_DROPPED = flow.Verdict_DROPPED
View Source 
const Verdict_ERROR = flow.Verdict_ERROR
View Source 
const Verdict_FORWARDED = flow.Verdict_FORWARDED
View Source 
const Verdict_VERDICT_UNKNOWN = flow.Verdict_VERDICT_UNKNOWN

Variables

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 CiliumEventType 

type CiliumEventType = flow.CiliumEventType

type DNS 

type DNS = flow.DNS

type DropReason 

type DropReason = flow.DropReason

type Endpoint 

type Endpoint = flow.Endpoint

type Ethernet 

type Ethernet = flow.Ethernet

type EventType 

type EventType = flow.EventType

type EventTypeFilter 

type EventTypeFilter = flow.EventTypeFilter

type Flow 

type Flow = flow.Flow

type FlowFilter 

type FlowFilter = flow.FlowFilter

type FlowType 

type FlowType = flow.FlowType

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 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 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 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)
	// 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
	// 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_GetFlowsClient 

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

type Observer_GetFlowsServer 

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

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"`
	// 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) 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 TCP 

type TCP = flow.TCP

type TCPFlags 

type TCPFlags = flow.TCPFlags

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

func (*UnimplementedObserverServer) GetFlows(*GetFlowsRequest, Observer_GetFlowsServer) 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.