protocol

package
v0.0.0-...-d687121 Latest Latest
Warning

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

 Go to latest Published: Apr 4, 2024 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const ClientQueryServicePathPrefix = "/twirp/protocol.ClientQueryService/"

ClientQueryServicePathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html

View Source 
const KVServicePathPrefix = "/twirp/protocol.KVService/"

KVServicePathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html

View Source 
const PKIServicePathPrefix = "/twirp/protocol.PKIService/"

PKIServicePathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html

View Source 
const TunnelServicePathPrefix = "/twirp/protocol.TunnelService/"

TunnelServicePathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html

View Source 
const VNodeServicePathPrefix = "/twirp/protocol.VNodeService/"

VNodeServicePathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html

Variables

View Source 
var (
	KeyComposite_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "SIMPLE",
		2: "PREFIX",
		3: "LEASE",
	}
	KeyComposite_Type_value = map[string]int32{
		"UNKNOWN": 0,
		"SIMPLE":  1,
		"PREFIX":  2,
		"LEASE":   3,
	}
)

Enum value maps for KeyComposite_Type.

View Source 
var (
	Context_TargetType_name = map[int32]string{
		0: "UNKNOWN",
		1: "KV_REPLICATION",
		2: "KV_DIRECT_TARGET",
	}
	Context_TargetType_value = map[string]int32{
		"UNKNOWN":          0,
		"KV_REPLICATION":   1,
		"KV_DIRECT_TARGET": 2,
	}
)

Enum value maps for Context_TargetType.

View Source 
var (
	Stream_Type_name = map[int32]string{
		0: "UNKNOWN_TYPE",
		1: "RPC",
		2: "DIRECT",
		3: "PROXY",
		4: "INTERNAL",
	}
	Stream_Type_value = map[string]int32{
		"UNKNOWN_TYPE": 0,
		"RPC":          1,
		"DIRECT":       2,
		"PROXY":        3,
		"INTERNAL":     4,
	}
)

Enum value maps for Stream_Type.

View Source 
var (
	Datagram_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "ALIVE",
		2: "DATA",
		3: "RTT_SYN",
		4: "RTT_ACK",
	}
	Datagram_Type_value = map[string]int32{
		"UNKNOWN": 0,
		"ALIVE":   1,
		"DATA":    2,
		"RTT_SYN": 3,
		"RTT_ACK": 4,
	}
)

Enum value maps for Datagram_Type.

View Source 
var (
	Connection_State_name = map[int32]string{
		0: "UNKNOWN_STATE",
		1: "CACHED",
		2: "FRESH",
	}
	Connection_State_value = map[string]int32{
		"UNKNOWN_STATE": 0,
		"CACHED":        1,
		"FRESH":         2,
	}
)

Enum value maps for Connection_State.

View Source 
var (
	Connection_Direction_name = map[int32]string{
		0: "UNKNOWN_DIRECTION",
		1: "INCOMING",
		2: "OUTGOING",
	}
	Connection_Direction_value = map[string]int32{
		"UNKNOWN_DIRECTION": 0,
		"INCOMING":          1,
		"OUTGOING":          2,
	}
)

Enum value maps for Connection_Direction.

View Source 
var (
	TunnelStatusCode_name = map[int32]string{
		0: "STATUS_OK",
		1: "UNKNOWN_ERROR",
		2: "NO_DIRECT",
	}
	TunnelStatusCode_value = map[string]int32{
		"STATUS_OK":     0,
		"UNKNOWN_ERROR": 1,
		"NO_DIRECT":     2,
	}
)

Enum value maps for TunnelStatusCode.

View Source 
var (
	Link_ALPN_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "SPECTER_CHORD",
		2:  "SPECTER_CLIENT",
		9:  "HTTP2",
		10: "HTTP",
		11: "TCP",
	}
	Link_ALPN_value = map[string]int32{
		"UNKNOWN":        0,
		"SPECTER_CHORD":  1,
		"SPECTER_CLIENT": 2,
		"HTTP2":          9,
		"HTTP":           10,
		"TCP":            11,
	}
)

Enum value maps for Link_ALPN.

View Source 
var (
	// optional string alpn_name = 54242;
	E_AlpnName = &file_spec_proto_tunnel_proto_extTypes[0]
)

Extension fields to descriptorpb.EnumValueOptions.

View Source 
var File_spec_proto_chord_proto protoreflect.FileDescriptor
View Source 
var File_spec_proto_client_query_proto protoreflect.FileDescriptor
View Source 
var File_spec_proto_kv_proto protoreflect.FileDescriptor
View Source 
var File_spec_proto_node_proto protoreflect.FileDescriptor
View Source 
var File_spec_proto_pki_proto protoreflect.FileDescriptor
View Source 
var File_spec_proto_pow_proto protoreflect.FileDescriptor
View Source 
var File_spec_proto_rpc_proto protoreflect.FileDescriptor
View Source 
var File_spec_proto_transport_proto protoreflect.FileDescriptor
View Source 
var File_spec_proto_tunnel_proto protoreflect.FileDescriptor

Functions

func WriteError 

func WriteError(resp http.ResponseWriter, err error)

WriteError writes an HTTP response with a valid Twirp error format (code, msg, meta). Useful outside of the Twirp server (e.g. http middleware), but does not trigger hooks. If err is not a twirp.Error, it will get wrapped with twirp.InternalErrorWith(err)

Types

type CertificateRequest 

type CertificateRequest struct {
	Proof *ProofOfWork `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*CertificateRequest) Descriptor deprecated 

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

Deprecated: Use CertificateRequest.ProtoReflect.Descriptor instead.

func (*CertificateRequest) GetProof 

func (x *CertificateRequest) GetProof() *ProofOfWork

func (*CertificateRequest) MarshalToSizedBufferVT 

func (m *CertificateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CertificateRequest) MarshalToVT 

func (m *CertificateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CertificateRequest) MarshalVT 

func (m *CertificateRequest) MarshalVT() (dAtA []byte, err error)

func (*CertificateRequest) ProtoMessage 

func (*CertificateRequest) ProtoMessage()

func (*CertificateRequest) ProtoReflect 

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

func (*CertificateRequest) Reset 

func (x *CertificateRequest) Reset()

func (*CertificateRequest) SizeVT 

func (m *CertificateRequest) SizeVT() (n int)

func (*CertificateRequest) String 

func (x *CertificateRequest) String() string

func (*CertificateRequest) UnmarshalVT 

func (m *CertificateRequest) UnmarshalVT(dAtA []byte) error

type CertificateResponse 

type CertificateResponse struct {
	CertDer []byte `protobuf:"bytes,1,opt,name=cert_der,json=certDer,proto3" json:"cert_der,omitempty"`
	CertPem []byte `protobuf:"bytes,2,opt,name=cert_pem,json=certPem,proto3" json:"cert_pem,omitempty"`
	// contains filtered or unexported fields
}

func (*CertificateResponse) Descriptor deprecated 

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

Deprecated: Use CertificateResponse.ProtoReflect.Descriptor instead.

func (*CertificateResponse) GetCertDer 

func (x *CertificateResponse) GetCertDer() []byte

func (*CertificateResponse) GetCertPem 

func (x *CertificateResponse) GetCertPem() []byte

func (*CertificateResponse) MarshalToSizedBufferVT 

func (m *CertificateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CertificateResponse) MarshalToVT 

func (m *CertificateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CertificateResponse) MarshalVT 

func (m *CertificateResponse) MarshalVT() (dAtA []byte, err error)

func (*CertificateResponse) ProtoMessage 

func (*CertificateResponse) ProtoMessage()

func (*CertificateResponse) ProtoReflect 

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

func (*CertificateResponse) Reset 

func (x *CertificateResponse) Reset()

func (*CertificateResponse) SizeVT 

func (m *CertificateResponse) SizeVT() (n int)

func (*CertificateResponse) String 

func (x *CertificateResponse) String() string

func (*CertificateResponse) UnmarshalVT 

func (m *CertificateResponse) UnmarshalVT(dAtA []byte) error

type ClientPingRequest 

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

func (*ClientPingRequest) Descriptor deprecated 

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

Deprecated: Use ClientPingRequest.ProtoReflect.Descriptor instead.

func (*ClientPingRequest) MarshalToSizedBufferVT 

func (m *ClientPingRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClientPingRequest) MarshalToVT 

func (m *ClientPingRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ClientPingRequest) MarshalVT 

func (m *ClientPingRequest) MarshalVT() (dAtA []byte, err error)

func (*ClientPingRequest) ProtoMessage 

func (*ClientPingRequest) ProtoMessage()

func (*ClientPingRequest) ProtoReflect 

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

func (*ClientPingRequest) Reset 

func (x *ClientPingRequest) Reset()

func (*ClientPingRequest) SizeVT 

func (m *ClientPingRequest) SizeVT() (n int)

func (*ClientPingRequest) String 

func (x *ClientPingRequest) String() string

func (*ClientPingRequest) UnmarshalVT 

func (m *ClientPingRequest) UnmarshalVT(dAtA []byte) error

type ClientPingResponse 

type ClientPingResponse struct {
	Node *Node  `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Apex string `protobuf:"bytes,2,opt,name=apex,proto3" json:"apex,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientPingResponse) Descriptor deprecated 

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

Deprecated: Use ClientPingResponse.ProtoReflect.Descriptor instead.

func (*ClientPingResponse) GetApex 

func (x *ClientPingResponse) GetApex() string

func (*ClientPingResponse) GetNode 

func (x *ClientPingResponse) GetNode() *Node

func (*ClientPingResponse) MarshalToSizedBufferVT 

func (m *ClientPingResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClientPingResponse) MarshalToVT 

func (m *ClientPingResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ClientPingResponse) MarshalVT 

func (m *ClientPingResponse) MarshalVT() (dAtA []byte, err error)

func (*ClientPingResponse) ProtoMessage 

func (*ClientPingResponse) ProtoMessage()

func (*ClientPingResponse) ProtoReflect 

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

func (*ClientPingResponse) Reset 

func (x *ClientPingResponse) Reset()

func (*ClientPingResponse) SizeVT 

func (m *ClientPingResponse) SizeVT() (n int)

func (*ClientPingResponse) String 

func (x *ClientPingResponse) String() string

func (*ClientPingResponse) UnmarshalVT 

func (m *ClientPingResponse) UnmarshalVT(dAtA []byte) error

type ClientQueryService 

type ClientQueryService interface {
	ListTunnels(context.Context, *ListTunnelsRequest) (*ListTunnelsResponse, error)
}

func NewClientQueryServiceJSONClient 

func NewClientQueryServiceJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) ClientQueryService

NewClientQueryServiceJSONClient creates a JSON client that implements the ClientQueryService interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewClientQueryServiceProtobufClient 

func NewClientQueryServiceProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) ClientQueryService

NewClientQueryServiceProtobufClient creates a Protobuf client that implements the ClientQueryService interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type ClientToken 

type ClientToken struct {
	Token []byte `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientToken) Descriptor deprecated 

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

Deprecated: Use ClientToken.ProtoReflect.Descriptor instead.

func (*ClientToken) GetToken 

func (x *ClientToken) GetToken() []byte

func (*ClientToken) MarshalToSizedBufferVT 

func (m *ClientToken) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClientToken) MarshalToVT 

func (m *ClientToken) MarshalToVT(dAtA []byte) (int, error)

func (*ClientToken) MarshalVT 

func (m *ClientToken) MarshalVT() (dAtA []byte, err error)

func (*ClientToken) ProtoMessage 

func (*ClientToken) ProtoMessage()

func (*ClientToken) ProtoReflect 

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

func (*ClientToken) Reset 

func (x *ClientToken) Reset()

func (*ClientToken) SizeVT 

func (m *ClientToken) SizeVT() (n int)

func (*ClientToken) String 

func (x *ClientToken) String() string

func (*ClientToken) UnmarshalVT 

func (m *ClientToken) UnmarshalVT(dAtA []byte) error

type ClientTunnel 

type ClientTunnel struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Target   string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientTunnel) Descriptor deprecated 

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

Deprecated: Use ClientTunnel.ProtoReflect.Descriptor instead.

func (*ClientTunnel) GetHostname 

func (x *ClientTunnel) GetHostname() string

func (*ClientTunnel) GetTarget 

func (x *ClientTunnel) GetTarget() string

func (*ClientTunnel) MarshalToSizedBufferVT 

func (m *ClientTunnel) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClientTunnel) MarshalToVT 

func (m *ClientTunnel) MarshalToVT(dAtA []byte) (int, error)

func (*ClientTunnel) MarshalVT 

func (m *ClientTunnel) MarshalVT() (dAtA []byte, err error)

func (*ClientTunnel) ProtoMessage 

func (*ClientTunnel) ProtoMessage()

func (*ClientTunnel) ProtoReflect 

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

func (*ClientTunnel) Reset 

func (x *ClientTunnel) Reset()

func (*ClientTunnel) SizeVT 

func (m *ClientTunnel) SizeVT() (n int)

func (*ClientTunnel) String 

func (x *ClientTunnel) String() string

