ui

package
v0.0.0-...-17853a9 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UI_GetEvents_FullMethodName        = "/ui.UI/GetEvents"
	UI_GetStatus_FullMethodName        = "/ui.UI/GetStatus"
	UI_GetControlStream_FullMethodName = "/ui.UI/GetControlStream"
)

Variables

View Source 
var (
	EventType_name = map[int32]string{
		0: "UNKNOWN_EVENT",
		1: "FLOW",
		2: "K8S_NAMESPACE_STATE",
		3: "SERVICE_STATE",
		4: "SERVICE_LINK_STATE",
		5: "FLOWS",
		6: "STATUS",
	}
	EventType_value = map[string]int32{
		"UNKNOWN_EVENT":       0,
		"FLOW":                1,
		"K8S_NAMESPACE_STATE": 2,
		"SERVICE_STATE":       3,
		"SERVICE_LINK_STATE":  4,
		"FLOWS":               5,
		"STATUS":              6,
	}
)

Enum value maps for EventType.

View Source 
var (
	IPProtocol_name = map[int32]string{
		0: "UNKNOWN_IP_PROTOCOL",
		1: "TCP",
		2: "UDP",
		3: "ICMP_V4",
		4: "ICMP_V6",
	}
	IPProtocol_value = map[string]int32{
		"UNKNOWN_IP_PROTOCOL": 0,
		"TCP":                 1,
		"UDP":                 2,
		"ICMP_V4":             3,
		"ICMP_V6":             4,
	}
)

Enum value maps for IPProtocol.

View Source 
var (
	StateChange_name = map[int32]string{
		0: "UNKNOWN_STATE_CHANGE",
		1: "ADDED",
		2: "MODIFIED",
		3: "DELETED",
		4: "EXISTS",
	}
	StateChange_value = map[string]int32{
		"UNKNOWN_STATE_CHANGE": 0,
		"ADDED":                1,
		"MODIFIED":             2,
		"DELETED":              3,
		"EXISTS":               4,
	}
)

Enum value maps for StateChange.

View Source 
var File_ui_notifications_proto protoreflect.FileDescriptor
View Source 
var File_ui_status_proto protoreflect.FileDescriptor
View Source 
var File_ui_ui_proto protoreflect.FileDescriptor
View Source 
var UI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ui.UI",
	HandlerType: (*UIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetStatus",
			Handler:    _UI_GetStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetEvents",
			Handler:       _UI_GetEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetControlStream",
			Handler:       _UI_GetControlStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "ui/ui.proto",
}

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

Functions

func RegisterUIServer 

func RegisterUIServer(s grpc.ServiceRegistrar, srv UIServer)

Types

type ConnectionState 

