observer

package
v1.8.12 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2021 License: Apache-2.0 Imports: 22 Imported by: 29

Documentation

Index

Constants

View Source 
const EventType_EventSample = EventType(flow.EventType_EventSample)
View Source 
const EventType_RecordLost = EventType(flow.EventType_RecordLost)
View Source 
const EventType_UNKNOWN = EventType(flow.EventType_UNKNOWN)
View Source 
const FlowType_L3_L4 = FlowType(flow.FlowType_L3_L4)
View Source 
const FlowType_L7 = FlowType(flow.FlowType_L7)
View Source 
const FlowType_UNKNOWN_TYPE = FlowType(flow.FlowType_UNKNOWN_TYPE)
View Source 
const IPVersion_IP_NOT_USED = IPVersion(flow.IPVersion_IP_NOT_USED)
View Source 
const IPVersion_IPv4 = IPVersion(flow.IPVersion_IPv4)
View Source 
const IPVersion_IPv6 = IPVersion(flow.IPVersion_IPv6)
View Source 
const L7FlowType_REQUEST = L7FlowType(flow.L7FlowType_REQUEST)
View Source 
const L7FlowType_RESPONSE = L7FlowType(flow.L7FlowType_RESPONSE)
View Source 
const L7FlowType_SAMPLE = L7FlowType(flow.L7FlowType_SAMPLE)
View Source 
const L7FlowType_UNKNOWN_L7_TYPE = L7FlowType(flow.L7FlowType_UNKNOWN_L7_TYPE)
View Source 
const TraceObservationPoint_FROM_ENDPOINT = TraceObservationPoint(flow.TraceObservationPoint_FROM_ENDPOINT)
View Source 
const TraceObservationPoint_FROM_HOST = TraceObservationPoint(flow.TraceObservationPoint_FROM_HOST)
View Source 
const TraceObservationPoint_FROM_NETWORK = TraceObservationPoint(flow.TraceObservationPoint_FROM_NETWORK)
View Source 
const TraceObservationPoint_FROM_OVERLAY = TraceObservationPoint(flow.TraceObservationPoint_FROM_OVERLAY)
View Source 
const TraceObservationPoint_FROM_PROXY = TraceObservationPoint(flow.TraceObservationPoint_FROM_PROXY)
View Source 
const TraceObservationPoint_FROM_STACK = TraceObservationPoint(flow.TraceObservationPoint_FROM_STACK)
View Source 
const TraceObservationPoint_TO_ENDPOINT = TraceObservationPoint(flow.TraceObservationPoint_TO_ENDPOINT)
View Source 
const TraceObservationPoint_TO_HOST = TraceObservationPoint(flow.TraceObservationPoint_TO_HOST)
View Source 
const TraceObservationPoint_TO_NETWORK = TraceObservationPoint(flow.TraceObservationPoint_TO_NETWORK)
View Source 
const TraceObservationPoint_TO_OVERLAY = TraceObservationPoint(flow.TraceObservationPoint_TO_OVERLAY)
View Source 
const TraceObservationPoint_TO_PROXY = TraceObservationPoint(flow.TraceObservationPoint_TO_PROXY)
View Source 
const TraceObservationPoint_TO_STACK = TraceObservationPoint(flow.TraceObservationPoint_TO_STACK)
View Source 
const TraceObservationPoint_UNKNOWN_POINT = TraceObservationPoint(flow.TraceObservationPoint_UNKNOWN_POINT)
View Source 
const TrafficDirection_EGRESS = TrafficDirection(flow.TrafficDirection_EGRESS)
View Source 
const TrafficDirection_INGRESS = TrafficDirection(flow.TrafficDirection_INGRESS)
View Source 
const TrafficDirection_TRAFFIC_DIRECTION_UNKNOWN = TrafficDirection(flow.TrafficDirection_TRAFFIC_DIRECTION_UNKNOWN)
View Source 
const Verdict_DROPPED = Verdict(flow.Verdict_DROPPED)
View Source 
const Verdict_ERROR = Verdict(flow.Verdict_ERROR)
View Source 
const Verdict_FORWARDED = Verdict(flow.Verdict_FORWARDED)
View Source 
const Verdict_VERDICT_UNKNOWN = Verdict(flow.Verdict_VERDICT_UNKNOWN)

Variables

View Source 
var EventType_name = flow.EventType_name
View Source 
var EventType_value = flow.EventType_value
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 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

CiliumEventType from public import flow/flow.proto

type DNS 

type DNS = flow.DNS

DNS from public import flow/flow.proto

type Endpoint 

type Endpoint = flow.Endpoint

Endpoint from public import flow/flow.proto

type Ethernet 