func (*ClientTunnel) UnmarshalVT 

func (m *ClientTunnel) UnmarshalVT(dAtA []byte) error

type Connection 

type Connection struct {
	Identity       *Node                `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	CacheState     Connection_State     `protobuf:"varint,2,opt,name=cache_state,json=cacheState,proto3,enum=protocol.Connection_State" json:"cache_state,omitempty"`
	CacheDirection Connection_Direction `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Connection) Descriptor deprecated 

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

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetCacheDirection 

func (x *Connection) GetCacheDirection() Connection_Direction

func (*Connection) GetCacheState 

func (x *Connection) GetCacheState() Connection_State

func (*Connection) GetIdentity 

func (x *Connection) GetIdentity() *Node

func (*Connection) MarshalToSizedBufferVT 

func (m *Connection) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Connection) MarshalToVT 

func (m *Connection) MarshalToVT(dAtA []byte) (int, error)

func (*Connection) MarshalVT 

func (m *Connection) MarshalVT() (dAtA []byte, err error)

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect 

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

func (*Connection) Reset 

func (x *Connection) Reset()

func (*Connection) SizeVT 

func (m *Connection) SizeVT() (n int)

func (*Connection) String 

func (x *Connection) String() string

func (*Connection) UnmarshalVT 

func (m *Connection) UnmarshalVT(dAtA []byte) error

type Connection_Direction 

type Connection_Direction int32
const (
	Connection_UNKNOWN_DIRECTION Connection_Direction = 0
	Connection_INCOMING          Connection_Direction = 1
	Connection_OUTGOING          Connection_Direction = 2
)

func (Connection_Direction) Descriptor 

func (Connection_Direction) Descriptor() protoreflect.EnumDescriptor

func (Connection_Direction) Enum 

func (x Connection_Direction) Enum() *Connection_Direction

func (Connection_Direction) EnumDescriptor deprecated 

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

Deprecated: Use Connection_Direction.Descriptor instead.

func (Connection_Direction) Number 

func (x Connection_Direction) Number() protoreflect.EnumNumber

func (Connection_Direction) String 

func (x Connection_Direction) String() string

func (Connection_Direction) Type 

func (Connection_Direction) Type() protoreflect.EnumType

type Connection_State 

type Connection_State int32
const (
	Connection_UNKNOWN_STATE Connection_State = 0
	Connection_CACHED        Connection_State = 1
	Connection_FRESH         Connection_State = 2
)

func (Connection_State) Descriptor 

func (Connection_State) Descriptor() protoreflect.EnumDescriptor

func (Connection_State) Enum 

func (x Connection_State) Enum() *Connection_State

func (Connection_State) EnumDescriptor deprecated 

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

Deprecated: Use Connection_State.Descriptor instead.

func (Connection_State) Number 

func (x Connection_State) Number() protoreflect.EnumNumber

func (Connection_State) String 

func (x Connection_State) String() string

func (Connection_State) Type 

func (Connection_State) Type() protoreflect.EnumType

type Context 

type Context struct {
	RequestTarget Context_TargetType `protobuf:"varint,1,opt,name=requestTarget,proto3,enum=protocol.Context_TargetType" json:"requestTarget,omitempty"`
	// contains filtered or unexported fields
}

func (*Context) Descriptor deprecated 

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

Deprecated: Use Context.ProtoReflect.Descriptor instead.

func (*Context) GetRequestTarget 

func (x *Context) GetRequestTarget() Context_TargetType

func (*Context) MarshalToSizedBufferVT 

func (m *Context) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Context) MarshalToVT 

func (m *Context) MarshalToVT(dAtA []byte) (int, error)

func (*Context) MarshalVT 

func (m *Context) MarshalVT() (dAtA []byte, err error)

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) ProtoReflect 

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

func (*Context) Reset 

func (x *Context) Reset()

func (*Context) SizeVT 

func (m *Context) SizeVT() (n int)

func (*Context) String 

func (x *Context) String() string

func (*Context) UnmarshalVT 

func (m *Context) UnmarshalVT(dAtA []byte) error

type Context_TargetType 

type Context_TargetType int32
const (
	Context_UNKNOWN          Context_TargetType = 0
	Context_KV_REPLICATION   Context_TargetType = 1
	Context_KV_DIRECT_TARGET Context_TargetType = 2
)

func (Context_TargetType) Descriptor 

func (Context_TargetType) Descriptor() protoreflect.EnumDescriptor

func (Context_TargetType) Enum 

func (x Context_TargetType) Enum() *Context_TargetType

func (Context_TargetType) EnumDescriptor deprecated 

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

Deprecated: Use Context_TargetType.Descriptor instead.

func (Context_TargetType) Number 

func (x Context_TargetType) Number() protoreflect.EnumNumber

func (Context_TargetType) String 

func (x Context_TargetType) String() string

func (Context_TargetType) Type 

func (Context_TargetType) Type() protoreflect.EnumType

type CustomHostname 

type CustomHostname struct {
	ClientIdentity *Node        `protobuf:"bytes,1,opt,name=client_identity,json=clientIdentity,proto3" json:"client_identity,omitempty"`
	ClientToken    *ClientToken `protobuf:"bytes,2,opt,name=client_token,json=clientToken,proto3" json:"client_token,omitempty"`
	// contains filtered or unexported fields
}

func (*CustomHostname) Descriptor deprecated 

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

Deprecated: Use CustomHostname.ProtoReflect.Descriptor instead.

func (*CustomHostname) GetClientIdentity 

func (x *CustomHostname) GetClientIdentity() *Node

func (*CustomHostname) GetClientToken 

func (x *CustomHostname) GetClientToken() *ClientToken

func (*CustomHostname) MarshalToSizedBufferVT 

func (m *CustomHostname) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CustomHostname) MarshalToVT 

func (m *CustomHostname) MarshalToVT(dAtA []byte) (int, error)

func (*CustomHostname) MarshalVT 

func (m *CustomHostname) MarshalVT() (dAtA []byte, err error)

func (*CustomHostname) ProtoMessage 

func (*CustomHostname) ProtoMessage()

func (*CustomHostname) ProtoReflect 

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

func (*CustomHostname) Reset 

func (x *CustomHostname) Reset()

func (*CustomHostname) SizeVT 

func (m *CustomHostname) SizeVT() (n int)

func (*CustomHostname) String 

func (x *CustomHostname) String() string

func (*CustomHostname) UnmarshalVT 

func (m *CustomHostname) UnmarshalVT(dAtA []byte) error

type Datagram 

