forward

Documentation

Index

• Variables
• type Endpoint
  • func (*Endpoint) Descriptor() ([]byte, []int)
  • func (m *Endpoint) GetEndpoint() isEndpoint_Endpoint
  • func (x *Endpoint) GetInterface() *Interface
  • func (x *Endpoint) GetLocalNode() *LocalNode
  • func (x *Endpoint) GetRemoteNode() *RemoteNode
  • func (*Endpoint) ProtoMessage()
  • func (x *Endpoint) ProtoReflect() protoreflect.Message
  • func (x *Endpoint) Reset()
  • func (x *Endpoint) String() string
• type Endpoint_Interface
• type Endpoint_LocalNode
• type Endpoint_RemoteNode
• type ForwardConfig
  • func (*ForwardConfig) Descriptor() ([]byte, []int)
  • func (x *ForwardConfig) GetWires() []*Wire
  • func (*ForwardConfig) ProtoMessage()
  • func (x *ForwardConfig) ProtoReflect() protoreflect.Message
  • func (x *ForwardConfig) Reset()
  • func (x *ForwardConfig) String() string
• type Interface
  • func (*Interface) Descriptor() ([]byte, []int)
  • func (x *Interface) GetName() string
  • func (*Interface) ProtoMessage()
  • func (x *Interface) ProtoReflect() protoreflect.Message
  • func (x *Interface) Reset()
  • func (x *Interface) String() string
• type LocalNode
  • func (*LocalNode) Descriptor() ([]byte, []int)
  • func (x *LocalNode) GetInterface() string
  • func (x *LocalNode) GetName() string
  • func (*LocalNode) ProtoMessage()
  • func (x *LocalNode) ProtoReflect() protoreflect.Message
  • func (x *LocalNode) Reset()
  • func (x *LocalNode) String() string
• type RemoteNode
  • func (*RemoteNode) Descriptor() ([]byte, []int)
  • func (x *RemoteNode) GetAddr() string
  • func (x *RemoteNode) GetInterface() string
  • func (*RemoteNode) ProtoMessage()
  • func (x *RemoteNode) ProtoReflect() protoreflect.Message
  • func (x *RemoteNode) Reset()
  • func (x *RemoteNode) String() string
• type Wire
  • func (*Wire) Descriptor() ([]byte, []int)
  • func (x *Wire) GetA() *Endpoint
  • func (x *Wire) GetZ() *Endpoint
  • func (*Wire) ProtoMessage()
  • func (x *Wire) ProtoReflect() protoreflect.Message
  • func (x *Wire) Reset()
  • func (x *Wire) String() string

Variables

var File_forward_proto protoreflect.FileDescriptor

Types

type Endpoint

type Endpoint struct {

	// Types that are assignable to Endpoint:
	//
	//	*Endpoint_Interface
	//	*Endpoint_LocalNode
	//	*Endpoint_RemoteNode
	Endpoint isEndpoint_Endpoint `protobuf_oneof:"endpoint"`
	// contains filtered or unexported fields
}

func (*Endpoint) Descriptor

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetEndpoint

func (m *Endpoint) GetEndpoint() isEndpoint_Endpoint

func (*Endpoint) GetInterface

func (x *Endpoint) GetInterface() *Interface

func (*Endpoint) GetLocalNode

func (x *Endpoint) GetLocalNode() *LocalNode

func (*Endpoint) GetRemoteNode

func (x *Endpoint) GetRemoteNode() *RemoteNode

func (*Endpoint) ProtoMessage

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect

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

func (*Endpoint) Reset

func (x *Endpoint) Reset()

func (*Endpoint) String

func (x *Endpoint) String() string

type Endpoint_Interface

type Endpoint_Interface struct {
	// Interface is a local interface (ex. eth0) on the node.
	Interface *Interface `protobuf:"bytes,1,opt,name=interface,proto3,oneof"`
}

type Endpoint_LocalNode