type Ethernet = flow.Ethernet

Ethernet from public import flow/flow.proto

type EventType 

type EventType = flow.EventType

EventType from public import flow/flow.proto

type EventTypeFilter 

type EventTypeFilter = flow.EventTypeFilter

EventTypeFilter from public import flow/flow.proto

type Flow 

type Flow = flow.Flow

Flow from public import flow/flow.proto

type FlowFilter 

type FlowFilter = flow.FlowFilter

FlowFilter from public import flow/flow.proto

type FlowType 

type FlowType = flow.FlowType

FlowType from public import flow/flow.proto

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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*GetFlowsRequest) Descriptor 

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

func (*GetFlowsRequest) GetBlacklist 

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

func (*GetFlowsRequest) GetFollow 

func (m *GetFlowsRequest) GetFollow() bool

func (*GetFlowsRequest) GetNumber 

func (m *GetFlowsRequest) GetNumber() uint64

func (*GetFlowsRequest) GetSince 

func (m *GetFlowsRequest) GetSince() *timestamp.Timestamp

func (*GetFlowsRequest) GetUntil 

func (m *GetFlowsRequest) GetUntil() *timestamp.Timestamp

func (*GetFlowsRequest) GetWhitelist 

func (m *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) Reset 

func (m *GetFlowsRequest) Reset()

func (*GetFlowsRequest) String 

func (m *GetFlowsRequest) String() string

func (*GetFlowsRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*GetFlowsRequest) Validate added in v1.8.0 

func (m *GetFlowsRequest) Validate() error

Validate checks the field values on GetFlowsRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*GetFlowsRequest) XXX_DiscardUnknown added in v1.8.0 

func (m *GetFlowsRequest) XXX_DiscardUnknown()

func (*GetFlowsRequest) XXX_Marshal added in v1.8.0 

func (m *GetFlowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFlowsRequest) XXX_Merge added in v1.8.0 

func (m *GetFlowsRequest) XXX_Merge(src proto.Message)

func (*GetFlowsRequest) XXX_Size added in v1.8.0 

func (m *GetFlowsRequest) XXX_Size() int

func (*GetFlowsRequest) XXX_Unmarshal added in v1.8.0 

func (m *GetFlowsRequest) XXX_Unmarshal(b []byte) error

type GetFlowsRequestValidationError added in v1.8.0 

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

GetFlowsRequestValidationError is the validation error returned by GetFlowsRequest.Validate if the designated constraints aren't met.

func (GetFlowsRequestValidationError) Cause added in v1.8.0 

func (e GetFlowsRequestValidationError) Cause() error

Cause function returns cause value.

func (GetFlowsRequestValidationError) Error added in v1.8.0 

func (e GetFlowsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetFlowsRequestValidationError) ErrorName added in v1.8.0 

func (e GetFlowsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetFlowsRequestValidationError) Field added in v1.8.0 

func (e GetFlowsRequestValidationError) Field() string

Field function returns field value.

func (GetFlowsRequestValidationError) Key added in v1.8.0 

func (e GetFlowsRequestValidationError) Key() bool

Key function returns key value.

func (GetFlowsRequestValidationError) Reason added in v1.8.0 

func (e GetFlowsRequestValidationError) Reason() string

Reason function returns reason value.

type GetFlowsResponse 

type GetFlowsResponse struct {
	// Types that are valid to be assigned to ResponseTypes:
	//	*GetFlowsResponse_Flow
	//	*GetFlowsResponse_NodeStatus
	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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

GetFlowsResponse contains either a flow or a protocol message.

func (*GetFlowsResponse) Descriptor 

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

func (*GetFlowsResponse) GetFlow 

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

func (*GetFlowsResponse) GetNodeName 

func (m *GetFlowsResponse) GetNodeName() string

func (*GetFlowsResponse) GetNodeStatus 

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

func (*GetFlowsResponse) GetResponseTypes 

func (m *GetFlowsResponse) GetResponseTypes() isGetFlowsResponse_ResponseTypes

func (*GetFlowsResponse) GetTime 

func (m *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) Reset 

func (m *GetFlowsResponse) Reset()

func (*GetFlowsResponse) String 

func (m *GetFlowsResponse) String() string

func (*GetFlowsResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*GetFlowsResponse) Validate added in v1.8.0 

func (m *GetFlowsResponse) Validate() error

Validate checks the field values on GetFlowsResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*GetFlowsResponse) XXX_DiscardUnknown added in v1.8.0 

func (m *GetFlowsResponse) XXX_DiscardUnknown()

func (*GetFlowsResponse) XXX_Marshal added in v1.8.0 

func (m *GetFlowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFlowsResponse) XXX_Merge added in v1.8.0 