type Datagram struct {
	Type Datagram_Type `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.Datagram_Type" json:"type,omitempty"`
	Data []byte        `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Datagram) Descriptor deprecated 

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

Deprecated: Use Datagram.ProtoReflect.Descriptor instead.

func (*Datagram) GetData 

func (x *Datagram) GetData() []byte

func (*Datagram) GetType 

func (x *Datagram) GetType() Datagram_Type

func (*Datagram) MarshalToSizedBufferVT 

func (m *Datagram) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Datagram) MarshalToVT 

func (m *Datagram) MarshalToVT(dAtA []byte) (int, error)

func (*Datagram) MarshalVT 

func (m *Datagram) MarshalVT() (dAtA []byte, err error)

func (*Datagram) ProtoMessage 

func (*Datagram) ProtoMessage()

func (*Datagram) ProtoReflect 

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

func (*Datagram) Reset 

func (x *Datagram) Reset()

func (*Datagram) SizeVT 

func (m *Datagram) SizeVT() (n int)

func (*Datagram) String 

func (x *Datagram) String() string

func (*Datagram) UnmarshalVT 

func (m *Datagram) UnmarshalVT(dAtA []byte) error

type Datagram_Type 

type Datagram_Type int32
const (
	Datagram_UNKNOWN Datagram_Type = 0
	Datagram_ALIVE   Datagram_Type = 1
	Datagram_DATA    Datagram_Type = 2
	Datagram_RTT_SYN Datagram_Type = 3
	Datagram_RTT_ACK Datagram_Type = 4
)

func (Datagram_Type) Descriptor 

func (Datagram_Type) Descriptor() protoreflect.EnumDescriptor

func (Datagram_Type) Enum 

func (x Datagram_Type) Enum() *Datagram_Type

func (Datagram_Type) EnumDescriptor deprecated 

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

Deprecated: Use Datagram_Type.Descriptor instead.

func (Datagram_Type) Number 

func (x Datagram_Type) Number() protoreflect.EnumNumber

func (Datagram_Type) String 

func (x Datagram_Type) String() string

func (Datagram_Type) Type 

func (Datagram_Type) Type() protoreflect.EnumType

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) MarshalToSizedBufferVT 

func (m *Empty) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Empty) MarshalToVT 

func (m *Empty) MarshalToVT(dAtA []byte) (int, error)

func (*Empty) MarshalVT 

func (m *Empty) MarshalVT() (dAtA []byte, err error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) SizeVT 

func (m *Empty) SizeVT() (n int)

func (*Empty) String 

func (x *Empty) String() string

func (*Empty) UnmarshalVT 

func (m *Empty) UnmarshalVT(dAtA []byte) error

type FindSuccessorRequest 

type FindSuccessorRequest struct {
	Key uint64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*FindSuccessorRequest) Descriptor deprecated 

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

Deprecated: Use FindSuccessorRequest.ProtoReflect.Descriptor instead.

func (*FindSuccessorRequest) GetKey 

func (x *FindSuccessorRequest) GetKey() uint64

func (*FindSuccessorRequest) MarshalToSizedBufferVT 

func (m *FindSuccessorRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FindSuccessorRequest) MarshalToVT 

func (m *FindSuccessorRequest) MarshalToVT(dAtA []byte) (int, error)

func (*FindSuccessorRequest) MarshalVT 

func (m *FindSuccessorRequest) MarshalVT() (dAtA []byte, err error)

func (*FindSuccessorRequest) ProtoMessage 

func (*FindSuccessorRequest) ProtoMessage()

func (*FindSuccessorRequest) ProtoReflect 

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

func (*FindSuccessorRequest) Reset 

func (x *FindSuccessorRequest) Reset()

func (*FindSuccessorRequest) SizeVT 

func (m *FindSuccessorRequest) SizeVT() (n int)

func (*FindSuccessorRequest) String 

func (x *FindSuccessorRequest) String() string

func (*FindSuccessorRequest) UnmarshalVT 

func (m *FindSuccessorRequest) UnmarshalVT(dAtA []byte) error

type FindSuccessorResponse 

type FindSuccessorResponse struct {
	Successor *Node `protobuf:"bytes,1,opt,name=successor,proto3" json:"successor,omitempty"`
	// contains filtered or unexported fields
}

func (*FindSuccessorResponse) Descriptor deprecated 

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

Deprecated: Use FindSuccessorResponse.ProtoReflect.Descriptor instead.

func (*FindSuccessorResponse) GetSuccessor 

func (x *FindSuccessorResponse) GetSuccessor() *Node

func (*FindSuccessorResponse) MarshalToSizedBufferVT 

func (m *FindSuccessorResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FindSuccessorResponse) MarshalToVT 

func (m *FindSuccessorResponse) MarshalToVT(dAtA []byte) (int, error)

func (*FindSuccessorResponse) MarshalVT 

func (m *FindSuccessorResponse) MarshalVT() (dAtA []byte, err error)

func (*FindSuccessorResponse) ProtoMessage 

func (*FindSuccessorResponse) ProtoMessage()

func (*FindSuccessorResponse) ProtoReflect 

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

func (*FindSuccessorResponse) Reset 

func (x *FindSuccessorResponse) Reset()

func (*FindSuccessorResponse) SizeVT 

func (m *FindSuccessorResponse) SizeVT() (n int)

func (*FindSuccessorResponse) String 

func (x *FindSuccessorResponse) String() string

func (*FindSuccessorResponse) UnmarshalVT 

func (m *FindSuccessorResponse) UnmarshalVT(dAtA []byte) error

type GenerateHostnameRequest 

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

func (*GenerateHostnameRequest) Descriptor deprecated 

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

Deprecated: Use GenerateHostnameRequest.ProtoReflect.Descriptor instead.

func (*GenerateHostnameRequest) MarshalToSizedBufferVT 

func (m *GenerateHostnameRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GenerateHostnameRequest) MarshalToVT 

func (m *GenerateHostnameRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GenerateHostnameRequest) MarshalVT 

func (m *GenerateHostnameRequest) MarshalVT() (dAtA []byte, err error)

func (*GenerateHostnameRequest) ProtoMessage 

func (*GenerateHostnameRequest) ProtoMessage()

func (*GenerateHostnameRequest) ProtoReflect 

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

func (*GenerateHostnameRequest) Reset 

func (x *GenerateHostnameRequest) Reset()

func (*GenerateHostnameRequest) SizeVT 

func (m *GenerateHostnameRequest) SizeVT() (n int)

func (*GenerateHostnameRequest) String 

func (x *GenerateHostnameRequest) String() string

func (*GenerateHostnameRequest) UnmarshalVT 

func (m *GenerateHostnameRequest) UnmarshalVT(dAtA []byte) error

type GenerateHostnameResponse 

type GenerateHostnameResponse struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateHostnameResponse) Descriptor deprecated 

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

Deprecated: Use GenerateHostnameResponse.ProtoReflect.Descriptor instead.

func (*GenerateHostnameResponse) GetHostname 

func (x *GenerateHostnameResponse) GetHostname() string

func (*GenerateHostnameResponse) MarshalToSizedBufferVT 

func (m *GenerateHostnameResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GenerateHostnameResponse) MarshalToVT 

func (m *GenerateHostnameResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GenerateHostnameResponse) MarshalVT 

func (m *GenerateHostnameResponse) MarshalVT() (dAtA []byte, err error)

func (*GenerateHostnameResponse) ProtoMessage 

func (*GenerateHostnameResponse) ProtoMessage()

func (*GenerateHostnameResponse) ProtoReflect 

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

func (*GenerateHostnameResponse) Reset 

func (x *GenerateHostnameResponse) Reset()

func (*GenerateHostnameResponse) SizeVT 

func (m *GenerateHostnameResponse) SizeVT() (n int)

func (*GenerateHostnameResponse) String 

func (x *GenerateHostnameResponse) String() string

func (*GenerateHostnameResponse) UnmarshalVT 

func (m *GenerateHostnameResponse) UnmarshalVT(dAtA []byte) error

type GetNodesRequest 

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

func (*GetNodesRequest) Descriptor deprecated 

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

Deprecated: Use GetNodesRequest.ProtoReflect.Descriptor instead.

func (*GetNodesRequest) MarshalToSizedBufferVT 

func (m *GetNodesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetNodesRequest) MarshalToVT 

func (m *GetNodesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetNodesRequest) MarshalVT 

func (m *GetNodesRequest) MarshalVT() (dAtA []byte, err error)

func (*GetNodesRequest) ProtoMessage 

func (*GetNodesRequest) ProtoMessage()

func (*GetNodesRequest) ProtoReflect 

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

func (*GetNodesRequest) Reset 

func (x *GetNodesRequest) Reset()

func (*GetNodesRequest) SizeVT 

func (m *GetNodesRequest) SizeVT() (n int)

func (*GetNodesRequest) String 

func (x *GetNodesRequest) String() string

func (*GetNodesRequest) UnmarshalVT 

func (m *GetNodesRequest) UnmarshalVT(dAtA []byte) error

type GetNodesResponse 

type GetNodesResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodesResponse) Descriptor deprecated 

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

Deprecated: Use GetNodesResponse.ProtoReflect.Descriptor instead.

func (*GetNodesResponse) GetNodes 

func (x *GetNodesResponse) GetNodes() []*Node

func (*GetNodesResponse) MarshalToSizedBufferVT 

func (m *GetNodesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetNodesResponse) MarshalToVT 

func (m *GetNodesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetNodesResponse) MarshalVT 

func (m *GetNodesResponse) MarshalVT() (dAtA []byte, err error)

func (*GetNodesResponse) ProtoMessage 

func (*GetNodesResponse) ProtoMessage()

func (*GetNodesResponse) ProtoReflect 

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

func (*GetNodesResponse) Reset 

func (x *GetNodesResponse) Reset()

func (*GetNodesResponse) SizeVT 

func (m *GetNodesResponse) SizeVT() (n int)

func (*GetNodesResponse) String 

func (x *GetNodesResponse) String() string

func (*GetNodesResponse) UnmarshalVT 

func (m *GetNodesResponse) UnmarshalVT(dAtA []byte) error

type GetPredecessorRequest 

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

func (*GetPredecessorRequest) Descriptor deprecated 

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

Deprecated: Use GetPredecessorRequest.ProtoReflect.Descriptor instead.

func (*GetPredecessorRequest) MarshalToSizedBufferVT 

func (m *GetPredecessorRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetPredecessorRequest) MarshalToVT 

func (m *GetPredecessorRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetPredecessorRequest) MarshalVT 

func (m *GetPredecessorRequest) MarshalVT() (dAtA []byte, err error)

func (*GetPredecessorRequest) ProtoMessage 

func (*GetPredecessorRequest) ProtoMessage()

func (*GetPredecessorRequest) ProtoReflect 

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

func (*GetPredecessorRequest) Reset 

func (x *GetPredecessorRequest) Reset()

func (*GetPredecessorRequest) SizeVT 

func (m *GetPredecessorRequest) SizeVT() (n int)

func (*GetPredecessorRequest) String 

func (x *GetPredecessorRequest) String() string

func (*GetPredecessorRequest) UnmarshalVT 

func (m *GetPredecessorRequest) UnmarshalVT(dAtA []byte) error

type GetPredecessorResponse 

type GetPredecessorResponse struct {
	Predecessor *Node `protobuf:"bytes,1,opt,name=predecessor,proto3" json:"predecessor,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPredecessorResponse) Descriptor deprecated 

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

Deprecated: Use GetPredecessorResponse.ProtoReflect.Descriptor instead.

func (*GetPredecessorResponse) GetPredecessor 

func (x *GetPredecessorResponse) GetPredecessor() *Node

func (*GetPredecessorResponse) MarshalToSizedBufferVT 

func (m *GetPredecessorResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetPredecessorResponse) MarshalToVT 

func (m *GetPredecessorResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetPredecessorResponse) MarshalVT 

func (m *GetPredecessorResponse) MarshalVT() (dAtA []byte, err error)

func (*GetPredecessorResponse) ProtoMessage 

func (*GetPredecessorResponse) ProtoMessage()

func (*GetPredecessorResponse) ProtoReflect 

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

func (*GetPredecessorResponse) Reset 

func (x *GetPredecessorResponse) Reset()

func (*GetPredecessorResponse) SizeVT 

func (m *GetPredecessorResponse) SizeVT() (n int)

func (*GetPredecessorResponse) String 

func (x *GetPredecessorResponse) String() string

func (*GetPredecessorResponse) UnmarshalVT 

func (m *GetPredecessorResponse) UnmarshalVT(dAtA []byte) error

type GetSuccessorsRequest 

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

func (*GetSuccessorsRequest) Descriptor deprecated 

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

Deprecated: Use GetSuccessorsRequest.ProtoReflect.Descriptor instead.

func (*GetSuccessorsRequest) MarshalToSizedBufferVT 

func (m *GetSuccessorsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetSuccessorsRequest) MarshalToVT 

func (m *GetSuccessorsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetSuccessorsRequest) MarshalVT 

func (m *GetSuccessorsRequest) MarshalVT() (dAtA []byte, err error)

func (*GetSuccessorsRequest) ProtoMessage 

func (*GetSuccessorsRequest) ProtoMessage()

func (*GetSuccessorsRequest) ProtoReflect 

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

func (*GetSuccessorsRequest) Reset 

func (x *GetSuccessorsRequest) Reset()

func (*GetSuccessorsRequest) SizeVT 

func (m *GetSuccessorsRequest) SizeVT() (n int)

func (*GetSuccessorsRequest) String 

func (x *GetSuccessorsRequest) String() string

func (*GetSuccessorsRequest) UnmarshalVT 

func (m *GetSuccessorsRequest) UnmarshalVT(dAtA []byte) error

type GetSuccessorsResponse 

type GetSuccessorsResponse struct {
	Successors []*Node `protobuf:"bytes,1,rep,name=successors,proto3" json:"successors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSuccessorsResponse) Descriptor deprecated 

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

Deprecated: Use GetSuccessorsResponse.ProtoReflect.Descriptor instead.

func (*GetSuccessorsResponse) GetSuccessors 

func (x *GetSuccessorsResponse) GetSuccessors() []*Node

func (*GetSuccessorsResponse) MarshalToSizedBufferVT 

func (m *GetSuccessorsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetSuccessorsResponse) MarshalToVT 

func (m *GetSuccessorsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetSuccessorsResponse) MarshalVT 

func (m *GetSuccessorsResponse) MarshalVT() (dAtA []byte, err error)

func (*GetSuccessorsResponse) ProtoMessage 

func (*GetSuccessorsResponse) ProtoMessage()

func (*GetSuccessorsResponse) ProtoReflect 

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

func (*GetSuccessorsResponse) Reset 

func (x *GetSuccessorsResponse) Reset()

func (*GetSuccessorsResponse) SizeVT 

func (m *GetSuccessorsResponse) SizeVT() (n int)

func (*GetSuccessorsResponse) String 

func (x *GetSuccessorsResponse) String() string

func (*GetSuccessorsResponse) UnmarshalVT 

func (m *GetSuccessorsResponse) UnmarshalVT(dAtA []byte) error

type HTTPClient 

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient is the interface used by generated clients to send HTTP requests. It is fulfilled by *(net/http).Client, which is sufficient for most users. Users can provide their own implementation for special retry policies.

HTTPClient implementations should not follow redirects. Redirects are automatically disabled if *(net/http).Client is passed to client constructors. See the withoutRedirects function in this file for more details.

type IdentityRequest 

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

func (*IdentityRequest) Descriptor deprecated 

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

Deprecated: Use IdentityRequest.ProtoReflect.Descriptor instead.

func (*IdentityRequest) MarshalToSizedBufferVT 

func (m *IdentityRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IdentityRequest) MarshalToVT 

func (m *IdentityRequest) MarshalToVT(dAtA []byte) (int, error)

func (*IdentityRequest) MarshalVT 

func (m *IdentityRequest) MarshalVT() (dAtA []byte, err error)

func (*IdentityRequest) ProtoMessage 

func (*IdentityRequest) ProtoMessage()

func (*IdentityRequest) ProtoReflect 

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

func (*IdentityRequest) Reset 

func (x *IdentityRequest) Reset()

func (*IdentityRequest) SizeVT 

func (m *IdentityRequest) SizeVT() (n int)

func (*IdentityRequest) String 

func (x *IdentityRequest) String() string

func (*IdentityRequest) UnmarshalVT 

func (m *IdentityRequest) UnmarshalVT(dAtA []byte) error

type IdentityResponse 

type IdentityResponse struct {
	Identity *Node `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

func (*IdentityResponse) Descriptor deprecated 

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

Deprecated: Use IdentityResponse.ProtoReflect.Descriptor instead.

func (*IdentityResponse) GetIdentity 

func (x *IdentityResponse) GetIdentity() *Node

func (*IdentityResponse) MarshalToSizedBufferVT 

func (m *IdentityResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IdentityResponse) MarshalToVT 

func (m *IdentityResponse) MarshalToVT(dAtA []byte) (int, error)

func (*IdentityResponse) MarshalVT 

func (m *IdentityResponse) MarshalVT() (dAtA []byte, err error)

func (*IdentityResponse) ProtoMessage 

func (*IdentityResponse) ProtoMessage()

func (*IdentityResponse) ProtoReflect 

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

func (*IdentityResponse) Reset 

func (x *IdentityResponse) Reset()

func (*IdentityResponse) SizeVT 

func (m *IdentityResponse) SizeVT() (n int)

func (*IdentityResponse) String 

func (x *IdentityResponse) String() string

func (*IdentityResponse) UnmarshalVT 

func (m *IdentityResponse) UnmarshalVT(dAtA []byte) error

type ImportRequest 

type ImportRequest struct {
	Keys   [][]byte      `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values []*KVTransfer `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportRequest) Descriptor deprecated 

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

Deprecated: Use ImportRequest.ProtoReflect.Descriptor instead.

func (*ImportRequest) GetKeys 

func (x *ImportRequest) GetKeys() [][]byte

func (*ImportRequest) GetValues 

func (x *ImportRequest) GetValues() []*KVTransfer

func (*ImportRequest) MarshalToSizedBufferVT 

func (m *ImportRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ImportRequest) MarshalToVT 

func (m *ImportRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ImportRequest) MarshalVT 

func (m *ImportRequest) MarshalVT() (dAtA []byte, err error)

func (*ImportRequest) ProtoMessage 

func (*ImportRequest) ProtoMessage()

func (*ImportRequest) ProtoReflect 

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

func (*ImportRequest) Reset 

func (x *ImportRequest) Reset()

func (*ImportRequest) SizeVT 

func (m *ImportRequest) SizeVT() (n int)

func (*ImportRequest) String 

func (x *ImportRequest) String() string

func (*ImportRequest) UnmarshalVT 

func (m *ImportRequest) UnmarshalVT(dAtA []byte) error

type ImportResponse 

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

func (*ImportResponse) Descriptor deprecated 

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

Deprecated: Use ImportResponse.ProtoReflect.Descriptor instead.

func (*ImportResponse) MarshalToSizedBufferVT 

func (m *ImportResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ImportResponse) MarshalToVT 

func (m *ImportResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ImportResponse) MarshalVT 

func (m *ImportResponse) MarshalVT() (dAtA []byte, err error)

func (*ImportResponse) ProtoMessage 

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) ProtoReflect 

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

func (*ImportResponse) Reset 

func (x *ImportResponse) Reset()

func (*ImportResponse) SizeVT 

func (m *ImportResponse) SizeVT() (n int)

func (*ImportResponse) String 

func (x *ImportResponse) String() string

func (*ImportResponse) UnmarshalVT 

func (m *ImportResponse) UnmarshalVT(dAtA []byte) error

type InstructionRequest 

type InstructionRequest struct {
	Proof    *ProofOfWork `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	Hostname string       `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*InstructionRequest) Descriptor deprecated 

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

Deprecated: Use InstructionRequest.ProtoReflect.Descriptor instead.

func (*InstructionRequest) GetHostname 

func (x *InstructionRequest) GetHostname() string

func (*InstructionRequest) GetProof 

func (x *InstructionRequest) GetProof() *ProofOfWork

func (*InstructionRequest) MarshalToSizedBufferVT 

func (m *InstructionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InstructionRequest) MarshalToVT 

func (m *InstructionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*InstructionRequest) MarshalVT 

func (m *InstructionRequest) MarshalVT() (dAtA []byte, err error)

func (*InstructionRequest) ProtoMessage 

func (*InstructionRequest) ProtoMessage()

func (*InstructionRequest) ProtoReflect 

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

func (*InstructionRequest) Reset 

func (x *InstructionRequest) Reset()

func (*InstructionRequest) SizeVT 

func (m *InstructionRequest) SizeVT() (n int)

func (*InstructionRequest) String 

func (x *InstructionRequest) String() string

func (*InstructionRequest) UnmarshalVT 

func (m *InstructionRequest) UnmarshalVT(dAtA []byte) error

type InstructionResponse 

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

func (*InstructionResponse) Descriptor deprecated 

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

Deprecated: Use InstructionResponse.ProtoReflect.Descriptor instead.

func (*InstructionResponse) GetContent 

func (x *InstructionResponse) GetContent() string

func (*InstructionResponse) GetName 

func (x *InstructionResponse) GetName() string

func (*InstructionResponse) MarshalToSizedBufferVT 

func (m *InstructionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InstructionResponse) MarshalToVT 

func (m *InstructionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*InstructionResponse) MarshalVT 

func (m *InstructionResponse) MarshalVT() (dAtA []byte, err error)

func (*InstructionResponse) ProtoMessage 

func (*InstructionResponse) ProtoMessage()

func (*InstructionResponse) ProtoReflect 

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

func (*InstructionResponse) Reset 

func (x *InstructionResponse) Reset()

func (*InstructionResponse) SizeVT 

func (m *InstructionResponse) SizeVT() (n int)

func (*InstructionResponse) String 

func (x *InstructionResponse) String() string

func (*InstructionResponse) UnmarshalVT 

func (m *InstructionResponse) UnmarshalVT(dAtA []byte) error

type KVService 

type KVService interface {
	Put(context.Context, *SimpleRequest) (*SimpleResponse, error)

	Get(context.Context, *SimpleRequest) (*SimpleResponse, error)

	Delete(context.Context, *SimpleRequest) (*SimpleResponse, error)

	Append(context.Context, *PrefixRequest) (*PrefixResponse, error)

	List(context.Context, *PrefixRequest) (*PrefixResponse, error)

	Contains(context.Context, *PrefixRequest) (*PrefixResponse, error)

	Remove(context.Context, *PrefixRequest) (*PrefixResponse, error)

	Acquire(context.Context, *LeaseRequest) (*LeaseResponse, error)

	Renew(context.Context, *LeaseRequest) (*LeaseResponse, error)

	Release(context.Context, *LeaseRequest) (*LeaseResponse, error)

	Import(context.Context, *ImportRequest) (*ImportResponse, error)

	ListKeys(context.Context, *ListKeysRequest) (*ListKeysResponse, error)
}

func NewKVServiceJSONClient 

func NewKVServiceJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) KVService