type Endpoint_LocalNode struct {
	// LocalNode is a node in the same cluster.
	LocalNode *LocalNode `protobuf:"bytes,2,opt,name=local_node,json=localNode,proto3,oneof"`
}

type Endpoint_RemoteNode

type Endpoint_RemoteNode struct {
	// RemoteNode is a node in a different cluster.
	RemoteNode *RemoteNode `protobuf:"bytes,3,opt,name=remote_node,json=remoteNode,proto3,oneof"`
}

type ForwardConfig

type ForwardConfig struct {
	Wires []*Wire `protobuf:"bytes,1,rep,name=wires,proto3" json:"wires,omitempty"`
	// contains filtered or unexported fields
}

Forward specific config data for KNE

func (*ForwardConfig) Descriptor

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

Deprecated: Use ForwardConfig.ProtoReflect.Descriptor instead.

func (*ForwardConfig) GetWires

func (x *ForwardConfig) GetWires() []*Wire

func (*ForwardConfig) ProtoMessage

func (*ForwardConfig) ProtoMessage()

func (*ForwardConfig) ProtoReflect

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

func (*ForwardConfig) Reset

func (x *ForwardConfig) Reset()

func (*ForwardConfig) String

func (x *ForwardConfig) String() string

type Interface

type Interface struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // TODO: Add MTU and other configurable fields.
	// contains filtered or unexported fields
}

func (*Interface) Descriptor

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

Deprecated: Use Interface.ProtoReflect.Descriptor instead.

func (*Interface) GetName

func (x *Interface) GetName() string

func (*Interface) ProtoMessage

func (*Interface) ProtoMessage()

func (*Interface) ProtoReflect

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

func (*Interface) Reset

func (x *Interface) Reset()

func (*Interface) String

func (x *Interface) String() string

type LocalNode

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

func (*LocalNode) Descriptor

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

Deprecated: Use LocalNode.ProtoReflect.Descriptor instead.

func (*LocalNode) GetInterface

func (x *LocalNode) GetInterface() string

func (*LocalNode) GetName

func (x *LocalNode) GetName() string

func (*LocalNode) ProtoMessage

func (*LocalNode) ProtoMessage()

func (*LocalNode) ProtoReflect

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

func (*LocalNode) Reset

func (x *LocalNode) Reset()

func (*LocalNode) String

func (x *LocalNode) String() string

type RemoteNode

type RemoteNode struct {
	Addr      string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Interface string `protobuf:"bytes,2,opt,name=interface,proto3" json:"interface,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteNode) Descriptor

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

Deprecated: Use RemoteNode.ProtoReflect.Descriptor instead.

func (*RemoteNode) GetAddr

func (x *RemoteNode) GetAddr() string

func (*RemoteNode) GetInterface

func (x *RemoteNode) GetInterface() string

func (*RemoteNode) ProtoMessage

func (*RemoteNode) ProtoMessage()

func (*RemoteNode) ProtoReflect

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

func (*RemoteNode) Reset

func (x *RemoteNode) Reset()

func (*RemoteNode) String

func (x *RemoteNode) String() string

type Wire

type Wire struct {

	// The a endpoint serves as the client endpoint in the bidirectional stream.
	A *Endpoint `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	// The z endpoint serves as the server endpoint in the bidirectional stream.
	Z *Endpoint `protobuf:"bytes,2,opt,name=z,proto3" json:"z,omitempty"`
	// contains filtered or unexported fields
}

Wire is a connection between two endpoints intended to forward data bidirectionally between them. One of the endpoints must be of type Interface.

func (*Wire) Descriptor

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

Deprecated: Use Wire.ProtoReflect.Descriptor instead.

func (*Wire) GetA

func (x *Wire) GetA() *Endpoint

func (*Wire) GetZ

func (x *Wire) GetZ() *Endpoint

func (*Wire) ProtoMessage

func (*Wire) ProtoMessage()

func (*Wire) ProtoReflect

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

func (*Wire) Reset

func (x *Wire) Reset()

func (*Wire) String

func (x *Wire) String() string