func (m *GetFlowsResponse) XXX_Merge(src proto.Message)

func (*GetFlowsResponse) XXX_OneofWrappers added in v1.8.0 

func (*GetFlowsResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetFlowsResponse) XXX_Size added in v1.8.0 

func (m *GetFlowsResponse) XXX_Size() int

func (*GetFlowsResponse) XXX_Unmarshal added in v1.8.0 

func (m *GetFlowsResponse) XXX_Unmarshal(b []byte) error

type GetFlowsResponseValidationError added in v1.8.0 

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

GetFlowsResponseValidationError is the validation error returned by GetFlowsResponse.Validate if the designated constraints aren't met.

func (GetFlowsResponseValidationError) Cause added in v1.8.0 

func (e GetFlowsResponseValidationError) Cause() error

Cause function returns cause value.

func (GetFlowsResponseValidationError) Error added in v1.8.0 

func (e GetFlowsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetFlowsResponseValidationError) ErrorName added in v1.8.0 

func (e GetFlowsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetFlowsResponseValidationError) Field added in v1.8.0 

func (e GetFlowsResponseValidationError) Field() string

Field function returns field value.

func (GetFlowsResponseValidationError) Key added in v1.8.0 

func (e GetFlowsResponseValidationError) Key() bool

Key function returns key value.

func (GetFlowsResponseValidationError) Reason added in v1.8.0 

func (e GetFlowsResponseValidationError) Reason() string

Reason function returns reason value.

type GetFlowsResponse_Flow 

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

type GetFlowsResponse_NodeStatus 

type GetFlowsResponse_NodeStatus struct {
	NodeStatus *relay.NodeStatusEvent `protobuf:"bytes,2,opt,name=node_status,json=nodeStatus,proto3,oneof"`
}

type HTTP 

type HTTP = flow.HTTP

HTTP from public import flow/flow.proto

type HTTPHeader 

type HTTPHeader = flow.HTTPHeader

HTTPHeader from public import flow/flow.proto

type ICMPv4 

type ICMPv4 = flow.ICMPv4

ICMPv4 from public import flow/flow.proto

type ICMPv6 

type ICMPv6 = flow.ICMPv6

ICMPv6 from public import flow/flow.proto

type IP 

type IP = flow.IP

IP from public import flow/flow.proto

type IPVersion 

type IPVersion = flow.IPVersion

IPVersion from public import flow/flow.proto

type Kafka 

type Kafka = flow.Kafka

Kafka from public import flow/flow.proto

type L7FlowType 

type L7FlowType = flow.L7FlowType

L7FlowType from public import flow/flow.proto

type Layer4 

type Layer4 = flow.Layer4

Layer4 from public import flow/flow.proto

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

Layer7 from public import flow/flow.proto

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 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewObserverClient 

func NewObserverClient(cc *grpc.ClientConn) 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.

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 Payload added in v1.8.0 

type Payload = flow.Payload

Payload from public import flow/flow.proto

type ServerStatusRequest 

type ServerStatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerStatusRequest) Descriptor 

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

func (*ServerStatusRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*ServerStatusRequest) ProtoMessage 

func (*ServerStatusRequest) ProtoMessage()

func (*ServerStatusRequest) Reset 

func (m *ServerStatusRequest) Reset()

func (*ServerStatusRequest) String 

func (m *ServerStatusRequest) String() string

func (*ServerStatusRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*ServerStatusRequest) Validate added in v1.8.0 

func (m *ServerStatusRequest) Validate() error

Validate checks the field values on ServerStatusRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ServerStatusRequest) XXX_DiscardUnknown added in v1.8.0 

func (m *ServerStatusRequest) XXX_DiscardUnknown()

func (*ServerStatusRequest) XXX_Marshal added in v1.8.0 

func (m *ServerStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStatusRequest) XXX_Merge added in v1.8.0 

func (m *ServerStatusRequest) XXX_Merge(src proto.Message)

func (*ServerStatusRequest) XXX_Size added in v1.8.0 

func (m *ServerStatusRequest) XXX_Size() int

func (*ServerStatusRequest) XXX_Unmarshal added in v1.8.0 

func (m *ServerStatusRequest) XXX_Unmarshal(b []byte) error

type ServerStatusRequestValidationError added in v1.8.0 

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

ServerStatusRequestValidationError is the validation error returned by ServerStatusRequest.Validate if the designated constraints aren't met.

func (ServerStatusRequestValidationError) Cause added in v1.8.0 

func (e ServerStatusRequestValidationError) Cause() error

Cause function returns cause value.

func (ServerStatusRequestValidationError) Error added in v1.8.0 