NewKVServiceJSONClient creates a JSON client that implements the KVService interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewKVServiceProtobufClient 

func NewKVServiceProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) KVService

NewKVServiceProtobufClient creates a Protobuf client that implements the KVService interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type KVTransfer 

type KVTransfer struct {
	SimpleValue    []byte   `protobuf:"bytes,1,opt,name=simple_value,json=simpleValue,proto3" json:"simple_value,omitempty"`
	PrefixChildren [][]byte `protobuf:"bytes,2,rep,name=prefix_children,json=prefixChildren,proto3" json:"prefix_children,omitempty"`
	LeaseToken     uint64   `protobuf:"varint,3,opt,name=lease_token,json=leaseToken,proto3" json:"lease_token,omitempty"`
	// contains filtered or unexported fields
}

func (*KVTransfer) Descriptor deprecated 

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

Deprecated: Use KVTransfer.ProtoReflect.Descriptor instead.

func (*KVTransfer) GetLeaseToken 

func (x *KVTransfer) GetLeaseToken() uint64

func (*KVTransfer) GetPrefixChildren 

func (x *KVTransfer) GetPrefixChildren() [][]byte

func (*KVTransfer) GetSimpleValue 

func (x *KVTransfer) GetSimpleValue() []byte

func (*KVTransfer) MarshalToSizedBufferVT 

func (m *KVTransfer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KVTransfer) MarshalToVT 

func (m *KVTransfer) MarshalToVT(dAtA []byte) (int, error)

func (*KVTransfer) MarshalVT 

func (m *KVTransfer) MarshalVT() (dAtA []byte, err error)

func (*KVTransfer) ProtoMessage 

func (*KVTransfer) ProtoMessage()

func (*KVTransfer) ProtoReflect 

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

func (*KVTransfer) Reset 

func (x *KVTransfer) Reset()

func (*KVTransfer) SizeVT 

func (m *KVTransfer) SizeVT() (n int)

func (*KVTransfer) String 

func (x *KVTransfer) String() string

func (*KVTransfer) UnmarshalVT 

func (m *KVTransfer) UnmarshalVT(dAtA []byte) error

type KeyComposite 

type KeyComposite struct {
	Key  []byte            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Type KeyComposite_Type `protobuf:"varint,2,opt,name=type,proto3,enum=protocol.KeyComposite_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyComposite) Descriptor deprecated 

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

Deprecated: Use KeyComposite.ProtoReflect.Descriptor instead.

func (*KeyComposite) GetKey 

func (x *KeyComposite) GetKey() []byte

func (*KeyComposite) GetType 

func (x *KeyComposite) GetType() KeyComposite_Type

func (*KeyComposite) MarshalToSizedBufferVT 

func (m *KeyComposite) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyComposite) MarshalToVT 

func (m *KeyComposite) MarshalToVT(dAtA []byte) (int, error)

func (*KeyComposite) MarshalVT 

func (m *KeyComposite) MarshalVT() (dAtA []byte, err error)

func (*KeyComposite) ProtoMessage 

func (*KeyComposite) ProtoMessage()

func (*KeyComposite) ProtoReflect 

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

func (*KeyComposite) Reset 

func (x *KeyComposite) Reset()

func (*KeyComposite) SizeVT 

func (m *KeyComposite) SizeVT() (n int)

func (*KeyComposite) String 

func (x *KeyComposite) String() string

func (*KeyComposite) UnmarshalVT 

func (m *KeyComposite) UnmarshalVT(dAtA []byte) error

type KeyComposite_Type 

type KeyComposite_Type int32
const (
	KeyComposite_UNKNOWN KeyComposite_Type = 0
	KeyComposite_SIMPLE  KeyComposite_Type = 1
	KeyComposite_PREFIX  KeyComposite_Type = 2
	KeyComposite_LEASE   KeyComposite_Type = 3
)

func (KeyComposite_Type) Descriptor 

func (KeyComposite_Type) Descriptor() protoreflect.EnumDescriptor

func (KeyComposite_Type) Enum 

func (x KeyComposite_Type) Enum() *KeyComposite_Type

func (KeyComposite_Type) EnumDescriptor deprecated 

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

Deprecated: Use KeyComposite_Type.Descriptor instead.

func (KeyComposite_Type) Number 

func (x KeyComposite_Type) Number() protoreflect.EnumNumber

func (KeyComposite_Type) String 

func (x KeyComposite_Type) String() string

func (KeyComposite_Type) Type 

func (KeyComposite_Type) Type() protoreflect.EnumType

type LeaseRequest 

type LeaseRequest struct {
	Lease     []byte               `protobuf:"bytes,1,opt,name=lease,proto3" json:"lease,omitempty"`
	NewToken  uint64               `protobuf:"varint,2,opt,name=new_token,json=newToken,proto3" json:"new_token,omitempty"`
	PrevToken uint64               `protobuf:"varint,3,opt,name=prev_token,json=prevToken,proto3" json:"prev_token,omitempty"`
	Ttl       *durationpb.Duration `protobuf:"bytes,5,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaseRequest) Descriptor deprecated 

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

Deprecated: Use LeaseRequest.ProtoReflect.Descriptor instead.

func (*LeaseRequest) GetLease 

func (x *LeaseRequest) GetLease() []byte

func (*LeaseRequest) GetNewToken 

func (x *LeaseRequest) GetNewToken() uint64

func (*LeaseRequest) GetPrevToken 

func (x *LeaseRequest) GetPrevToken() uint64

func (*LeaseRequest) GetTtl 

func (x *LeaseRequest) GetTtl() *durationpb.Duration

func (*LeaseRequest) MarshalToSizedBufferVT 

func (m *LeaseRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LeaseRequest) MarshalToVT 

func (m *LeaseRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LeaseRequest) MarshalVT 

func (m *LeaseRequest) MarshalVT() (dAtA []byte, err error)

func (*LeaseRequest) ProtoMessage 

func (*LeaseRequest) ProtoMessage()

func (*LeaseRequest) ProtoReflect 

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

func (*LeaseRequest) Reset 

func (x *LeaseRequest) Reset()

func (*LeaseRequest) SizeVT 

func (m *LeaseRequest) SizeVT() (n int)

func (*LeaseRequest) String 

func (x *LeaseRequest) String() string

func (*LeaseRequest) UnmarshalVT 

func (m *LeaseRequest) UnmarshalVT(dAtA []byte) error

type LeaseResponse 

type LeaseResponse struct {
	Token uint64 `protobuf:"varint,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaseResponse) Descriptor deprecated 

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

Deprecated: Use LeaseResponse.ProtoReflect.Descriptor instead.

func (*LeaseResponse) GetToken 

func (x *LeaseResponse) GetToken() uint64

func (*LeaseResponse) MarshalToSizedBufferVT 

func (m *LeaseResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LeaseResponse) MarshalToVT 

func (m *LeaseResponse) MarshalToVT(dAtA []byte) (int, error)

func (*LeaseResponse) MarshalVT 

func (m *LeaseResponse) MarshalVT() (dAtA []byte, err error)

func (*LeaseResponse) ProtoMessage 

func (*LeaseResponse) ProtoMessage()

func (*LeaseResponse) ProtoReflect 

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

func (*LeaseResponse) Reset 

func (x *LeaseResponse) Reset()

func (*LeaseResponse) SizeVT 

func (m *LeaseResponse) SizeVT() (n int)

func (*LeaseResponse) String 

func (x *LeaseResponse) String() string

func (*LeaseResponse) UnmarshalVT 

func (m *LeaseResponse) UnmarshalVT(dAtA []byte) error
type Link struct {
	Alpn     Link_ALPN `protobuf:"varint,1,opt,name=alpn,proto3,enum=protocol.Link_ALPN" json:"alpn,omitempty"`
	Hostname string    `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Remote   string    `protobuf:"bytes,3,opt,name=remote,proto3" json:"remote,omitempty"`
	// contains filtered or unexported fields
}

func (*Link) Descriptor deprecated 

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

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (*Link) GetAlpn 

func (x *Link) GetAlpn() Link_ALPN

func (*Link) GetHostname 

func (x *Link) GetHostname() string

func (*Link) GetRemote 

func (x *Link) GetRemote() string

func (*Link) MarshalToSizedBufferVT 

func (m *Link) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Link) MarshalToVT 

func (m *Link) MarshalToVT(dAtA []byte) (int, error)

func (*Link) MarshalVT 

func (m *Link) MarshalVT() (dAtA []byte, err error)

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) ProtoReflect 

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

func (*Link) Reset 

func (x *Link) Reset()

func (*Link) SizeVT 

func (m *Link) SizeVT() (n int)

func (*Link) String 

func (x *Link) String() string

func (*Link) UnmarshalVT 

func (m *Link) UnmarshalVT(dAtA []byte) error
type Link_ALPN int32
const (
	Link_UNKNOWN        Link_ALPN = 0
	Link_SPECTER_CHORD  Link_ALPN = 1
	Link_SPECTER_CLIENT Link_ALPN = 2
	Link_HTTP2          Link_ALPN = 9
	Link_HTTP           Link_ALPN = 10
	Link_TCP            Link_ALPN = 11
)
func (Link_ALPN) Descriptor() protoreflect.EnumDescriptor
func (x Link_ALPN) Enum() *Link_ALPN
func (Link_ALPN) EnumDescriptor() ([]byte, []int)

Deprecated: Use Link_ALPN.Descriptor instead. 

func (x Link_ALPN) Number() protoreflect.EnumNumber
func (x Link_ALPN) String() string
func (Link_ALPN) Type() protoreflect.EnumType

type ListKeysRequest 

