relay

Documentation

Index

• Variables
• type NodeState
  • func (NodeState) Descriptor() protoreflect.EnumDescriptor
  • func (x NodeState) Enum() *NodeState
  • func (NodeState) EnumDescriptor() ([]byte, []int)
  • func (x NodeState) Number() protoreflect.EnumNumber
  • func (x NodeState) String() string
  • func (NodeState) Type() protoreflect.EnumType
• type NodeStatusEvent
  • func (*NodeStatusEvent) Descriptor() ([]byte, []int)
  • func (x *NodeStatusEvent) GetMessage() string
  • func (x *NodeStatusEvent) GetNodeNames() []string
  • func (x *NodeStatusEvent) GetStateChange() NodeState
  • func (msg *NodeStatusEvent) MarshalJSON() ([]byte, error)
  • func (*NodeStatusEvent) ProtoMessage()
  • func (x *NodeStatusEvent) ProtoReflect() protoreflect.Message
  • func (x *NodeStatusEvent) Reset()
  • func (x *NodeStatusEvent) String() string
  • func (msg *NodeStatusEvent) UnmarshalJSON(b []byte) error

Variables

var (
	NodeState_name = map[int32]string{
		0: "UNKNOWN_NODE_STATE",
		1: "NODE_CONNECTED",
		2: "NODE_UNAVAILABLE",
		3: "NODE_GONE",
		4: "NODE_ERROR",
	}
	NodeState_value = map[string]int32{
		"UNKNOWN_NODE_STATE": 0,
		"NODE_CONNECTED":     1,
		"NODE_UNAVAILABLE":   2,
		"NODE_GONE":          3,
		"NODE_ERROR":         4,
	}
)

Enum value maps for NodeState.

var File_relay_relay_proto protoreflect.FileDescriptor

Types

type NodeState

type NodeState int32

const (
	// UNKNOWN_NODE_STATE indicates that the state of this node is unknown.
	NodeState_UNKNOWN_NODE_STATE NodeState = 0
	// NODE_CONNECTED indicates that we have established a connection
	// to this node. The client can expect to observe flows from this node.
	NodeState_NODE_CONNECTED NodeState = 1
	// NODE_UNAVAILABLE indicates that the connection to this
	// node is currently unavailable. The client can expect to not see any
	// flows from this node until either the connection is re-established or
	// the node is gone.
	NodeState_NODE_UNAVAILABLE NodeState = 2
	// NODE_GONE indicates that a node has been removed from the
	// cluster. No reconnection attempts will be made.
	NodeState_NODE_GONE NodeState = 3
	// NODE_ERROR indicates that a node has reported an error while processing
	// the request. No reconnection attempts will be made.
	NodeState_NODE_ERROR NodeState = 4
)

func (NodeState) Descriptor

func (NodeState) Descriptor() protoreflect.EnumDescriptor

func (NodeState) Enum

func (x NodeState) Enum() *NodeState

func (NodeState) EnumDescriptor

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

Deprecated: Use NodeState.Descriptor instead.

func (NodeState) Number

func (x NodeState) Number() protoreflect.EnumNumber

func (NodeState) String

func (x NodeState) String() string

func (NodeState) Type

func (NodeState) Type() protoreflect.EnumType

type NodeStatusEvent

type NodeStatusEvent struct {

	// state_change contains the new node state
	StateChange NodeState `protobuf:"varint,1,opt,name=state_change,json=stateChange,proto3,enum=relay.NodeState" json:"state_change,omitempty"`
	// node_names is the list of nodes for which the above state changes applies
	NodeNames []string `protobuf:"bytes,2,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"`
	// message is an optional message attached to the state change (e.g. an
	// error message). The message applies to all nodes in node_names.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

NodeStatusEvent is a message sent by hubble-relay to inform clients about the state of a particular node.

func (*NodeStatusEvent) Descriptor

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

Deprecated: Use NodeStatusEvent.ProtoReflect.Descriptor instead.

func (*NodeStatusEvent) GetMessage

func (x *NodeStatusEvent) GetMessage() string

func (*NodeStatusEvent) GetNodeNames

func (x *NodeStatusEvent) GetNodeNames() []string

func (*NodeStatusEvent) GetStateChange

func (x *NodeStatusEvent) GetStateChange() NodeState

func (*NodeStatusEvent) MarshalJSON

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

MarshalJSON implements json.Marshaler

func (*NodeStatusEvent) ProtoMessage

func (*NodeStatusEvent) ProtoMessage()

func (*NodeStatusEvent) ProtoReflect

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

func (*NodeStatusEvent) Reset

func (x *NodeStatusEvent) Reset()

func (*NodeStatusEvent) String

func (x *NodeStatusEvent) String() string

func (*NodeStatusEvent) UnmarshalJSON

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

UnmarshalJSON implements json.Unmarshaler