proxy

Documentation

Index

• Variables
• type ClientHandshake
  • func (*ClientHandshake) Descriptor() ([]byte, []int)
  • func (x *ClientHandshake) GetCommand() HANDSHAKECOMMAND
  • func (x *ClientHandshake) GetTofuToken() string
  • func (*ClientHandshake) ProtoMessage()
  • func (x *ClientHandshake) ProtoReflect() protoreflect.Message
  • func (x *ClientHandshake) Reset()
  • func (x *ClientHandshake) String() string
• type HANDSHAKECOMMAND
  • func (HANDSHAKECOMMAND) Descriptor() protoreflect.EnumDescriptor
  • func (x HANDSHAKECOMMAND) Enum() *HANDSHAKECOMMAND
  • func (HANDSHAKECOMMAND) EnumDescriptor() ([]byte, []int)
  • func (x HANDSHAKECOMMAND) Number() protoreflect.EnumNumber
  • func (x HANDSHAKECOMMAND) String() string
  • func (HANDSHAKECOMMAND) Type() protoreflect.EnumType
• type HandshakeResult
  • func (*HandshakeResult) Descriptor() ([]byte, []int)
  • func (x *HandshakeResult) GetConnectionLimit() int32
  • func (x *HandshakeResult) GetConnectionsLeft() int32
  • func (x *HandshakeResult) GetExpiration() *timestamp.Timestamp
  • func (*HandshakeResult) ProtoMessage()
  • func (x *HandshakeResult) ProtoReflect() protoreflect.Message
  • func (x *HandshakeResult) Reset()
  • func (x *HandshakeResult) String() string

Variables

var (
	HANDSHAKECOMMAND_name = map[int32]string{
		0: "HANDSHAKECOMMAND_UNSPECIFIED",
		1: "HANDSHAKECOMMAND_SESSION_CANCEL",
	}
	HANDSHAKECOMMAND_value = map[string]int32{
		"HANDSHAKECOMMAND_UNSPECIFIED":    0,
		"HANDSHAKECOMMAND_SESSION_CANCEL": 1,
	}
)

Enum value maps for HANDSHAKECOMMAND.

var File_worker_proxy_v1_proxy_proto protoreflect.FileDescriptor

Types

type ClientHandshake

type ClientHandshake struct {
	TofuToken string           `protobuf:"bytes,10,opt,name=tofu_token,json=tofuToken,proto3" json:"tofu_token,omitempty"`
	Command   HANDSHAKECOMMAND `protobuf:"varint,20,opt,name=command,proto3,enum=worker.proxy.v1.HANDSHAKECOMMAND" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientHandshake) Descriptor

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

Deprecated: Use ClientHandshake.ProtoReflect.Descriptor instead.

func (*ClientHandshake) GetCommand

func (x *ClientHandshake) GetCommand() HANDSHAKECOMMAND

func (*ClientHandshake) GetTofuToken

func (x *ClientHandshake) GetTofuToken() string

func (*ClientHandshake) ProtoMessage

func (*ClientHandshake) ProtoMessage()

func (*ClientHandshake) ProtoReflect

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

func (*ClientHandshake) Reset

func (x *ClientHandshake) Reset()

func (*ClientHandshake) String

func (x *ClientHandshake) String() string

type HANDSHAKECOMMAND

type HANDSHAKECOMMAND int32

const (
	// Note: Unspecified is the desired zero value based on protolint, but for
	// our purposes it simply means a normal connection.
	HANDSHAKECOMMAND_HANDSHAKECOMMAND_UNSPECIFIED    HANDSHAKECOMMAND = 0
	HANDSHAKECOMMAND_HANDSHAKECOMMAND_SESSION_CANCEL HANDSHAKECOMMAND = 1
)

func (HANDSHAKECOMMAND) Descriptor

func (HANDSHAKECOMMAND) Descriptor() protoreflect.EnumDescriptor

func (HANDSHAKECOMMAND) Enum

func (x HANDSHAKECOMMAND) Enum() *HANDSHAKECOMMAND

func (HANDSHAKECOMMAND) EnumDescriptor

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

Deprecated: Use HANDSHAKECOMMAND.Descriptor instead.

func (HANDSHAKECOMMAND) Number

func (x HANDSHAKECOMMAND) Number() protoreflect.EnumNumber

func (HANDSHAKECOMMAND) String

func (x HANDSHAKECOMMAND) String() string

func (HANDSHAKECOMMAND) Type

func (HANDSHAKECOMMAND) Type() protoreflect.EnumType

type HandshakeResult

type HandshakeResult struct {
	Expiration      *timestamp.Timestamp `protobuf:"bytes,10,opt,name=expiration,proto3" json:"expiration,omitempty"`
	ConnectionLimit int32                `protobuf:"varint,20,opt,name=connection_limit,json=connectionLimit,proto3" json:"connection_limit,omitempty"`
	ConnectionsLeft int32                `protobuf:"varint,30,opt,name=connections_left,json=connectionsLeft,proto3" json:"connections_left,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakeResult) Descriptor

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

Deprecated: Use HandshakeResult.ProtoReflect.Descriptor instead.

func (*HandshakeResult) GetConnectionLimit

func (x *HandshakeResult) GetConnectionLimit() int32

func (*HandshakeResult) GetConnectionsLeft

func (x *HandshakeResult) GetConnectionsLeft() int32

func (*HandshakeResult) GetExpiration

func (x *HandshakeResult) GetExpiration() *timestamp.Timestamp

func (*HandshakeResult) ProtoMessage

func (*HandshakeResult) ProtoMessage()

func (*HandshakeResult) ProtoReflect

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

func (*HandshakeResult) Reset

func (x *HandshakeResult) Reset()

func (*HandshakeResult) String

func (x *HandshakeResult) String() string