type ListKeysRequest struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKeysRequest) Descriptor deprecated 

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

Deprecated: Use ListKeysRequest.ProtoReflect.Descriptor instead.

func (*ListKeysRequest) GetPrefix 

func (x *ListKeysRequest) GetPrefix() []byte

func (*ListKeysRequest) MarshalToSizedBufferVT 

func (m *ListKeysRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListKeysRequest) MarshalToVT 

func (m *ListKeysRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ListKeysRequest) MarshalVT 

func (m *ListKeysRequest) MarshalVT() (dAtA []byte, err error)

func (*ListKeysRequest) ProtoMessage 

func (*ListKeysRequest) ProtoMessage()

func (*ListKeysRequest) ProtoReflect 

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

func (*ListKeysRequest) Reset 

func (x *ListKeysRequest) Reset()

func (*ListKeysRequest) SizeVT 

func (m *ListKeysRequest) SizeVT() (n int)

func (*ListKeysRequest) String 

func (x *ListKeysRequest) String() string

func (*ListKeysRequest) UnmarshalVT 

func (m *ListKeysRequest) UnmarshalVT(dAtA []byte) error

type ListKeysResponse 

type ListKeysResponse struct {
	Keys []*KeyComposite `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKeysResponse) Descriptor deprecated 

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

Deprecated: Use ListKeysResponse.ProtoReflect.Descriptor instead.

func (*ListKeysResponse) GetKeys 

func (x *ListKeysResponse) GetKeys() []*KeyComposite

func (*ListKeysResponse) MarshalToSizedBufferVT 

func (m *ListKeysResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListKeysResponse) MarshalToVT 

func (m *ListKeysResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListKeysResponse) MarshalVT 

func (m *ListKeysResponse) MarshalVT() (dAtA []byte, err error)

func (*ListKeysResponse) ProtoMessage 

func (*ListKeysResponse) ProtoMessage()

func (*ListKeysResponse) ProtoReflect 

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

func (*ListKeysResponse) Reset 

func (x *ListKeysResponse) Reset()

func (*ListKeysResponse) SizeVT 

func (m *ListKeysResponse) SizeVT() (n int)

func (*ListKeysResponse) String 

func (x *ListKeysResponse) String() string

func (*ListKeysResponse) UnmarshalVT 

func (m *ListKeysResponse) UnmarshalVT(dAtA []byte) error

type ListTunnelsRequest 

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

func (*ListTunnelsRequest) Descriptor deprecated 

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

Deprecated: Use ListTunnelsRequest.ProtoReflect.Descriptor instead.

func (*ListTunnelsRequest) MarshalToSizedBufferVT 

func (m *ListTunnelsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListTunnelsRequest) MarshalToVT 

func (m *ListTunnelsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ListTunnelsRequest) MarshalVT 

func (m *ListTunnelsRequest) MarshalVT() (dAtA []byte, err error)

func (*ListTunnelsRequest) ProtoMessage 

func (*ListTunnelsRequest) ProtoMessage()

func (*ListTunnelsRequest) ProtoReflect 

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

func (*ListTunnelsRequest) Reset 

func (x *ListTunnelsRequest) Reset()

func (*ListTunnelsRequest) SizeVT 

func (m *ListTunnelsRequest) SizeVT() (n int)

func (*ListTunnelsRequest) String 

func (x *ListTunnelsRequest) String() string

func (*ListTunnelsRequest) UnmarshalVT 

func (m *ListTunnelsRequest) UnmarshalVT(dAtA []byte) error

type ListTunnelsResponse 

type ListTunnelsResponse struct {
	Tunnels []*ClientTunnel `protobuf:"bytes,1,rep,name=tunnels,proto3" json:"tunnels,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTunnelsResponse) Descriptor deprecated 

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

Deprecated: Use ListTunnelsResponse.ProtoReflect.Descriptor instead.

func (*ListTunnelsResponse) GetTunnels 

func (x *ListTunnelsResponse) GetTunnels() []*ClientTunnel

func (*ListTunnelsResponse) MarshalToSizedBufferVT 

func (m *ListTunnelsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListTunnelsResponse) MarshalToVT 

func (m *ListTunnelsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListTunnelsResponse) MarshalVT 

func (m *ListTunnelsResponse) MarshalVT() (dAtA []byte, err error)

func (*ListTunnelsResponse) ProtoMessage 

func (*ListTunnelsResponse) ProtoMessage()

func (*ListTunnelsResponse) ProtoReflect 

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

func (*ListTunnelsResponse) Reset 

func (x *ListTunnelsResponse) Reset()

func (*ListTunnelsResponse) SizeVT 

func (m *ListTunnelsResponse) SizeVT() (n int)

func (*ListTunnelsResponse) String 

func (x *ListTunnelsResponse) String() string

func (*ListTunnelsResponse) UnmarshalVT 

func (m *ListTunnelsResponse) UnmarshalVT(dAtA []byte) error

type MembershipConclusionRequest 

type MembershipConclusionRequest struct {
	Stabilize bool `protobuf:"varint,1,opt,name=stabilize,proto3" json:"stabilize,omitempty"`
	Release   bool `protobuf:"varint,2,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

func (*MembershipConclusionRequest) Descriptor deprecated 

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

Deprecated: Use MembershipConclusionRequest.ProtoReflect.Descriptor instead.

func (*MembershipConclusionRequest) GetRelease 

func (x *MembershipConclusionRequest) GetRelease() bool

func (*MembershipConclusionRequest) GetStabilize 

func (x *MembershipConclusionRequest) GetStabilize() bool

func (*MembershipConclusionRequest) MarshalToSizedBufferVT 

func (m *MembershipConclusionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MembershipConclusionRequest) MarshalToVT 

func (m *MembershipConclusionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*MembershipConclusionRequest) MarshalVT 

func (m *MembershipConclusionRequest) MarshalVT() (dAtA []byte, err error)

func (*MembershipConclusionRequest) ProtoMessage 

func (*MembershipConclusionRequest) ProtoMessage()

func (*MembershipConclusionRequest) ProtoReflect 

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

func (*MembershipConclusionRequest) Reset 

func (x *MembershipConclusionRequest) Reset()

func (*MembershipConclusionRequest) SizeVT 

func (m *MembershipConclusionRequest) SizeVT() (n int)

func (*MembershipConclusionRequest) String 

func (x *MembershipConclusionRequest) String() string

func (*MembershipConclusionRequest) UnmarshalVT 

func (m *MembershipConclusionRequest) UnmarshalVT(dAtA []byte) error

type MembershipConclusionResponse 

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

func (*MembershipConclusionResponse) Descriptor deprecated 

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

Deprecated: Use MembershipConclusionResponse.ProtoReflect.Descriptor instead.

func (*MembershipConclusionResponse) MarshalToSizedBufferVT 

func (m *MembershipConclusionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MembershipConclusionResponse) MarshalToVT 

func (m *MembershipConclusionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*MembershipConclusionResponse) MarshalVT 

func (m *MembershipConclusionResponse) MarshalVT() (dAtA []byte, err error)

func (*MembershipConclusionResponse) ProtoMessage 

func (*MembershipConclusionResponse) ProtoMessage()

func (*MembershipConclusionResponse) ProtoReflect 

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

func (*MembershipConclusionResponse) Reset 

func (x *MembershipConclusionResponse) Reset()

func (*MembershipConclusionResponse) SizeVT 

func (m *MembershipConclusionResponse) SizeVT() (n int)

func (*MembershipConclusionResponse) String 

func (x *MembershipConclusionResponse) String() string

func (*MembershipConclusionResponse) UnmarshalVT 

func (m *MembershipConclusionResponse) UnmarshalVT(dAtA []byte) error

type Node 

type Node struct {
	Id         uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Address    string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Unknown    bool   `protobuf:"varint,3,opt,name=unknown,proto3" json:"unknown,omitempty"`       // indicate negotiation for ID is needed
	Rendezvous bool   `protobuf:"varint,4,opt,name=rendezvous,proto3" json:"rendezvous,omitempty"` // indicate a client connection
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAddress 

func (x *Node) GetAddress() string

func (*Node) GetId 

func (x *Node) GetId() uint64

func (*Node) GetRendezvous 

func (x *Node) GetRendezvous() bool

func (*Node) GetUnknown 

func (x *Node) GetUnknown() bool

func (*Node) MarshalLogObject 

func (n *Node) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Node) MarshalToSizedBufferVT 

func (m *Node) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Node) MarshalToVT 

func (m *Node) MarshalToVT(dAtA []byte) (int, error)

func (*Node) MarshalVT 

func (m *Node) MarshalVT() (dAtA []byte, err error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) SizeVT 

func (m *Node) SizeVT() (n int)

func (*Node) String 

func (x *Node) String() string

func (*Node) UnmarshalVT 

func (m *Node) UnmarshalVT(dAtA []byte) error

type NotifyRequest 

type NotifyRequest struct {
	Predecessor *Node `protobuf:"bytes,1,opt,name=predecessor,proto3" json:"predecessor,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyRequest) Descriptor deprecated 

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

Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.

func (*NotifyRequest) GetPredecessor 

func (x *NotifyRequest) GetPredecessor() *Node

func (*NotifyRequest) MarshalToSizedBufferVT 

func (m *NotifyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NotifyRequest) MarshalToVT 

func (m *NotifyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*NotifyRequest) MarshalVT 

func (m *NotifyRequest) MarshalVT() (dAtA []byte, err error)

func (*NotifyRequest) ProtoMessage 

func (*NotifyRequest) ProtoMessage()

func (*NotifyRequest) ProtoReflect 

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

func (*NotifyRequest) Reset 

func (x *NotifyRequest) Reset()

func (*NotifyRequest) SizeVT 

func (m *NotifyRequest) SizeVT() (n int)

func (*NotifyRequest) String 

func (x *NotifyRequest) String() string

func (*NotifyRequest) UnmarshalVT 

func (m *NotifyRequest) UnmarshalVT(dAtA []byte) error

type NotifyResponse 

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

func (*NotifyResponse) Descriptor deprecated 

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

Deprecated: Use NotifyResponse.ProtoReflect.Descriptor instead.

func (*NotifyResponse) MarshalToSizedBufferVT 

func (m *NotifyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NotifyResponse) MarshalToVT 

func (m *NotifyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*NotifyResponse) MarshalVT 

func (m *NotifyResponse) MarshalVT() (dAtA []byte, err error)

func (*NotifyResponse) ProtoMessage 

func (*NotifyResponse) ProtoMessage()

func (*NotifyResponse) ProtoReflect 

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

func (*NotifyResponse) Reset 

func (x *NotifyResponse) Reset()

func (*NotifyResponse) SizeVT 

func (m *NotifyResponse) SizeVT() (n int)

func (*NotifyResponse) String 

func (x *NotifyResponse) String() string

func (*NotifyResponse) UnmarshalVT 

func (m *NotifyResponse) UnmarshalVT(dAtA []byte) error

type PKIService 

type PKIService interface {
	RequestCertificate(context.Context, *CertificateRequest) (*CertificateResponse, error)
}

func NewPKIServiceJSONClient 

func NewPKIServiceJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) PKIService

NewPKIServiceJSONClient creates a JSON client that implements the PKIService interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewPKIServiceProtobufClient 

func NewPKIServiceProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) PKIService

NewPKIServiceProtobufClient creates a Protobuf client that implements the PKIService interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type PingRequest 

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

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) MarshalToSizedBufferVT 

func (m *PingRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PingRequest) MarshalToVT 

func (m *PingRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PingRequest) MarshalVT 

func (m *PingRequest) MarshalVT() (dAtA []byte, err error)

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) SizeVT 

func (m *PingRequest) SizeVT() (n int)

func (*PingRequest) String 

func (x *PingRequest) String() string

func (*PingRequest) UnmarshalVT 

func (m *PingRequest) UnmarshalVT(dAtA []byte) error

type PingResponse 

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

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) MarshalToSizedBufferVT 

func (m *PingResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PingResponse) MarshalToVT 

func (m *PingResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PingResponse) MarshalVT 

func (m *PingResponse) MarshalVT() (dAtA []byte, err error)

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) SizeVT 

func (m *PingResponse) SizeVT() (n int)

func (*PingResponse) String 

func (x *PingResponse) String() string

func (*PingResponse) UnmarshalVT 

func (m *PingResponse) UnmarshalVT(dAtA []byte) error

type PrefixRequest 

type PrefixRequest struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Child  []byte `protobuf:"bytes,2,opt,name=child,proto3" json:"child,omitempty"`
	// contains filtered or unexported fields
}

func (*PrefixRequest) Descriptor deprecated 

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

Deprecated: Use PrefixRequest.ProtoReflect.Descriptor instead.

func (*PrefixRequest) GetChild 

func (x *PrefixRequest) GetChild() []byte

func (*PrefixRequest) GetPrefix 

func (x *PrefixRequest) GetPrefix() []byte

func (*PrefixRequest) MarshalToSizedBufferVT 

func (m *PrefixRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PrefixRequest) MarshalToVT 

func (m *PrefixRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PrefixRequest) MarshalVT 