type ConnectionState struct {

	// Backend is successfully connected to hubble-relay
	RelayConnected bool `protobuf:"varint,1,opt,name=relay_connected,json=relayConnected,proto3" json:"relay_connected,omitempty"`
	// Backend has lost the connection to hubble-relay and is reconnecting now
	RelayReconnecting bool `protobuf:"varint,2,opt,name=relay_reconnecting,json=relayReconnecting,proto3" json:"relay_reconnecting,omitempty"`
	// Backend has lost the connection to kubernetes and is reconnecting
	K8SUnavailable bool `protobuf:"varint,3,opt,name=k8s_unavailable,json=k8sUnavailable,proto3" json:"k8s_unavailable,omitempty"`
	// Backend has established connection to k8s
	K8SConnected bool `protobuf:"varint,4,opt,name=k8s_connected,json=k8sConnected,proto3" json:"k8s_connected,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionState) Descriptor deprecated 

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

Deprecated: Use ConnectionState.ProtoReflect.Descriptor instead.

func (*ConnectionState) GetK8SConnected 

func (x *ConnectionState) GetK8SConnected() bool

func (*ConnectionState) GetK8SUnavailable 

func (x *ConnectionState) GetK8SUnavailable() bool

func (*ConnectionState) GetRelayConnected 

func (x *ConnectionState) GetRelayConnected() bool

func (*ConnectionState) GetRelayReconnecting 

func (x *ConnectionState) GetRelayReconnecting() bool

func (*ConnectionState) ProtoMessage 

func (*ConnectionState) ProtoMessage()

func (*ConnectionState) ProtoReflect 

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

func (*ConnectionState) Reset 

func (x *ConnectionState) Reset()

func (*ConnectionState) String 

func (x *ConnectionState) String() string

type DataState 

type DataState struct {

	// No pods in selected namespace
	NoActivity bool `protobuf:"varint,1,opt,name=no_activity,json=noActivity,proto3" json:"no_activity,omitempty"`
	// contains filtered or unexported fields
}

func (*DataState) Descriptor deprecated 

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

Deprecated: Use DataState.ProtoReflect.Descriptor instead.

func (*DataState) GetNoActivity 

func (x *DataState) GetNoActivity() bool

func (*DataState) ProtoMessage 

func (*DataState) ProtoMessage()

func (*DataState) ProtoReflect 

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

func (*DataState) Reset 

func (x *DataState) Reset()

func (*DataState) String 

func (x *DataState) String() string

type DeployedComponent 

type DeployedComponent struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployedComponent) Descriptor deprecated 

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

Deprecated: Use DeployedComponent.ProtoReflect.Descriptor instead.

func (*DeployedComponent) GetName 

func (x *DeployedComponent) GetName() string

func (*DeployedComponent) GetVersion 

func (x *DeployedComponent) GetVersion() string

func (*DeployedComponent) ProtoMessage 

func (*DeployedComponent) ProtoMessage()

func (*DeployedComponent) ProtoReflect 

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

func (*DeployedComponent) Reset 

func (x *DeployedComponent) Reset()

func (*DeployedComponent) String 

func (x *DeployedComponent) String() string

type Event 

type Event struct {

	// Types that are assignable to Event:
	//
	//	*Event_Flow
	//	*Event_NamespaceState
	//	*Event_ServiceState
	//	*Event_ServiceLinkState
	//	*Event_Flows
	//	*Event_Notification
	Event isEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetFlow 

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

func (*Event) GetFlows 

func (x *Event) GetFlows() *Flows

func (*Event) GetNamespaceState 

func (x *Event) GetNamespaceState() *NamespaceState

func (*Event) GetNotification 

func (x *Event) GetNotification() *Notification

func (*Event) GetServiceLinkState 

func (x *Event) GetServiceLinkState() *ServiceLinkState

func (*Event) GetServiceState 

func (x *Event) GetServiceState() *ServiceState

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventFilter 

type EventFilter struct {

	// Types that are assignable to Filter:
	//
	//	*EventFilter_FlowFilter
	//	*EventFilter_ServiceFilter
	//	*EventFilter_ServiceLinkFilter
	Filter isEventFilter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

Here I added different filter types for different events. Another option is to reuse and extend FlowFilter to filter all the events, but I worry that it might become too confusing in terms of figuring out which filter fields apply to which events.

func (*EventFilter) Descriptor deprecated 

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

Deprecated: Use EventFilter.ProtoReflect.Descriptor instead.

func (*EventFilter) GetFilter 

func (m *EventFilter) GetFilter() isEventFilter_Filter

func (*EventFilter) GetFlowFilter 

func (x *EventFilter) GetFlowFilter() *flow.FlowFilter

func (*EventFilter) GetServiceFilter 

func (x *EventFilter) GetServiceFilter() *ServiceFilter

func (*EventFilter) GetServiceLinkFilter 

func (x *EventFilter) GetServiceLinkFilter() *ServiceLinkFilter

func (*EventFilter) ProtoMessage 

func (*EventFilter) ProtoMessage()

func (*EventFilter) ProtoReflect 

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

func (*EventFilter) Reset 

func (x *EventFilter) Reset()

func (*EventFilter) String 

func (x *EventFilter) String() string

type EventFilter_FlowFilter 

type EventFilter_FlowFilter struct {
	FlowFilter *flow.FlowFilter `protobuf:"bytes,2,opt,name=flow_filter,json=flowFilter,proto3,oneof"`
}

type EventFilter_ServiceFilter 

type EventFilter_ServiceFilter struct {
	ServiceFilter *ServiceFilter `protobuf:"bytes,3,opt,name=service_filter,json=serviceFilter,proto3,oneof"`
}

type EventFilter_ServiceLinkFilter 

type EventFilter_ServiceLinkFilter struct {
	ServiceLinkFilter *ServiceLinkFilter `protobuf:"bytes,4,opt,name=service_link_filter,json=serviceLinkFilter,proto3,oneof"`
}

type EventType 

type EventType int32
const (
	EventType_UNKNOWN_EVENT       EventType = 0
	EventType_FLOW                EventType = 1
	EventType_K8S_NAMESPACE_STATE EventType = 2
	EventType_SERVICE_STATE       EventType = 3
	EventType_SERVICE_LINK_STATE  EventType = 4
	EventType_FLOWS               EventType = 5
	EventType_STATUS              EventType = 6
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

func (EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

type Event_Flow 

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

type Event_Flows 

type Event_Flows struct {
	Flows *Flows `protobuf:"bytes,7,opt,name=flows,proto3,oneof"`
}

type Event_NamespaceState 

type Event_NamespaceState struct {
	NamespaceState *NamespaceState `protobuf:"bytes,4,opt,name=namespace_state,json=namespaceState,proto3,oneof"`
}

type Event_Notification 

type Event_Notification struct {
	Notification *Notification `protobuf:"bytes,8,opt,name=notification,proto3,oneof"`
}

type Event_ServiceLinkState 

type Event_ServiceLinkState struct {
	// It's unclear how we can define what it means for service links to get
	// added/deleted. For now I'm deferring the decision for whether a
	// particular link should be included in the service map to the client.
	// Maybe the server can periodically send service_link events for active
	// links to keep-alive, and the client can expire older links based on their
	// timestamp.
	ServiceLinkState *ServiceLinkState `protobuf:"bytes,6,opt,name=service_link_state,json=serviceLinkState,proto3,oneof"`
}

type Event_ServiceState 

type Event_ServiceState struct {
	ServiceState *ServiceState `protobuf:"bytes,5,opt,name=service_state,json=serviceState,proto3,oneof"`
}

type FlowStats 

type FlowStats struct {
	PerSecond float32 `protobuf:"fixed32,1,opt,name=per_second,json=perSecond,proto3" json:"per_second,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowStats) Descriptor deprecated 

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

Deprecated: Use FlowStats.ProtoReflect.Descriptor instead.

func (*FlowStats) GetPerSecond 

func (x *FlowStats) GetPerSecond() float32

func (*FlowStats) ProtoMessage 

func (*FlowStats) ProtoMessage()

func (*FlowStats) ProtoReflect 

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

func (*FlowStats) Reset 

func (x *FlowStats) Reset()

func (*FlowStats) String 

func (x *FlowStats) String() string

type Flows 

type Flows struct {
	Flows []*flow.Flow `protobuf:"bytes,1,rep,name=flows,proto3" json:"flows,omitempty"`
	// contains filtered or unexported fields
}

func (*Flows) Descriptor deprecated 

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

Deprecated: Use Flows.ProtoReflect.Descriptor instead.

func (*Flows) GetFlows 

func (x *Flows) GetFlows() []*flow.Flow

func (*Flows) ProtoMessage 

func (*Flows) ProtoMessage()

func (*Flows) ProtoReflect 

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

func (*Flows) Reset 

func (x *Flows) Reset()

func (*Flows) String 

func (x *Flows) String() string

type GetControlStreamRequest 

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

func (*GetControlStreamRequest) Descriptor deprecated 

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

Deprecated: Use GetControlStreamRequest.ProtoReflect.Descriptor instead.

func (*GetControlStreamRequest) ProtoMessage 

func (*GetControlStreamRequest) ProtoMessage()

func (*GetControlStreamRequest) ProtoReflect 

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

func (*GetControlStreamRequest) Reset 

func (x *GetControlStreamRequest) Reset()

func (*GetControlStreamRequest) String 

func (x *GetControlStreamRequest) String() string

type GetControlStreamResponse 

type GetControlStreamResponse struct {

	// Types that are assignable to Event:
	//
	//	*GetControlStreamResponse_Namespaces
	//	*GetControlStreamResponse_Notification
	Event isGetControlStreamResponse_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*GetControlStreamResponse) Descriptor deprecated 

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

Deprecated: Use GetControlStreamResponse.ProtoReflect.Descriptor instead.

func (*GetControlStreamResponse) GetEvent 

func (m *GetControlStreamResponse) GetEvent() isGetControlStreamResponse_Event

func (*GetControlStreamResponse) GetNamespaces 

func (x *GetControlStreamResponse) GetNamespaces() *GetControlStreamResponse_NamespaceStates

func (*GetControlStreamResponse) GetNotification 

func (x *GetControlStreamResponse) GetNotification() *Notification

func (*GetControlStreamResponse) ProtoMessage 

func (*GetControlStreamResponse) ProtoMessage()

func (*GetControlStreamResponse) ProtoReflect 

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

func (*GetControlStreamResponse) Reset 

func (x *GetControlStreamResponse) Reset()

func (*GetControlStreamResponse) String 

func (x *GetControlStreamResponse) String() string

type GetControlStreamResponse_NamespaceStates 

type GetControlStreamResponse_NamespaceStates struct {
	Namespaces []*NamespaceState `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*GetControlStreamResponse_NamespaceStates) Descriptor deprecated 

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

Deprecated: Use GetControlStreamResponse_NamespaceStates.ProtoReflect.Descriptor instead.

func (*GetControlStreamResponse_NamespaceStates) GetNamespaces 

func (x *GetControlStreamResponse_NamespaceStates) GetNamespaces() []*NamespaceState

func (*GetControlStreamResponse_NamespaceStates) ProtoMessage 

func (*GetControlStreamResponse_NamespaceStates) ProtoMessage()

func (*GetControlStreamResponse_NamespaceStates) ProtoReflect 

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

func (*GetControlStreamResponse_NamespaceStates) Reset 

func (x *GetControlStreamResponse_NamespaceStates) Reset()

func (*GetControlStreamResponse_NamespaceStates) String 

func (x *GetControlStreamResponse_NamespaceStates) String() string

type GetControlStreamResponse_Namespaces 

type GetControlStreamResponse_Namespaces struct {
	Namespaces *GetControlStreamResponse_NamespaceStates `protobuf:"bytes,1,opt,name=namespaces,proto3,oneof"`
}

type GetControlStreamResponse_Notification 

type GetControlStreamResponse_Notification struct {
	Notification *Notification `protobuf:"bytes,2,opt,name=notification,proto3,oneof"`
}

type GetEventsRequest 

type GetEventsRequest struct {

	// EventType specifies which types of events to subscribe to. If unspecified, the
	// request is subscribed to all the event types.
	EventTypes    []EventType            `protobuf:"varint,1,rep,packed,name=event_types,json=eventTypes,proto3,enum=ui.EventType" json:"event_types,omitempty"`
	Blacklist     []*EventFilter         `protobuf:"bytes,2,rep,name=blacklist,proto3" json:"blacklist,omitempty"`
	Whitelist     []*EventFilter         `protobuf:"bytes,3,rep,name=whitelist,proto3" json:"whitelist,omitempty"`
	Since         *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=since,proto3" json:"since,omitempty"`
	StatusRequest *GetStatusRequest      `protobuf:"bytes,5,opt,name=status_request,json=statusRequest,proto3" json:"status_request,omitempty"`
	// contains filtered or unexported fields
}

Here I didn't include "follow", "until", and "number". This request assumes follow, and lets the client decide when to end the request, whether it's based on timestamp or the number of responses received.

func (*GetEventsRequest) Descriptor deprecated 

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

Deprecated: Use GetEventsRequest.ProtoReflect.Descriptor instead.

func (*GetEventsRequest) GetBlacklist 

func (x *GetEventsRequest) GetBlacklist() []*EventFilter

func (*GetEventsRequest) GetEventTypes 

func (x *GetEventsRequest) GetEventTypes() []EventType

func (*GetEventsRequest) GetSince 

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

func (*GetEventsRequest) GetStatusRequest 

func (x *GetEventsRequest) GetStatusRequest() *GetStatusRequest

func (*GetEventsRequest) GetWhitelist 

func (x *GetEventsRequest) GetWhitelist() []*EventFilter

func (*GetEventsRequest) ProtoMessage 

func (*GetEventsRequest) ProtoMessage()

func (*GetEventsRequest) ProtoReflect 

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

func (*GetEventsRequest) Reset 

func (x *GetEventsRequest) Reset()

func (*GetEventsRequest) String 

func (x *GetEventsRequest) String() string

type GetEventsResponse 

type GetEventsResponse struct {
	Node      string                 `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Events    []*Event               `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsResponse) Descriptor deprecated 

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

Deprecated: Use GetEventsResponse.ProtoReflect.Descriptor instead.

func (*GetEventsResponse) GetEvents 

func (x *GetEventsResponse) GetEvents() []*Event

func (*GetEventsResponse) GetNode 

func (x *GetEventsResponse) GetNode() string

func (*GetEventsResponse) GetTimestamp 

func (x *GetEventsResponse) GetTimestamp() *timestamppb.Timestamp

func (*GetEventsResponse) ProtoMessage 

func (*GetEventsResponse) ProtoMessage()

func (*GetEventsResponse) ProtoReflect 

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

func (*GetEventsResponse) Reset 

func (x *GetEventsResponse) Reset()

func (*GetEventsResponse) String 

func (x *GetEventsResponse) String() string

type GetStatusRequest 

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

func (*GetStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect 

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

func (*GetStatusRequest) Reset 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String 

func (x *GetStatusRequest) String() string

type GetStatusResponse 

type GetStatusResponse struct {
	Nodes        *observer.GetNodesResponse     `protobuf:"bytes,1,opt,name=nodes,proto3" json:"nodes,omitempty"`
	ServerStatus *observer.ServerStatusResponse `protobuf:"bytes,2,opt,name=server_status,json=serverStatus,proto3" json:"server_status,omitempty"`
	Versions     []*DeployedComponent           `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty"`
	Flows        *FlowStats                     `protobuf:"bytes,4,opt,name=flows,proto3" json:"flows,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) GetFlows 

func (x *GetStatusResponse) GetFlows() *FlowStats

func (*GetStatusResponse) GetNodes 

func (x *GetStatusResponse) GetNodes() *observer.GetNodesResponse

func (*GetStatusResponse) GetServerStatus 

func (x *GetStatusResponse) GetServerStatus() *observer.ServerStatusResponse

func (*GetStatusResponse) GetVersions 

func (x *GetStatusResponse) GetVersions() []*DeployedComponent

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect 

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

func (*GetStatusResponse) Reset 

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) String 

func (x *GetStatusResponse) String() string

type IPProtocol 

type IPProtocol int32

IP protocols. The values of enums do not correspond to actual IP protocol numbers. 

const (
	IPProtocol_UNKNOWN_IP_PROTOCOL IPProtocol = 0
	IPProtocol_TCP                 IPProtocol = 1
	IPProtocol_UDP                 IPProtocol = 2
	IPProtocol_ICMP_V4             IPProtocol = 3
	IPProtocol_ICMP_V6             IPProtocol = 4
)

func (IPProtocol) Descriptor 

func (IPProtocol) Descriptor() protoreflect.EnumDescriptor

func (IPProtocol) Enum 

func (x IPProtocol) Enum() *IPProtocol

func (IPProtocol) EnumDescriptor deprecated 

func (IPProtocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use IPProtocol.Descriptor instead.

func (IPProtocol) Number 

func (x IPProtocol) Number() protoreflect.EnumNumber

func (IPProtocol) String 

func (x IPProtocol) String() string

func (IPProtocol) Type 

func (IPProtocol) Type() protoreflect.EnumType

type NamespaceDescriptor 

type NamespaceDescriptor struct {
	Id                string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name              string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreationTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespaceDescriptor) Descriptor deprecated 

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

Deprecated: Use NamespaceDescriptor.ProtoReflect.Descriptor instead.

func (*NamespaceDescriptor) GetCreationTimestamp 

func (x *NamespaceDescriptor) GetCreationTimestamp() *timestamppb.Timestamp

func (*NamespaceDescriptor) GetId 

func (x *NamespaceDescriptor) GetId() string

func (*NamespaceDescriptor) GetName 

func (x *NamespaceDescriptor) GetName() string

func (*NamespaceDescriptor) ProtoMessage 

func (*NamespaceDescriptor) ProtoMessage()

func (*NamespaceDescriptor) ProtoReflect 

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

func (*NamespaceDescriptor) Reset 

func (x *NamespaceDescriptor) Reset()

func (*NamespaceDescriptor) String 

func (x *NamespaceDescriptor) String() string

type NamespaceState 

type NamespaceState struct {
	Namespace *NamespaceDescriptor `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      StateChange          `protobuf:"varint,2,opt,name=type,proto3,enum=ui.StateChange" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespaceState) Descriptor deprecated 

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

Deprecated: Use NamespaceState.ProtoReflect.Descriptor instead.

func (*NamespaceState) GetNamespace 

func (x *NamespaceState) GetNamespace() *NamespaceDescriptor

func (*NamespaceState) GetType 

func (x *NamespaceState) GetType() StateChange

func (*NamespaceState) ProtoMessage 

func (*NamespaceState) ProtoMessage()

func (*NamespaceState) ProtoReflect 

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

func (*NamespaceState) Reset 

func (x *NamespaceState) Reset()

func (*NamespaceState) String 

func (x *NamespaceState) String() string

type NoPermission 

type NoPermission struct {
	Resource string `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Error    string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*NoPermission) Descriptor deprecated 

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

Deprecated: Use NoPermission.ProtoReflect.Descriptor instead.

func (*NoPermission) GetError 

func (x *NoPermission) GetError() string

func (*NoPermission) GetResource 

func (x *NoPermission) GetResource() string

func (*NoPermission) ProtoMessage 

func (*NoPermission) ProtoMessage()

func (*NoPermission) ProtoReflect 

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

func (*NoPermission) Reset 

func (x *NoPermission) Reset()

func (*NoPermission) String 

func (x *NoPermission) String() string

type NodeStatus 

type NodeStatus struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IsAvailable bool   `protobuf:"varint,2,opt,name=is_available,json=isAvailable,proto3" json:"is_available,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeStatus) Descriptor deprecated 

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

Deprecated: Use NodeStatus.ProtoReflect.Descriptor instead.

func (*NodeStatus) GetIsAvailable 

func (x *NodeStatus) GetIsAvailable() bool

func (*NodeStatus) GetName 

func (x *NodeStatus) GetName() string

func (*NodeStatus) ProtoMessage 

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) ProtoReflect 

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

func (*NodeStatus) Reset 

func (x *NodeStatus) Reset()

func (*NodeStatus) String 

func (x *NodeStatus) String() string

type Notification 

type Notification struct {

	// Types that are assignable to Notification:
	//
	//	*Notification_ConnState
	//	*Notification_DataState
	//	*Notification_Status
	//	*Notification_NoPermission
	Notification isNotification_Notification `protobuf_oneof:"notification"`
	// contains filtered or unexported fields
}

func (*Notification) Descriptor deprecated 

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetConnState 

func (x *Notification) GetConnState() *ConnectionState

func (*Notification) GetDataState 

func (x *Notification) GetDataState() *DataState

func (*Notification) GetNoPermission 

func (x *Notification) GetNoPermission() *NoPermission

func (*Notification) GetNotification 

func (m *Notification) GetNotification() isNotification_Notification

func (*Notification) GetStatus 

func (x *Notification) GetStatus() *GetStatusResponse

func (*Notification) ProtoMessage 

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect 

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

func (*Notification) Reset 

func (x *Notification) Reset()

func (*Notification) String 

func (x *Notification) String() string

type Notification_ConnState 

type Notification_ConnState struct {
	ConnState *ConnectionState `protobuf:"bytes,1,opt,name=conn_state,json=connState,proto3,oneof"`
}

type Notification_DataState 

type Notification_DataState struct {
	DataState *DataState `protobuf:"bytes,2,opt,name=data_state,json=dataState,proto3,oneof"`
}

type Notification_NoPermission 

type Notification_NoPermission struct {
	NoPermission *NoPermission `protobuf:"bytes,4,opt,name=no_permission,json=noPermission,proto3,oneof"`
}

type Notification_Status 

type Notification_Status struct {
	Status *GetStatusResponse `protobuf:"bytes,3,opt,name=status,proto3,oneof"`
}

type Service 

type Service struct {

	// An opaque ID that uniquely identifies the service.
	Id                    string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                  string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace             string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels                []string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`
	DnsNames              []string `protobuf:"bytes,5,rep,name=dns_names,json=dnsNames,proto3" json:"dns_names,omitempty"`
	EgressPolicyEnforced  bool     `protobuf:"varint,6,opt,name=egress_policy_enforced,json=egressPolicyEnforced,proto3" json:"egress_policy_enforced,omitempty"`
	IngressPolicyEnforced bool     `` /* 127-byte string literal not displayed */
	// This is a string instead of boolean because Cilium reports status message. If it's
	// successfully enabled, this string is set to "OK" I think.
	VisibilityPolicyStatus string `` /* 129-byte string literal not displayed */
	// We probably can't reliably set creation timestamp.
	CreationTimestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	Workloads         []*flow.Workload       `protobuf:"bytes,10,rep,name=workloads,proto3" json:"workloads,omitempty"`
	Identity          uint32                 `protobuf:"varint,12,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

Come up with a better name for Service.

func (*Service) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetCreationTimestamp 

func (x *Service) GetCreationTimestamp() *timestamppb.Timestamp

func (*Service) GetDnsNames 

func (x *Service) GetDnsNames() []string

func (*Service) GetEgressPolicyEnforced 

func (x *Service) GetEgressPolicyEnforced() bool

func (*Service) GetId 

func (x *Service) GetId() string

func (*Service) GetIdentity 

func (x *Service) GetIdentity() uint32

func (*Service) GetIngressPolicyEnforced 

func (x *Service) GetIngressPolicyEnforced() bool

func (*Service) GetLabels 

func (x *Service) GetLabels() []string

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetNamespace 

func (x *Service) GetNamespace() string

func (*Service) GetVisibilityPolicyStatus 

func (x *Service) GetVisibilityPolicyStatus() string

func (*Service) GetWorkloads 

func (x *Service) GetWorkloads() []*flow.Workload

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type ServiceFilter 

type ServiceFilter struct {
	Namespace []string `protobuf:"bytes,1,rep,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceFilter) Descriptor deprecated 

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

Deprecated: Use ServiceFilter.ProtoReflect.Descriptor instead.

func (*ServiceFilter) GetNamespace 

func (x *ServiceFilter) GetNamespace() []string

func (*ServiceFilter) ProtoMessage 

func (*ServiceFilter) ProtoMessage()

func (*ServiceFilter) ProtoReflect 

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

func (*ServiceFilter) Reset 

func (x *ServiceFilter) Reset()

func (*ServiceFilter) String 

func (x *ServiceFilter) String() string
type ServiceLink struct {

	// An opaque ID that uniquely identifies this link.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// source Service id
	SourceId string `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	// destination Service id
	DestinationId   string               `protobuf:"bytes,3,opt,name=destination_id,json=destinationId,proto3" json:"destination_id,omitempty"`
	DestinationPort uint32               `protobuf:"varint,4,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	IpProtocol      IPProtocol           `protobuf:"varint,5,opt,name=ip_protocol,json=ipProtocol,proto3,enum=ui.IPProtocol" json:"ip_protocol,omitempty"`
	Verdict         flow.Verdict         `protobuf:"varint,6,opt,name=verdict,proto3,enum=flow.Verdict" json:"verdict,omitempty"`
	FlowAmount      uint64               `protobuf:"varint,7,opt,name=flow_amount,json=flowAmount,proto3" json:"flow_amount,omitempty"`
	Latency         *ServiceLink_Latency `protobuf:"bytes,8,opt,name=latency,proto3" json:"latency,omitempty"`
	BytesTransfered uint64               `protobuf:"varint,9,opt,name=bytes_transfered,json=bytesTransfered,proto3" json:"bytes_transfered,omitempty"`
	AuthType        flow.AuthType        `protobuf:"varint,10,opt,name=auth_type,json=authType,proto3,enum=flow.AuthType" json:"auth_type,omitempty"`
	IsEncrypted     bool                 `protobuf:"varint,11,opt,name=is_encrypted,json=isEncrypted,proto3" json:"is_encrypted,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceLink) Descriptor deprecated 

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

Deprecated: Use ServiceLink.ProtoReflect.Descriptor instead.

func (*ServiceLink) GetAuthType 

func (x *ServiceLink) GetAuthType() flow.AuthType

func (*ServiceLink) GetBytesTransfered 

func (x *ServiceLink) GetBytesTransfered() uint64

func (*ServiceLink) GetDestinationId 

func (x *ServiceLink) GetDestinationId() string

func (*ServiceLink) GetDestinationPort 

func (x *ServiceLink) GetDestinationPort() uint32

func (*ServiceLink) GetFlowAmount 

func (x *ServiceLink) GetFlowAmount() uint64

func (*ServiceLink) GetId 

func (x *ServiceLink) GetId() string

func (*ServiceLink) GetIpProtocol 

func (x *ServiceLink) GetIpProtocol() IPProtocol

func (*ServiceLink) GetIsEncrypted 

func (x *ServiceLink) GetIsEncrypted() bool

func (*ServiceLink) GetLatency 

func (x *ServiceLink) GetLatency() *ServiceLink_Latency

func (*ServiceLink) GetSourceId 

func (x *ServiceLink) GetSourceId() string

func (*ServiceLink) GetVerdict 

func (x *ServiceLink) GetVerdict() flow.Verdict

func (*ServiceLink) ProtoMessage 

func (*ServiceLink) ProtoMessage()

func (*ServiceLink) ProtoReflect 

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

func (*ServiceLink) Reset 

func (x *ServiceLink) Reset()

func (*ServiceLink) String 

func (x *ServiceLink) String() string

type ServiceLinkFilter 

type ServiceLinkFilter struct {
	Source      []*ServiceFilter `protobuf:"bytes,1,rep,name=source,proto3" json:"source,omitempty"`
	Destination []*ServiceFilter `protobuf:"bytes,2,rep,name=destination,proto3" json:"destination,omitempty"`
	// Use string here to support things like port ranges (e.g. 100-200).
	DestinationPort []string       `protobuf:"bytes,3,rep,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	Verdict         []flow.Verdict `protobuf:"varint,4,rep,packed,name=verdict,proto3,enum=flow.Verdict" json:"verdict,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceLinkFilter) Descriptor deprecated 

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

Deprecated: Use ServiceLinkFilter.ProtoReflect.Descriptor instead.

func (*ServiceLinkFilter) GetDestination 

func (x *ServiceLinkFilter) GetDestination() []*ServiceFilter

func (*ServiceLinkFilter) GetDestinationPort 

func (x *ServiceLinkFilter) GetDestinationPort() []string

func (*ServiceLinkFilter) GetSource 

func (x *ServiceLinkFilter) GetSource() []*ServiceFilter

func (*ServiceLinkFilter) GetVerdict 

func (x *ServiceLinkFilter) GetVerdict() []flow.Verdict

func (*ServiceLinkFilter) ProtoMessage 

func (*ServiceLinkFilter) ProtoMessage()

func (*ServiceLinkFilter) ProtoReflect 

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

func (*ServiceLinkFilter) Reset 

func (x *ServiceLinkFilter) Reset()

func (*ServiceLinkFilter) String 

func (x *ServiceLinkFilter) String() string

type ServiceLinkState 

type ServiceLinkState struct {
	ServiceLink *ServiceLink `protobuf:"bytes,1,opt,name=service_link,json=serviceLink,proto3" json:"service_link,omitempty"`
	Type        StateChange  `protobuf:"varint,2,opt,name=type,proto3,enum=ui.StateChange" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceLinkState) Descriptor deprecated 

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

Deprecated: Use ServiceLinkState.ProtoReflect.Descriptor instead. 

func (x *ServiceLinkState) GetServiceLink() *ServiceLink

func (*ServiceLinkState) GetType 

func (x *ServiceLinkState) GetType() StateChange

func (*ServiceLinkState) ProtoMessage 

func (*ServiceLinkState) ProtoMessage()

func (*ServiceLinkState) ProtoReflect 

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

func (*ServiceLinkState) Reset 

func (x *ServiceLinkState) Reset()

func (*ServiceLinkState) String 

func (x *ServiceLinkState) String() string
type ServiceLink_Latency struct {
	Min *durationpb.Duration `protobuf:"bytes,1,opt,name=min,proto3" json:"min,omitempty"`
	Max *durationpb.Duration `protobuf:"bytes,2,opt,name=max,proto3" json:"max,omitempty"`
	Avg *durationpb.Duration `protobuf:"bytes,3,opt,name=avg,proto3" json:"avg,omitempty"`
	// contains filtered or unexported fields
}
func (*ServiceLink_Latency) Descriptor() ([]byte, []int)

Deprecated: Use ServiceLink_Latency.ProtoReflect.Descriptor instead. 

func (x *ServiceLink_Latency) GetAvg() *durationpb.Duration
func (x *ServiceLink_Latency) GetMax() *durationpb.Duration
func (x *ServiceLink_Latency) GetMin() *durationpb.Duration
func (*ServiceLink_Latency) ProtoMessage()
func (x *ServiceLink_Latency) ProtoReflect() protoreflect.Message
func (x *ServiceLink_Latency) Reset()
func (x *ServiceLink_Latency) String() string

type ServiceState 

type ServiceState struct {
	Service *Service    `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Type    StateChange `protobuf:"varint,2,opt,name=type,proto3,enum=ui.StateChange" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceState) Descriptor deprecated 

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

Deprecated: Use ServiceState.ProtoReflect.Descriptor instead.

func (*ServiceState) GetService 

func (x *ServiceState) GetService() *Service

func (*ServiceState) GetType 

func (x *ServiceState) GetType() StateChange

func (*ServiceState) ProtoMessage 

func (*ServiceState) ProtoMessage()

func (*ServiceState) ProtoReflect 

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

func (*ServiceState) Reset 

func (x *ServiceState) Reset()

func (*ServiceState) String 

func (x *ServiceState) String() string

type StateChange 

type StateChange int32
const (
	StateChange_UNKNOWN_STATE_CHANGE StateChange = 0
	StateChange_ADDED                StateChange = 1
	StateChange_MODIFIED             StateChange = 2
	StateChange_DELETED              StateChange = 3
	// This is needed in case the relay server knows that the service exists,
	// but it doesn't know when it got created.
	StateChange_EXISTS StateChange = 4
)

func (StateChange) Descriptor 

func (StateChange) Descriptor() protoreflect.EnumDescriptor

func (StateChange) Enum 

func (x StateChange) Enum() *StateChange

func (StateChange) EnumDescriptor deprecated 

func (StateChange) EnumDescriptor() ([]byte, []int)

Deprecated: Use StateChange.Descriptor instead.

func (StateChange) Number 

func (x StateChange) Number() protoreflect.EnumNumber

func (StateChange) String 

func (x StateChange) String() string

func (StateChange) Type 

func (StateChange) Type() protoreflect.EnumType

type UIClient 

type UIClient interface {
	GetEvents(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (UI_GetEventsClient, error)
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
	GetControlStream(ctx context.Context, in *GetControlStreamRequest, opts ...grpc.CallOption) (UI_GetControlStreamClient, error)
}

UIClient is the client API for UI 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 NewUIClient 

func NewUIClient(cc grpc.ClientConnInterface) UIClient

type UIServer 

type UIServer interface {
	GetEvents(*GetEventsRequest, UI_GetEventsServer) error
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
	GetControlStream(*GetControlStreamRequest, UI_GetControlStreamServer) error
	// contains filtered or unexported methods
}

UIServer is the server API for UI service. All implementations must embed UnimplementedUIServer for forward compatibility

type UI_GetControlStreamClient 

type UI_GetControlStreamClient interface {
	Recv() (*GetControlStreamResponse, error)
	grpc.ClientStream
}

type UI_GetControlStreamServer 

type UI_GetControlStreamServer interface {
	Send(*GetControlStreamResponse) error
	grpc.ServerStream
}

type UI_GetEventsClient 

type UI_GetEventsClient interface {
	Recv() (*GetEventsResponse, error)
	grpc.ClientStream
}

type UI_GetEventsServer 

type UI_GetEventsServer interface {
	Send(*GetEventsResponse) error
	grpc.ServerStream
}

type UnimplementedUIServer 

type UnimplementedUIServer struct {
}

UnimplementedUIServer must be embedded to have forward compatible implementations.

func (UnimplementedUIServer) GetControlStream 

func (UnimplementedUIServer) GetControlStream(*GetControlStreamRequest, UI_GetControlStreamServer) error

func (UnimplementedUIServer) GetEvents 

func (UnimplementedUIServer) GetEvents(*GetEventsRequest, UI_GetEventsServer) error

func (UnimplementedUIServer) GetStatus 

func (UnimplementedUIServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

type UnsafeUIServer 

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

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

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.