func (e ServerStatusRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ServerStatusRequestValidationError) ErrorName added in v1.8.0 

func (e ServerStatusRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ServerStatusRequestValidationError) Field added in v1.8.0 

func (e ServerStatusRequestValidationError) Field() string

Field function returns field value.

func (ServerStatusRequestValidationError) Key added in v1.8.0 

func (e ServerStatusRequestValidationError) Key() bool

Key function returns key value.

func (ServerStatusRequestValidationError) Reason added in v1.8.0 

func (e ServerStatusRequestValidationError) Reason() string

Reason function returns reason value.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerStatusResponse) Descriptor 

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

func (*ServerStatusResponse) GetMaxFlows 

func (m *ServerStatusResponse) GetMaxFlows() uint64

func (*ServerStatusResponse) GetNumConnectedNodes 

func (m *ServerStatusResponse) GetNumConnectedNodes() *wrappers.UInt32Value

func (*ServerStatusResponse) GetNumFlows 

func (m *ServerStatusResponse) GetNumFlows() uint64

func (*ServerStatusResponse) GetNumUnavailableNodes 

func (m *ServerStatusResponse) GetNumUnavailableNodes() *wrappers.UInt32Value

func (*ServerStatusResponse) GetSeenFlows 

func (m *ServerStatusResponse) GetSeenFlows() uint64

func (*ServerStatusResponse) GetUnavailableNodes 

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

func (*ServerStatusResponse) GetUptimeNs 

func (m *ServerStatusResponse) GetUptimeNs() uint64

func (*ServerStatusResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*ServerStatusResponse) ProtoMessage 

func (*ServerStatusResponse) ProtoMessage()

func (*ServerStatusResponse) Reset 

func (m *ServerStatusResponse) Reset()

func (*ServerStatusResponse) String 

func (m *ServerStatusResponse) String() string

func (*ServerStatusResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*ServerStatusResponse) Validate added in v1.8.0 

func (m *ServerStatusResponse) Validate() error

Validate checks the field values on ServerStatusResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ServerStatusResponse) XXX_DiscardUnknown added in v1.8.0 

func (m *ServerStatusResponse) XXX_DiscardUnknown()

func (*ServerStatusResponse) XXX_Marshal added in v1.8.0 

func (m *ServerStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStatusResponse) XXX_Merge added in v1.8.0 

func (m *ServerStatusResponse) XXX_Merge(src proto.Message)

func (*ServerStatusResponse) XXX_Size added in v1.8.0 

func (m *ServerStatusResponse) XXX_Size() int

func (*ServerStatusResponse) XXX_Unmarshal added in v1.8.0 

func (m *ServerStatusResponse) XXX_Unmarshal(b []byte) error

type ServerStatusResponseValidationError added in v1.8.0 

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

ServerStatusResponseValidationError is the validation error returned by ServerStatusResponse.Validate if the designated constraints aren't met.

func (ServerStatusResponseValidationError) Cause added in v1.8.0 

func (e ServerStatusResponseValidationError) Cause() error

Cause function returns cause value.

func (ServerStatusResponseValidationError) Error added in v1.8.0 

func (e ServerStatusResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ServerStatusResponseValidationError) ErrorName added in v1.8.0 

func (e ServerStatusResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ServerStatusResponseValidationError) Field added in v1.8.0 

func (e ServerStatusResponseValidationError) Field() string

Field function returns field value.

func (ServerStatusResponseValidationError) Key added in v1.8.0 

func (e ServerStatusResponseValidationError) Key() bool

Key function returns key value.

func (ServerStatusResponseValidationError) Reason added in v1.8.0 

func (e ServerStatusResponseValidationError) Reason() string

Reason function returns reason value.

type Service 

type Service = flow.Service

Service from public import flow/flow.proto

type TCP 

type TCP = flow.TCP

TCP from public import flow/flow.proto

type TCPFlags 

type TCPFlags = flow.TCPFlags

TCPFlags from public import flow/flow.proto

type TraceObservationPoint 

type TraceObservationPoint = flow.TraceObservationPoint

TraceObservationPoint from public import flow/flow.proto

type TrafficDirection 

type TrafficDirection = flow.TrafficDirection

TrafficDirection from public import flow/flow.proto

type UDP 

type UDP = flow.UDP

UDP from public import flow/flow.proto

type UnimplementedObserverServer 

type UnimplementedObserverServer struct {
}

UnimplementedObserverServer can be embedded to have forward compatible implementations.

func (*UnimplementedObserverServer) GetFlows 

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

func (*UnimplementedObserverServer) ServerStatus 

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

type Verdict 

type Verdict = flow.Verdict

Verdict from public import flow/flow.proto

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.