func (m *PrefixRequest) MarshalVT() (dAtA []byte, err error)

func (*PrefixRequest) ProtoMessage 

func (*PrefixRequest) ProtoMessage()

func (*PrefixRequest) ProtoReflect 

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

func (*PrefixRequest) Reset 

func (x *PrefixRequest) Reset()

func (*PrefixRequest) SizeVT 

func (m *PrefixRequest) SizeVT() (n int)

func (*PrefixRequest) String 

func (x *PrefixRequest) String() string

func (*PrefixRequest) UnmarshalVT 

func (m *PrefixRequest) UnmarshalVT(dAtA []byte) error

type PrefixResponse 

type PrefixResponse struct {
	Children [][]byte `protobuf:"bytes,1,rep,name=children,proto3" json:"children,omitempty"`
	Exists   bool     `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*PrefixResponse) Descriptor deprecated 

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

Deprecated: Use PrefixResponse.ProtoReflect.Descriptor instead.

func (*PrefixResponse) GetChildren 

func (x *PrefixResponse) GetChildren() [][]byte

func (*PrefixResponse) GetExists 

func (x *PrefixResponse) GetExists() bool

func (*PrefixResponse) MarshalToSizedBufferVT 

func (m *PrefixResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PrefixResponse) MarshalToVT 

func (m *PrefixResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PrefixResponse) MarshalVT 

func (m *PrefixResponse) MarshalVT() (dAtA []byte, err error)

func (*PrefixResponse) ProtoMessage 

func (*PrefixResponse) ProtoMessage()

func (*PrefixResponse) ProtoReflect 

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

func (*PrefixResponse) Reset 

func (x *PrefixResponse) Reset()

func (*PrefixResponse) SizeVT 

func (m *PrefixResponse) SizeVT() (n int)

func (*PrefixResponse) String 

func (x *PrefixResponse) String() string

func (*PrefixResponse) UnmarshalVT 

func (m *PrefixResponse) UnmarshalVT(dAtA []byte) error

type ProofOfWork 

type ProofOfWork struct {
	PubKey    []byte `protobuf:"bytes,1,opt,name=pub_key,json=pubKey,proto3" json:"pub_key,omitempty"`
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	Solution  string `protobuf:"bytes,3,opt,name=solution,proto3" json:"solution,omitempty"`
	// contains filtered or unexported fields
}

func (*ProofOfWork) Descriptor deprecated 

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

Deprecated: Use ProofOfWork.ProtoReflect.Descriptor instead.

func (*ProofOfWork) GetPubKey 

func (x *ProofOfWork) GetPubKey() []byte

func (*ProofOfWork) GetSignature 

func (x *ProofOfWork) GetSignature() []byte

func (*ProofOfWork) GetSolution 

func (x *ProofOfWork) GetSolution() string

func (*ProofOfWork) MarshalToSizedBufferVT 

func (m *ProofOfWork) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ProofOfWork) MarshalToVT 

func (m *ProofOfWork) MarshalToVT(dAtA []byte) (int, error)

func (*ProofOfWork) MarshalVT 

func (m *ProofOfWork) MarshalVT() (dAtA []byte, err error)

func (*ProofOfWork) ProtoMessage 

func (*ProofOfWork) ProtoMessage()

func (*ProofOfWork) ProtoReflect 

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

func (*ProofOfWork) Reset 

func (x *ProofOfWork) Reset()

func (*ProofOfWork) SizeVT 

func (m *ProofOfWork) SizeVT() (n int)

func (*ProofOfWork) String 

func (x *ProofOfWork) String() string

func (*ProofOfWork) UnmarshalVT 

func (m *ProofOfWork) UnmarshalVT(dAtA []byte) error

type PublishTunnelRequest 

type PublishTunnelRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// servers are tun identities
	Servers []*Node `protobuf:"bytes,2,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishTunnelRequest) Descriptor deprecated 

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

Deprecated: Use PublishTunnelRequest.ProtoReflect.Descriptor instead.

func (*PublishTunnelRequest) GetHostname 

func (x *PublishTunnelRequest) GetHostname() string

func (*PublishTunnelRequest) GetServers 

func (x *PublishTunnelRequest) GetServers() []*Node

func (*PublishTunnelRequest) MarshalToSizedBufferVT 

func (m *PublishTunnelRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishTunnelRequest) MarshalToVT 

func (m *PublishTunnelRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PublishTunnelRequest) MarshalVT 

func (m *PublishTunnelRequest) MarshalVT() (dAtA []byte, err error)

func (*PublishTunnelRequest) ProtoMessage 

func (*PublishTunnelRequest) ProtoMessage()

func (*PublishTunnelRequest) ProtoReflect 

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

func (*PublishTunnelRequest) Reset 

func (x *PublishTunnelRequest) Reset()

func (*PublishTunnelRequest) SizeVT 

func (m *PublishTunnelRequest) SizeVT() (n int)

func (*PublishTunnelRequest) String 

func (x *PublishTunnelRequest) String() string

func (*PublishTunnelRequest) UnmarshalVT 

func (m *PublishTunnelRequest) UnmarshalVT(dAtA []byte) error

type PublishTunnelResponse 

type PublishTunnelResponse struct {
	Published []*Node `protobuf:"bytes,1,rep,name=published,proto3" json:"published,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishTunnelResponse) Descriptor deprecated 

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

Deprecated: Use PublishTunnelResponse.ProtoReflect.Descriptor instead.

func (*PublishTunnelResponse) GetPublished 

func (x *PublishTunnelResponse) GetPublished() []*Node

func (*PublishTunnelResponse) MarshalToSizedBufferVT 

func (m *PublishTunnelResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishTunnelResponse) MarshalToVT 

func (m *PublishTunnelResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PublishTunnelResponse) MarshalVT 

func (m *PublishTunnelResponse) MarshalVT() (dAtA []byte, err error)

func (*PublishTunnelResponse) ProtoMessage 

func (*PublishTunnelResponse) ProtoMessage()

func (*PublishTunnelResponse) ProtoReflect 

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

func (*PublishTunnelResponse) Reset 

func (x *PublishTunnelResponse) Reset()

func (*PublishTunnelResponse) SizeVT 

func (m *PublishTunnelResponse) SizeVT() (n int)

func (*PublishTunnelResponse) String 

func (x *PublishTunnelResponse) String() string

func (*PublishTunnelResponse) UnmarshalVT 

func (m *PublishTunnelResponse) UnmarshalVT(dAtA []byte) error

type RegisterIdentityRequest 

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

func (*RegisterIdentityRequest) Descriptor deprecated 

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

Deprecated: Use RegisterIdentityRequest.ProtoReflect.Descriptor instead.

func (*RegisterIdentityRequest) MarshalToSizedBufferVT 

func (m *RegisterIdentityRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RegisterIdentityRequest) MarshalToVT 

func (m *RegisterIdentityRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RegisterIdentityRequest) MarshalVT 

func (m *RegisterIdentityRequest) MarshalVT() (dAtA []byte, err error)

func (*RegisterIdentityRequest) ProtoMessage 

func (*RegisterIdentityRequest) ProtoMessage()

func (*RegisterIdentityRequest) ProtoReflect 

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

func (*RegisterIdentityRequest) Reset 

func (x *RegisterIdentityRequest) Reset()

func (*RegisterIdentityRequest) SizeVT 

func (m *RegisterIdentityRequest) SizeVT() (n int)

func (*RegisterIdentityRequest) String 

func (x *RegisterIdentityRequest) String() string

func (*RegisterIdentityRequest) UnmarshalVT 

func (m *RegisterIdentityRequest) UnmarshalVT(dAtA []byte) error

type RegisterIdentityResponse 

type RegisterIdentityResponse struct {
	Apex string `protobuf:"bytes,2,opt,name=apex,proto3" json:"apex,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterIdentityResponse) Descriptor deprecated 

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

Deprecated: Use RegisterIdentityResponse.ProtoReflect.Descriptor instead.

func (*RegisterIdentityResponse) GetApex 

func (x *RegisterIdentityResponse) GetApex() string

func (*RegisterIdentityResponse) MarshalToSizedBufferVT 

func (m *RegisterIdentityResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RegisterIdentityResponse) MarshalToVT 

func (m *RegisterIdentityResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RegisterIdentityResponse) MarshalVT 

func (m *RegisterIdentityResponse) MarshalVT() (dAtA []byte, err error)

func (*RegisterIdentityResponse) ProtoMessage 

func (*RegisterIdentityResponse) ProtoMessage()

func (*RegisterIdentityResponse) ProtoReflect 

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

func (*RegisterIdentityResponse) Reset 

func (x *RegisterIdentityResponse) Reset()

func (*RegisterIdentityResponse) SizeVT 

func (m *RegisterIdentityResponse) SizeVT() (n int)

func (*RegisterIdentityResponse) String 

func (x *RegisterIdentityResponse) String() string

func (*RegisterIdentityResponse) UnmarshalVT 

func (m *RegisterIdentityResponse) UnmarshalVT(dAtA []byte) error

type RegisteredHostnamesRequest 

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

func (*RegisteredHostnamesRequest) Descriptor deprecated 

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

Deprecated: Use RegisteredHostnamesRequest.ProtoReflect.Descriptor instead.

func (*RegisteredHostnamesRequest) MarshalToSizedBufferVT 

func (m *RegisteredHostnamesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RegisteredHostnamesRequest) MarshalToVT 

func (m *RegisteredHostnamesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RegisteredHostnamesRequest) MarshalVT 

func (m *RegisteredHostnamesRequest) MarshalVT() (dAtA []byte, err error)

func (*RegisteredHostnamesRequest) ProtoMessage 

func (*RegisteredHostnamesRequest) ProtoMessage()

func (*RegisteredHostnamesRequest) ProtoReflect 

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

func (*RegisteredHostnamesRequest) Reset 

func (x *RegisteredHostnamesRequest) Reset()

func (*RegisteredHostnamesRequest) SizeVT 

func (m *RegisteredHostnamesRequest) SizeVT() (n int)

func (*RegisteredHostnamesRequest) String 

func (x *RegisteredHostnamesRequest) String() string

func (*RegisteredHostnamesRequest) UnmarshalVT 

func (m *RegisteredHostnamesRequest) UnmarshalVT(dAtA []byte) error

type RegisteredHostnamesResponse 

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

func (*RegisteredHostnamesResponse) Descriptor deprecated 

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

Deprecated: Use RegisteredHostnamesResponse.ProtoReflect.Descriptor instead.

func (*RegisteredHostnamesResponse) GetHostnames 

func (x *RegisteredHostnamesResponse) GetHostnames() []string

func (*RegisteredHostnamesResponse) MarshalToSizedBufferVT 

func (m *RegisteredHostnamesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RegisteredHostnamesResponse) MarshalToVT 

func (m *RegisteredHostnamesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RegisteredHostnamesResponse) MarshalVT 

func (m *RegisteredHostnamesResponse) MarshalVT() (dAtA []byte, err error)

func (*RegisteredHostnamesResponse) ProtoMessage 

func (*RegisteredHostnamesResponse) ProtoMessage()

func (*RegisteredHostnamesResponse) ProtoReflect 

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

func (*RegisteredHostnamesResponse) Reset 

func (x *RegisteredHostnamesResponse) Reset()

func (*RegisteredHostnamesResponse) SizeVT 

func (m *RegisteredHostnamesResponse) SizeVT() (n int)

func (*RegisteredHostnamesResponse) String 

func (x *RegisteredHostnamesResponse) String() string

func (*RegisteredHostnamesResponse) UnmarshalVT 

func (m *RegisteredHostnamesResponse) UnmarshalVT(dAtA []byte) error

type ReleaseTunnelRequest 

type ReleaseTunnelRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseTunnelRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseTunnelRequest.ProtoReflect.Descriptor instead.

func (*ReleaseTunnelRequest) GetHostname 

func (x *ReleaseTunnelRequest) GetHostname() string

func (*ReleaseTunnelRequest) MarshalToSizedBufferVT 

func (m *ReleaseTunnelRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReleaseTunnelRequest) MarshalToVT 

func (m *ReleaseTunnelRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReleaseTunnelRequest) MarshalVT 

func (m *ReleaseTunnelRequest) MarshalVT() (dAtA []byte, err error)

func (*ReleaseTunnelRequest) ProtoMessage 

func (*ReleaseTunnelRequest) ProtoMessage()

func (*ReleaseTunnelRequest) ProtoReflect 

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

func (*ReleaseTunnelRequest) Reset 

func (x *ReleaseTunnelRequest) Reset()

func (*ReleaseTunnelRequest) SizeVT 

func (m *ReleaseTunnelRequest) SizeVT() (n int)

func (*ReleaseTunnelRequest) String 

func (x *ReleaseTunnelRequest) String() string

func (*ReleaseTunnelRequest) UnmarshalVT 

func (m *ReleaseTunnelRequest) UnmarshalVT(dAtA []byte) error

type ReleaseTunnelResponse 

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

func (*ReleaseTunnelResponse) Descriptor deprecated 

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

Deprecated: Use ReleaseTunnelResponse.ProtoReflect.Descriptor instead.

func (*ReleaseTunnelResponse) MarshalToSizedBufferVT 

func (m *ReleaseTunnelResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReleaseTunnelResponse) MarshalToVT 

func (m *ReleaseTunnelResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReleaseTunnelResponse) MarshalVT 

func (m *ReleaseTunnelResponse) MarshalVT() (dAtA []byte, err error)

func (*ReleaseTunnelResponse) ProtoMessage 

func (*ReleaseTunnelResponse) ProtoMessage()

func (*ReleaseTunnelResponse) ProtoReflect 

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

func (*ReleaseTunnelResponse) Reset 

func (x *ReleaseTunnelResponse) Reset()

func (*ReleaseTunnelResponse) SizeVT 

func (m *ReleaseTunnelResponse) SizeVT() (n int)

func (*ReleaseTunnelResponse) String 

func (x *ReleaseTunnelResponse) String() string

func (*ReleaseTunnelResponse) UnmarshalVT 

func (m *ReleaseTunnelResponse) UnmarshalVT(dAtA []byte) error

type RequestToJoinRequest 

type RequestToJoinRequest struct {
	Joiner *Node `protobuf:"bytes,1,opt,name=joiner,proto3" json:"joiner,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestToJoinRequest) Descriptor deprecated 

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

Deprecated: Use RequestToJoinRequest.ProtoReflect.Descriptor instead.

func (*RequestToJoinRequest) GetJoiner 

func (x *RequestToJoinRequest) GetJoiner() *Node

func (*RequestToJoinRequest) MarshalToSizedBufferVT 

func (m *RequestToJoinRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RequestToJoinRequest) MarshalToVT 

func (m *RequestToJoinRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RequestToJoinRequest) MarshalVT 

func (m *RequestToJoinRequest) MarshalVT() (dAtA []byte, err error)

func (*RequestToJoinRequest) ProtoMessage 

func (*RequestToJoinRequest) ProtoMessage()

func (*RequestToJoinRequest) ProtoReflect 

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

func (*RequestToJoinRequest) Reset 

func (x *RequestToJoinRequest) Reset()

func (*RequestToJoinRequest) SizeVT 

func (m *RequestToJoinRequest) SizeVT() (n int)

func (*RequestToJoinRequest) String 

func (x *RequestToJoinRequest) String() string

func (*RequestToJoinRequest) UnmarshalVT 

func (m *RequestToJoinRequest) UnmarshalVT(dAtA []byte) error

type RequestToJoinResponse 

type RequestToJoinResponse struct {
	Predecessor *Node   `protobuf:"bytes,1,opt,name=predecessor,proto3" json:"predecessor,omitempty"`
	Successors  []*Node `protobuf:"bytes,2,rep,name=successors,proto3" json:"successors,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestToJoinResponse) Descriptor deprecated 

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

Deprecated: Use RequestToJoinResponse.ProtoReflect.Descriptor instead.

func (*RequestToJoinResponse) GetPredecessor 

func (x *RequestToJoinResponse) GetPredecessor() *Node

func (*RequestToJoinResponse) GetSuccessors 

func (x *RequestToJoinResponse) GetSuccessors() []*Node

func (*RequestToJoinResponse) MarshalToSizedBufferVT 

func (m *RequestToJoinResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RequestToJoinResponse) MarshalToVT 

func (m *RequestToJoinResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RequestToJoinResponse) MarshalVT 

func (m *RequestToJoinResponse) MarshalVT() (dAtA []byte, err error)

func (*RequestToJoinResponse) ProtoMessage 

func (*RequestToJoinResponse) ProtoMessage()

func (*RequestToJoinResponse) ProtoReflect 

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

func (*RequestToJoinResponse) Reset 

func (x *RequestToJoinResponse) Reset()

func (*RequestToJoinResponse) SizeVT 

func (m *RequestToJoinResponse) SizeVT() (n int)

func (*RequestToJoinResponse) String 

func (x *RequestToJoinResponse) String() string

func (*RequestToJoinResponse) UnmarshalVT 

func (m *RequestToJoinResponse) UnmarshalVT(dAtA []byte) error

type RequestToLeaveRequest 

type RequestToLeaveRequest struct {
	Leaver *Node `protobuf:"bytes,1,opt,name=leaver,proto3" json:"leaver,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestToLeaveRequest) Descriptor deprecated 

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

Deprecated: Use RequestToLeaveRequest.ProtoReflect.Descriptor instead.

func (*RequestToLeaveRequest) GetLeaver 

func (x *RequestToLeaveRequest) GetLeaver() *Node

func (*RequestToLeaveRequest) MarshalToSizedBufferVT 

func (m *RequestToLeaveRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RequestToLeaveRequest) MarshalToVT 

func (m *RequestToLeaveRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RequestToLeaveRequest) MarshalVT 

func (m *RequestToLeaveRequest) MarshalVT() (dAtA []byte, err error)

func (*RequestToLeaveRequest) ProtoMessage 

func (*RequestToLeaveRequest) ProtoMessage()

func (*RequestToLeaveRequest) ProtoReflect 

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

func (*RequestToLeaveRequest) Reset 

func (x *RequestToLeaveRequest) Reset()

func (*RequestToLeaveRequest) SizeVT 

func (m *RequestToLeaveRequest) SizeVT() (n int)

func (*RequestToLeaveRequest) String 

func (x *RequestToLeaveRequest) String() string

func (*RequestToLeaveRequest) UnmarshalVT 

func (m *RequestToLeaveRequest) UnmarshalVT(dAtA []byte) error

type RequestToLeaveResponse 

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

func (*RequestToLeaveResponse) Descriptor deprecated 

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

Deprecated: Use RequestToLeaveResponse.ProtoReflect.Descriptor instead.

func (*RequestToLeaveResponse) MarshalToSizedBufferVT 

func (m *RequestToLeaveResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RequestToLeaveResponse) MarshalToVT 

func (m *RequestToLeaveResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RequestToLeaveResponse) MarshalVT 

func (m *RequestToLeaveResponse) MarshalVT() (dAtA []byte, err error)

func (*RequestToLeaveResponse) ProtoMessage 

func (*RequestToLeaveResponse) ProtoMessage()

func (*RequestToLeaveResponse) ProtoReflect 

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

func (*RequestToLeaveResponse) Reset 

func (x *RequestToLeaveResponse) Reset()

func (*RequestToLeaveResponse) SizeVT 

func (m *RequestToLeaveResponse) SizeVT() (n int)

func (*RequestToLeaveResponse) String 

func (x *RequestToLeaveResponse) String() string

func (*RequestToLeaveResponse) UnmarshalVT 

func (m *RequestToLeaveResponse) UnmarshalVT(dAtA []byte) error

type SimpleRequest 

type SimpleRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleRequest) Descriptor deprecated 

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

Deprecated: Use SimpleRequest.ProtoReflect.Descriptor instead.

func (*SimpleRequest) GetKey 

func (x *SimpleRequest) GetKey() []byte

func (*SimpleRequest) GetValue 

func (x *SimpleRequest) GetValue() []byte

func (*SimpleRequest) MarshalToSizedBufferVT 

func (m *SimpleRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SimpleRequest) MarshalToVT 

func (m *SimpleRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SimpleRequest) MarshalVT 

func (m *SimpleRequest) MarshalVT() (dAtA []byte, err error)

func (*SimpleRequest) ProtoMessage 

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) ProtoReflect 

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

func (*SimpleRequest) Reset 

func (x *SimpleRequest) Reset()

func (*SimpleRequest) SizeVT 

func (m *SimpleRequest) SizeVT() (n int)

func (*SimpleRequest) String 

func (x *SimpleRequest) String() string

func (*SimpleRequest) UnmarshalVT 

func (m *SimpleRequest) UnmarshalVT(dAtA []byte) error

type SimpleResponse 

type SimpleResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleResponse) Descriptor deprecated 

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

Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.

func (*SimpleResponse) GetValue 

func (x *SimpleResponse) GetValue() []byte

func (*SimpleResponse) MarshalToSizedBufferVT 

func (m *SimpleResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SimpleResponse) MarshalToVT 

func (m *SimpleResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SimpleResponse) MarshalVT 

func (m *SimpleResponse) MarshalVT() (dAtA []byte, err error)

func (*SimpleResponse) ProtoMessage 

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) ProtoReflect 

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

func (*SimpleResponse) Reset 

func (x *SimpleResponse) Reset()

func (*SimpleResponse) SizeVT 

func (m *SimpleResponse) SizeVT() (n int)

func (*SimpleResponse) String 

func (x *SimpleResponse) String() string

func (*SimpleResponse) UnmarshalVT 

func (m *SimpleResponse) UnmarshalVT(dAtA []byte) error

type Stream 

type Stream struct {
	Type   Stream_Type `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.Stream_Type" json:"type,omitempty"`
	Target *Node       `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetTarget 

func (x *Stream) GetTarget() *Node

func (*Stream) GetType 

func (x *Stream) GetType() Stream_Type

func (*Stream) MarshalToSizedBufferVT 

func (m *Stream) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Stream) MarshalToVT 

func (m *Stream) MarshalToVT(dAtA []byte) (int, error)

func (*Stream) MarshalVT 

func (m *Stream) MarshalVT() (dAtA []byte, err error)

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) SizeVT 

func (m *Stream) SizeVT() (n int)

func (*Stream) String 

func (x *Stream) String() string

func (*Stream) UnmarshalVT 

func (m *Stream) UnmarshalVT(dAtA []byte) error

type Stream_Type 

type Stream_Type int32
const (
	Stream_UNKNOWN_TYPE Stream_Type = 0
	Stream_RPC          Stream_Type = 1 // used for rpc between nodes and between client/server
	Stream_DIRECT       Stream_Type = 2 // used for establishing the reverse proxy from the tunneling node to client
	Stream_PROXY        Stream_Type = 3 // used when client is not directly connected to the tunneling node
	Stream_INTERNAL     Stream_Type = 4 // used for /_internal endpoint proxying between nodes
)

func (Stream_Type) Descriptor 

func (Stream_Type) Descriptor() protoreflect.EnumDescriptor

func (Stream_Type) Enum 

func (x Stream_Type) Enum() *Stream_Type

func (Stream_Type) EnumDescriptor deprecated 

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

Deprecated: Use Stream_Type.Descriptor instead.

func (Stream_Type) Number 

func (x Stream_Type) Number() protoreflect.EnumNumber

func (Stream_Type) String 

func (x Stream_Type) String() string

func (Stream_Type) Type 

func (Stream_Type) Type() protoreflect.EnumType

type TunnelDestination 

type TunnelDestination struct {
	Chord  *Node `protobuf:"bytes,1,opt,name=chord,proto3" json:"chord,omitempty"`
	Tunnel *Node `protobuf:"bytes,2,opt,name=tunnel,proto3" json:"tunnel,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelDestination) Descriptor deprecated 

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

Deprecated: Use TunnelDestination.ProtoReflect.Descriptor instead.

func (*TunnelDestination) GetChord 

func (x *TunnelDestination) GetChord() *Node

func (*TunnelDestination) GetTunnel 

func (x *TunnelDestination) GetTunnel() *Node

func (*TunnelDestination) MarshalToSizedBufferVT 

func (m *TunnelDestination) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TunnelDestination) MarshalToVT 

func (m *TunnelDestination) MarshalToVT(dAtA []byte) (int, error)

func (*TunnelDestination) MarshalVT 

func (m *TunnelDestination) MarshalVT() (dAtA []byte, err error)

func (*TunnelDestination) ProtoMessage 

func (*TunnelDestination) ProtoMessage()

func (*TunnelDestination) ProtoReflect 

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

func (*TunnelDestination) Reset 

func (x *TunnelDestination) Reset()

func (*TunnelDestination) SizeVT 

func (m *TunnelDestination) SizeVT() (n int)

func (*TunnelDestination) String 

func (x *TunnelDestination) String() string

func (*TunnelDestination) UnmarshalVT 

func (m *TunnelDestination) UnmarshalVT(dAtA []byte) error

type TunnelRoute 

type TunnelRoute struct {
	ClientDestination *Node  `protobuf:"bytes,1,opt,name=client_destination,json=clientDestination,proto3" json:"client_destination,omitempty"`
	ChordDestination  *Node  `protobuf:"bytes,2,opt,name=chord_destination,json=chordDestination,proto3" json:"chord_destination,omitempty"`
	TunnelDestination *Node  `protobuf:"bytes,3,opt,name=tunnel_destination,json=tunnelDestination,proto3" json:"tunnel_destination,omitempty"`
	Hostname          string `protobuf:"bytes,10,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelRoute) Descriptor deprecated 

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

Deprecated: Use TunnelRoute.ProtoReflect.Descriptor instead.

func (*TunnelRoute) GetChordDestination 

func (x *TunnelRoute) GetChordDestination() *Node

func (*TunnelRoute) GetClientDestination 

func (x *TunnelRoute) GetClientDestination() *Node

func (*TunnelRoute) GetHostname 

func (x *TunnelRoute) GetHostname() string

func (*TunnelRoute) GetTunnelDestination 

func (x *TunnelRoute) GetTunnelDestination() *Node

func (*TunnelRoute) MarshalToSizedBufferVT 

func (m *TunnelRoute) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TunnelRoute) MarshalToVT 

func (m *TunnelRoute) MarshalToVT(dAtA []byte) (int, error)

func (*TunnelRoute) MarshalVT 

func (m *TunnelRoute) MarshalVT() (dAtA []byte, err error)

func (*TunnelRoute) ProtoMessage 

func (*TunnelRoute) ProtoMessage()

func (*TunnelRoute) ProtoReflect 

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

func (*TunnelRoute) Reset 

func (x *TunnelRoute) Reset()

func (*TunnelRoute) SizeVT 

func (m *TunnelRoute) SizeVT() (n int)

func (*TunnelRoute) String 

func (x *TunnelRoute) String() string

func (*TunnelRoute) UnmarshalVT 

func (m *TunnelRoute) UnmarshalVT(dAtA []byte) error

type TunnelService 

type TunnelService interface {
	Ping(context.Context, *ClientPingRequest) (*ClientPingResponse, error)

	RegisterIdentity(context.Context, *RegisterIdentityRequest) (*RegisterIdentityResponse, error)

	GetNodes(context.Context, *GetNodesRequest) (*GetNodesResponse, error)

	GenerateHostname(context.Context, *GenerateHostnameRequest) (*GenerateHostnameResponse, error)

	RegisteredHostnames(context.Context, *RegisteredHostnamesRequest) (*RegisteredHostnamesResponse, error)

	PublishTunnel(context.Context, *PublishTunnelRequest) (*PublishTunnelResponse, error)

	UnpublishTunnel(context.Context, *UnpublishTunnelRequest) (*UnpublishTunnelResponse, error)

	ReleaseTunnel(context.Context, *ReleaseTunnelRequest) (*ReleaseTunnelResponse, error)

	AcmeInstruction(context.Context, *InstructionRequest) (*InstructionResponse, error)

	AcmeValidate(context.Context, *ValidateRequest) (*ValidateResponse, error)
}

func NewTunnelServiceJSONClient 

func NewTunnelServiceJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) TunnelService

NewTunnelServiceJSONClient creates a JSON client that implements the TunnelService interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewTunnelServiceProtobufClient 

func NewTunnelServiceProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) TunnelService

NewTunnelServiceProtobufClient creates a Protobuf client that implements the TunnelService interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type TunnelStatus 

type TunnelStatus struct {
	Status TunnelStatusCode `protobuf:"varint,2,opt,name=status,proto3,enum=protocol.TunnelStatusCode" json:"status,omitempty"`
	Error  string           `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelStatus) Descriptor deprecated 

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

Deprecated: Use TunnelStatus.ProtoReflect.Descriptor instead.

func (*TunnelStatus) GetError 

func (x *TunnelStatus) GetError() string

func (*TunnelStatus) GetStatus 

func (x *TunnelStatus) GetStatus() TunnelStatusCode

func (*TunnelStatus) MarshalToSizedBufferVT 

func (m *TunnelStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TunnelStatus) MarshalToVT 

func (m *TunnelStatus) MarshalToVT(dAtA []byte) (int, error)

func (*TunnelStatus) MarshalVT 

func (m *TunnelStatus) MarshalVT() (dAtA []byte, err error)

func (*TunnelStatus) ProtoMessage 

func (*TunnelStatus) ProtoMessage()

func (*TunnelStatus) ProtoReflect 

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

func (*TunnelStatus) Reset 

func (x *TunnelStatus) Reset()

func (*TunnelStatus) SizeVT 

func (m *TunnelStatus) SizeVT() (n int)

func (*TunnelStatus) String 

func (x *TunnelStatus) String() string

func (*TunnelStatus) UnmarshalVT 

func (m *TunnelStatus) UnmarshalVT(dAtA []byte) error

type TunnelStatusCode 

type TunnelStatusCode int32
const (
	TunnelStatusCode_STATUS_OK     TunnelStatusCode = 0
	TunnelStatusCode_UNKNOWN_ERROR TunnelStatusCode = 1
	TunnelStatusCode_NO_DIRECT     TunnelStatusCode = 2
)

func (TunnelStatusCode) Descriptor 

func (TunnelStatusCode) Descriptor() protoreflect.EnumDescriptor

func (TunnelStatusCode) Enum 

func (x TunnelStatusCode) Enum() *TunnelStatusCode

func (TunnelStatusCode) EnumDescriptor deprecated 

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

Deprecated: Use TunnelStatusCode.Descriptor instead.

func (TunnelStatusCode) Number 

func (x TunnelStatusCode) Number() protoreflect.EnumNumber

func (TunnelStatusCode) String 

func (x TunnelStatusCode) String() string

func (TunnelStatusCode) Type 

func (TunnelStatusCode) Type() protoreflect.EnumType

type TwirpServer 

type TwirpServer interface {
	http.Handler

	// ServiceDescriptor returns gzipped bytes describing the .proto file that
	// this service was generated from. Once unzipped, the bytes can be
	// unmarshalled as a
	// google.golang.org/protobuf/types/descriptorpb.FileDescriptorProto.
	//
	// The returned integer is the index of this particular service within that
	// FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a
	// low-level field, expected to be used for reflection.
	ServiceDescriptor() ([]byte, int)

	// ProtocGenTwirpVersion is the semantic version string of the version of
	// twirp used to generate this file.
	ProtocGenTwirpVersion() string

	// PathPrefix returns the HTTP URL path prefix for all methods handled by this
	// service. This can be used with an HTTP mux to route Twirp requests.
	// The path prefix is in the form: "/<prefix>/<package>.<Service>/"
	// that is, everything in a Twirp route except for the <Method> at the end.
	PathPrefix() string
}

TwirpServer is the interface generated server structs will support: they're HTTP handlers with additional methods for accessing metadata about the service. Those accessors are a low-level API for building reflection tools. Most people can think of TwirpServers as just http.Handlers.

func NewClientQueryServiceServer 

func NewClientQueryServiceServer(svc ClientQueryService, opts ...interface{}) TwirpServer

NewClientQueryServiceServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).

func NewKVServiceServer 

func NewKVServiceServer(svc KVService, opts ...interface{}) TwirpServer

NewKVServiceServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).

func NewPKIServiceServer 

func NewPKIServiceServer(svc PKIService, opts ...interface{}) TwirpServer

NewPKIServiceServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).

func NewTunnelServiceServer 

func NewTunnelServiceServer(svc TunnelService, opts ...interface{}) TwirpServer

NewTunnelServiceServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).

func NewVNodeServiceServer 

func NewVNodeServiceServer(svc VNodeService, opts ...interface{}) TwirpServer

NewVNodeServiceServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).

type UnpublishTunnelRequest 

type UnpublishTunnelRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*UnpublishTunnelRequest) Descriptor deprecated 

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

Deprecated: Use UnpublishTunnelRequest.ProtoReflect.Descriptor instead.

func (*UnpublishTunnelRequest) GetHostname 

func (x *UnpublishTunnelRequest) GetHostname() string

func (*UnpublishTunnelRequest) MarshalToSizedBufferVT 

func (m *UnpublishTunnelRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UnpublishTunnelRequest) MarshalToVT 

func (m *UnpublishTunnelRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UnpublishTunnelRequest) MarshalVT 

func (m *UnpublishTunnelRequest) MarshalVT() (dAtA []byte, err error)

func (*UnpublishTunnelRequest) ProtoMessage 

func (*UnpublishTunnelRequest) ProtoMessage()

func (*UnpublishTunnelRequest) ProtoReflect 

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

func (*UnpublishTunnelRequest) Reset 

func (x *UnpublishTunnelRequest) Reset()

func (*UnpublishTunnelRequest) SizeVT 

func (m *UnpublishTunnelRequest) SizeVT() (n int)

func (*UnpublishTunnelRequest) String 

func (x *UnpublishTunnelRequest) String() string

func (*UnpublishTunnelRequest) UnmarshalVT 

func (m *UnpublishTunnelRequest) UnmarshalVT(dAtA []byte) error

type UnpublishTunnelResponse 

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

func (*UnpublishTunnelResponse) Descriptor deprecated 

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

Deprecated: Use UnpublishTunnelResponse.ProtoReflect.Descriptor instead.

func (*UnpublishTunnelResponse) MarshalToSizedBufferVT 

func (m *UnpublishTunnelResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UnpublishTunnelResponse) MarshalToVT 

func (m *UnpublishTunnelResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UnpublishTunnelResponse) MarshalVT 

func (m *UnpublishTunnelResponse) MarshalVT() (dAtA []byte, err error)

func (*UnpublishTunnelResponse) ProtoMessage 

func (*UnpublishTunnelResponse) ProtoMessage()

func (*UnpublishTunnelResponse) ProtoReflect 

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

func (*UnpublishTunnelResponse) Reset 

func (x *UnpublishTunnelResponse) Reset()

func (*UnpublishTunnelResponse) SizeVT 

func (m *UnpublishTunnelResponse) SizeVT() (n int)

func (*UnpublishTunnelResponse) String 

func (x *UnpublishTunnelResponse) String() string

func (*UnpublishTunnelResponse) UnmarshalVT 

func (m *UnpublishTunnelResponse) UnmarshalVT(dAtA []byte) error

type VNodeService 

type VNodeService interface {
	Identity(context.Context, *IdentityRequest) (*IdentityResponse, error)

	Ping(context.Context, *PingRequest) (*PingResponse, error)

	Notify(context.Context, *NotifyRequest) (*NotifyResponse, error)

	FindSuccessor(context.Context, *FindSuccessorRequest) (*FindSuccessorResponse, error)

	GetSuccessors(context.Context, *GetSuccessorsRequest) (*GetSuccessorsResponse, error)

	GetPredecessor(context.Context, *GetPredecessorRequest) (*GetPredecessorResponse, error)

	RequestToJoin(context.Context, *RequestToJoinRequest) (*RequestToJoinResponse, error)

	FinishJoin(context.Context, *MembershipConclusionRequest) (*MembershipConclusionResponse, error)

	RequestToLeave(context.Context, *RequestToLeaveRequest) (*RequestToLeaveResponse, error)

	FinishLeave(context.Context, *MembershipConclusionRequest) (*MembershipConclusionResponse, error)
}

func NewVNodeServiceJSONClient 

func NewVNodeServiceJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) VNodeService

NewVNodeServiceJSONClient creates a JSON client that implements the VNodeService interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewVNodeServiceProtobufClient 

func NewVNodeServiceProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) VNodeService

NewVNodeServiceProtobufClient creates a Protobuf client that implements the VNodeService interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type ValidateRequest 

type ValidateRequest struct {
	Proof    *ProofOfWork `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	Hostname string       `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateRequest) Descriptor deprecated 

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

Deprecated: Use ValidateRequest.ProtoReflect.Descriptor instead.

func (*ValidateRequest) GetHostname 

func (x *ValidateRequest) GetHostname() string

func (*ValidateRequest) GetProof 

func (x *ValidateRequest) GetProof() *ProofOfWork

func (*ValidateRequest) MarshalToSizedBufferVT 

func (m *ValidateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateRequest) MarshalToVT 

func (m *ValidateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateRequest) MarshalVT 

func (m *ValidateRequest) MarshalVT() (dAtA []byte, err error)

func (*ValidateRequest) ProtoMessage 

func (*ValidateRequest) ProtoMessage()

func (*ValidateRequest) ProtoReflect 

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

func (*ValidateRequest) Reset 

func (x *ValidateRequest) Reset()

func (*ValidateRequest) SizeVT 

func (m *ValidateRequest) SizeVT() (n int)

func (*ValidateRequest) String 

func (x *ValidateRequest) String() string

func (*ValidateRequest) UnmarshalVT 

func (m *ValidateRequest) UnmarshalVT(dAtA []byte) error

type ValidateResponse 

type ValidateResponse struct {
	Apex string `protobuf:"bytes,1,opt,name=apex,proto3" json:"apex,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateResponse) Descriptor deprecated 

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

Deprecated: Use ValidateResponse.ProtoReflect.Descriptor instead.

func (*ValidateResponse) GetApex 

func (x *ValidateResponse) GetApex() string

func (*ValidateResponse) MarshalToSizedBufferVT 

func (m *ValidateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidateResponse) MarshalToVT 

func (m *ValidateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ValidateResponse) MarshalVT 

func (m *ValidateResponse) MarshalVT() (dAtA []byte, err error)

func (*ValidateResponse) ProtoMessage 

func (*ValidateResponse) ProtoMessage()

func (*ValidateResponse) ProtoReflect 

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

func (*ValidateResponse) Reset 

func (x *ValidateResponse) Reset()

func (*ValidateResponse) SizeVT 

func (m *ValidateResponse) SizeVT() (n int)

func (*ValidateResponse) String 

func (x *ValidateResponse) String() string

func (*ValidateResponse) UnmarshalVT 

func (m *ValidateResponse) UnmarshalVT(dAtA []byte) error

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.