altsproto

package
v0.0.0-...-015ad48 Latest Latest
Warning

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

Go to latest
Published: Jul 21, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	HandshakerService_DoHandshake_FullMethodName = "/grpc.alts.HandshakerService/DoHandshake"
)

Variables

View Source
var (
	SecurityLevel_name = map[int32]string{
		0: "SECURITY_NONE",
		1: "INTEGRITY_ONLY",
		2: "INTEGRITY_AND_PRIVACY",
	}
	SecurityLevel_value = map[string]int32{
		"SECURITY_NONE":         0,
		"INTEGRITY_ONLY":        1,
		"INTEGRITY_AND_PRIVACY": 2,
	}
)

Enum value maps for SecurityLevel.

View Source
var (
	HandshakeProtocol_name = map[int32]string{
		0: "HANDSHAKE_PROTOCOL_UNSPECIFIED",
		1: "TLS",
		2: "ALTS",
	}
	HandshakeProtocol_value = map[string]int32{
		"HANDSHAKE_PROTOCOL_UNSPECIFIED": 0,
		"TLS":                            1,
		"ALTS":                           2,
	}
)

Enum value maps for HandshakeProtocol.

View Source
var (
	NetworkProtocol_name = map[int32]string{
		0: "NETWORK_PROTOCOL_UNSPECIFIED",
		1: "TCP",
		2: "UDP",
	}
	NetworkProtocol_value = map[string]int32{
		"NETWORK_PROTOCOL_UNSPECIFIED": 0,
		"TCP":                          1,
		"UDP":                          2,
	}
)

Enum value maps for NetworkProtocol.

View Source
var File_handshaker_proto protoreflect.FileDescriptor
View Source
var HandshakerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc.alts.HandshakerService",
	HandlerType: (*HandshakerServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DoHandshake",
			Handler:       _HandshakerService_DoHandshake_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "handshaker.proto",
}

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

Functions

func RegisterHandshakerServiceServer

func RegisterHandshakerServiceServer(s grpc.ServiceRegistrar, srv HandshakerServiceServer)

Types

type AltsContext

type AltsContext struct {

	// The application protocol negotiated for this connection.
	ApplicationProtocol string `protobuf:"bytes,1,opt,name=application_protocol,json=applicationProtocol,proto3" json:"application_protocol,omitempty"`
	// The record protocol negotiated for this connection.
	RecordProtocol string `protobuf:"bytes,2,opt,name=record_protocol,json=recordProtocol,proto3" json:"record_protocol,omitempty"`
	// The security level of the created secure channel.
	SecurityLevel SecurityLevel `` /* 130-byte string literal not displayed */
	// The peer service account.
	PeerServiceAccount string `protobuf:"bytes,4,opt,name=peer_service_account,json=peerServiceAccount,proto3" json:"peer_service_account,omitempty"`
	// The local service account.
	LocalServiceAccount string `protobuf:"bytes,5,opt,name=local_service_account,json=localServiceAccount,proto3" json:"local_service_account,omitempty"`
	// The RPC protocol versions supported by the peer.
	PeerRpcVersions *RpcProtocolVersions `protobuf:"bytes,6,opt,name=peer_rpc_versions,json=peerRpcVersions,proto3" json:"peer_rpc_versions,omitempty"`
	// Additional attributes of the peer.
	PeerAttributes map[string]string `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AltsContext) Descriptor deprecated

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

Deprecated: Use AltsContext.ProtoReflect.Descriptor instead.

func (*AltsContext) GetApplicationProtocol

func (x *AltsContext) GetApplicationProtocol() string

func (*AltsContext) GetLocalServiceAccount

func (x *AltsContext) GetLocalServiceAccount() string

func (*AltsContext) GetPeerAttributes

func (x *AltsContext) GetPeerAttributes() map[string]string

func (*AltsContext) GetPeerRpcVersions

func (x *AltsContext) GetPeerRpcVersions() *RpcProtocolVersions

func (*AltsContext) GetPeerServiceAccount

func (x *AltsContext) GetPeerServiceAccount() string

func (*AltsContext) GetRecordProtocol

func (x *AltsContext) GetRecordProtocol() string

func (*AltsContext) GetSecurityLevel

func (x *AltsContext) GetSecurityLevel() SecurityLevel

func (*AltsContext) ProtoMessage

func (*AltsContext) ProtoMessage()

func (*AltsContext) ProtoReflect

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

func (*AltsContext) Reset

func (x *AltsContext) Reset()

func (*AltsContext) String

func (x *AltsContext) String() string

type Endpoint

type Endpoint struct {

	// IP address. It should contain an IPv4 or IPv6 string literal, e.g.
	// "192.168.0.1" or "2001:db8::1".
	IpAddress string `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	// Port number.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Network protocol (e.g., TCP, UDP) associated with this endpoint.
	Protocol NetworkProtocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=grpc.alts.NetworkProtocol" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

func (*Endpoint) Descriptor deprecated

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetIpAddress

func (x *Endpoint) GetIpAddress() string

func (*Endpoint) GetPort

func (x *Endpoint) GetPort() int32

func (*Endpoint) GetProtocol

func (x *Endpoint) GetProtocol() NetworkProtocol

func (*Endpoint) ProtoMessage

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect

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

func (*Endpoint) Reset

func (x *Endpoint) Reset()

func (*Endpoint) String

func (x *Endpoint) String() string

type HandshakeProtocol

type HandshakeProtocol int32
const (
	// Default value.
	HandshakeProtocol_HANDSHAKE_PROTOCOL_UNSPECIFIED HandshakeProtocol = 0
	// TLS handshake protocol.
	HandshakeProtocol_TLS HandshakeProtocol = 1
	// Application Layer Transport Security handshake protocol.
	HandshakeProtocol_ALTS HandshakeProtocol = 2
)

func (HandshakeProtocol) Descriptor

func (HandshakeProtocol) Enum

func (HandshakeProtocol) EnumDescriptor deprecated

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

Deprecated: Use HandshakeProtocol.Descriptor instead.

func (HandshakeProtocol) Number

func (HandshakeProtocol) String

func (x HandshakeProtocol) String() string

func (HandshakeProtocol) Type

type HandshakerReq

type HandshakerReq struct {

	// Types that are assignable to ReqOneof:
	//
	//	*HandshakerReq_ClientStart
	//	*HandshakerReq_ServerStart
	//	*HandshakerReq_Next
	ReqOneof isHandshakerReq_ReqOneof `protobuf_oneof:"req_oneof"`
	// contains filtered or unexported fields
}

func (*HandshakerReq) Descriptor deprecated

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

Deprecated: Use HandshakerReq.ProtoReflect.Descriptor instead.

func (*HandshakerReq) GetClientStart

func (x *HandshakerReq) GetClientStart() *StartClientHandshakeReq

func (*HandshakerReq) GetNext

func (x *HandshakerReq) GetNext() *NextHandshakeMessageReq

func (*HandshakerReq) GetReqOneof

func (m *HandshakerReq) GetReqOneof() isHandshakerReq_ReqOneof

func (*HandshakerReq) GetServerStart

func (x *HandshakerReq) GetServerStart() *StartServerHandshakeReq

func (*HandshakerReq) ProtoMessage

func (*HandshakerReq) ProtoMessage()

func (*HandshakerReq) ProtoReflect

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

func (*HandshakerReq) Reset

func (x *HandshakerReq) Reset()

func (*HandshakerReq) String

func (x *HandshakerReq) String() string

type HandshakerReq_ClientStart

type HandshakerReq_ClientStart struct {
	ClientStart *StartClientHandshakeReq `protobuf:"bytes,1,opt,name=client_start,json=clientStart,proto3,oneof"`
}

type HandshakerReq_Next

type HandshakerReq_Next struct {
	Next *NextHandshakeMessageReq `protobuf:"bytes,3,opt,name=next,proto3,oneof"`
}

type HandshakerReq_ServerStart

type HandshakerReq_ServerStart struct {
	ServerStart *StartServerHandshakeReq `protobuf:"bytes,2,opt,name=server_start,json=serverStart,proto3,oneof"`
}

type HandshakerResp

type HandshakerResp struct {
	OutFrames     []byte            `protobuf:"bytes,1,opt,name=out_frames,json=outFrames,proto3" json:"out_frames,omitempty"`
	BytesConsumed uint32            `protobuf:"varint,2,opt,name=bytes_consumed,json=bytesConsumed,proto3" json:"bytes_consumed,omitempty"`
	Result        *HandshakerResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	Status        *HandshakerStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakerResp) Descriptor deprecated

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

Deprecated: Use HandshakerResp.ProtoReflect.Descriptor instead.

func (*HandshakerResp) GetBytesConsumed

func (x *HandshakerResp) GetBytesConsumed() uint32

func (*HandshakerResp) GetOutFrames

func (x *HandshakerResp) GetOutFrames() []byte

func (*HandshakerResp) GetResult

func (x *HandshakerResp) GetResult() *HandshakerResult

func (*HandshakerResp) GetStatus

func (x *HandshakerResp) GetStatus() *HandshakerStatus

func (*HandshakerResp) ProtoMessage

func (*HandshakerResp) ProtoMessage()

func (*HandshakerResp) ProtoReflect

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

func (*HandshakerResp) Reset

func (x *HandshakerResp) Reset()

func (*HandshakerResp) String

func (x *HandshakerResp) String() string

type HandshakerResult

type HandshakerResult struct {
	ApplicationProtocol string               `protobuf:"bytes,1,opt,name=application_protocol,json=applicationProtocol,proto3" json:"application_protocol,omitempty"`
	RecordProtocol      string               `protobuf:"bytes,2,opt,name=record_protocol,json=recordProtocol,proto3" json:"record_protocol,omitempty"`
	KeyData             []byte               `protobuf:"bytes,3,opt,name=key_data,json=keyData,proto3" json:"key_data,omitempty"`
	PeerIdentity        *Identity            `protobuf:"bytes,4,opt,name=peer_identity,json=peerIdentity,proto3" json:"peer_identity,omitempty"`
	LocalIdentity       *Identity            `protobuf:"bytes,5,opt,name=local_identity,json=localIdentity,proto3" json:"local_identity,omitempty"`
	KeepChannelOpen     bool                 `protobuf:"varint,6,opt,name=keep_channel_open,json=keepChannelOpen,proto3" json:"keep_channel_open,omitempty"`
	PeerRpcVersions     *RpcProtocolVersions `protobuf:"bytes,7,opt,name=peer_rpc_versions,json=peerRpcVersions,proto3" json:"peer_rpc_versions,omitempty"`
	MaxFrameSize        uint32               `protobuf:"varint,8,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakerResult) Descriptor deprecated

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

Deprecated: Use HandshakerResult.ProtoReflect.Descriptor instead.

func (*HandshakerResult) GetApplicationProtocol

func (x *HandshakerResult) GetApplicationProtocol() string

func (*HandshakerResult) GetKeepChannelOpen

func (x *HandshakerResult) GetKeepChannelOpen() bool

func (*HandshakerResult) GetKeyData

func (x *HandshakerResult) GetKeyData() []byte

func (*HandshakerResult) GetLocalIdentity

func (x *HandshakerResult) GetLocalIdentity() *Identity

func (*HandshakerResult) GetMaxFrameSize

func (x *HandshakerResult) GetMaxFrameSize() uint32

func (*HandshakerResult) GetPeerIdentity

func (x *HandshakerResult) GetPeerIdentity() *Identity

func (*HandshakerResult) GetPeerRpcVersions

func (x *HandshakerResult) GetPeerRpcVersions() *RpcProtocolVersions

func (*HandshakerResult) GetRecordProtocol

func (x *HandshakerResult) GetRecordProtocol() string

func (*HandshakerResult) ProtoMessage

func (*HandshakerResult) ProtoMessage()

func (*HandshakerResult) ProtoReflect

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

func (*HandshakerResult) Reset

func (x *HandshakerResult) Reset()

func (*HandshakerResult) String

func (x *HandshakerResult) String() string

type HandshakerServiceClient

type HandshakerServiceClient interface {
	DoHandshake(ctx context.Context, opts ...grpc.CallOption) (HandshakerService_DoHandshakeClient, error)
}

HandshakerServiceClient is the client API for HandshakerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type HandshakerServiceServer

type HandshakerServiceServer interface {
	DoHandshake(HandshakerService_DoHandshakeServer) error
}

HandshakerServiceServer is the server API for HandshakerService service. All implementations should embed UnimplementedHandshakerServiceServer for forward compatibility

type HandshakerService_DoHandshakeClient

type HandshakerService_DoHandshakeClient interface {
	Send(*HandshakerReq) error
	Recv() (*HandshakerResp, error)
	grpc.ClientStream
}

type HandshakerService_DoHandshakeServer

type HandshakerService_DoHandshakeServer interface {
	Send(*HandshakerResp) error
	Recv() (*HandshakerReq, error)
	grpc.ServerStream
}

type HandshakerStatus

type HandshakerStatus struct {
	Code    uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Details string `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakerStatus) Descriptor deprecated

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

Deprecated: Use HandshakerStatus.ProtoReflect.Descriptor instead.

func (*HandshakerStatus) GetCode

func (x *HandshakerStatus) GetCode() uint32

func (*HandshakerStatus) GetDetails

func (x *HandshakerStatus) GetDetails() string

func (*HandshakerStatus) ProtoMessage

func (*HandshakerStatus) ProtoMessage()

func (*HandshakerStatus) ProtoReflect

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

func (*HandshakerStatus) Reset

func (x *HandshakerStatus) Reset()

func (*HandshakerStatus) String

func (x *HandshakerStatus) String() string

type Identity

type Identity struct {

	// Types that are assignable to IdentityOneof:
	//
	//	*Identity_ServiceAccount
	//	*Identity_Hostname
	IdentityOneof isIdentity_IdentityOneof `protobuf_oneof:"identity_oneof"`
	// Additional attributes of the identity.
	Attributes  map[string]string ``                                                                                               /* 161-byte string literal not displayed */
	ServiceName string            `protobuf:"bytes,4,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` //新加的,后面考虑怎么去掉
	// contains filtered or unexported fields
}

func (*Identity) Descriptor deprecated

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

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity) GetAttributes

func (x *Identity) GetAttributes() map[string]string

func (*Identity) GetHostname

func (x *Identity) GetHostname() string

func (*Identity) GetIdentityOneof

func (m *Identity) GetIdentityOneof() isIdentity_IdentityOneof

func (*Identity) GetServiceAccount

func (x *Identity) GetServiceAccount() string

func (*Identity) GetServiceName

func (x *Identity) GetServiceName() string

func (*Identity) ProtoMessage

func (*Identity) ProtoMessage()

func (*Identity) ProtoReflect

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

func (*Identity) Reset

func (x *Identity) Reset()

func (*Identity) String

func (x *Identity) String() string

type Identity_Hostname

type Identity_Hostname struct {
	// Hostname of a connection endpoint.
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3,oneof"`
}

type Identity_ServiceAccount

type Identity_ServiceAccount struct {
	// Service account of a connection endpoint.
	ServiceAccount string `protobuf:"bytes,1,opt,name=service_account,json=serviceAccount,proto3,oneof"`
}

type NetworkProtocol

type NetworkProtocol int32
const (
	NetworkProtocol_NETWORK_PROTOCOL_UNSPECIFIED NetworkProtocol = 0
	NetworkProtocol_TCP                          NetworkProtocol = 1
	NetworkProtocol_UDP                          NetworkProtocol = 2
)

func (NetworkProtocol) Descriptor

func (NetworkProtocol) Enum

func (x NetworkProtocol) Enum() *NetworkProtocol

func (NetworkProtocol) EnumDescriptor deprecated

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

Deprecated: Use NetworkProtocol.Descriptor instead.

func (NetworkProtocol) Number

func (NetworkProtocol) String

func (x NetworkProtocol) String() string

func (NetworkProtocol) Type

type NextHandshakeMessageReq

type NextHandshakeMessageReq struct {
	InBytes          []byte `protobuf:"bytes,1,opt,name=in_bytes,json=inBytes,proto3" json:"in_bytes,omitempty"`
	NetworkLatencyMs uint32 `protobuf:"varint,2,opt,name=network_latency_ms,json=networkLatencyMs,proto3" json:"network_latency_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*NextHandshakeMessageReq) Descriptor deprecated

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

Deprecated: Use NextHandshakeMessageReq.ProtoReflect.Descriptor instead.

func (*NextHandshakeMessageReq) GetInBytes

func (x *NextHandshakeMessageReq) GetInBytes() []byte

func (*NextHandshakeMessageReq) GetNetworkLatencyMs

func (x *NextHandshakeMessageReq) GetNetworkLatencyMs() uint32

func (*NextHandshakeMessageReq) ProtoMessage

func (*NextHandshakeMessageReq) ProtoMessage()

func (*NextHandshakeMessageReq) ProtoReflect

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

func (*NextHandshakeMessageReq) Reset

func (x *NextHandshakeMessageReq) Reset()

func (*NextHandshakeMessageReq) String

func (x *NextHandshakeMessageReq) String() string

type RpcProtocolVersions

type RpcProtocolVersions struct {

	// Maximum supported RPC version.
	MaxRpcVersion *RpcProtocolVersions_Version `protobuf:"bytes,1,opt,name=max_rpc_version,json=maxRpcVersion,proto3" json:"max_rpc_version,omitempty"`
	// Minimum supported RPC version.
	MinRpcVersion *RpcProtocolVersions_Version `protobuf:"bytes,2,opt,name=min_rpc_version,json=minRpcVersion,proto3" json:"min_rpc_version,omitempty"`
	// contains filtered or unexported fields
}

Max and min supported RPC protocol versions.

func (*RpcProtocolVersions) Descriptor deprecated

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

Deprecated: Use RpcProtocolVersions.ProtoReflect.Descriptor instead.

func (*RpcProtocolVersions) GetMaxRpcVersion

func (x *RpcProtocolVersions) GetMaxRpcVersion() *RpcProtocolVersions_Version

func (*RpcProtocolVersions) GetMinRpcVersion

func (x *RpcProtocolVersions) GetMinRpcVersion() *RpcProtocolVersions_Version

func (*RpcProtocolVersions) ProtoMessage

func (*RpcProtocolVersions) ProtoMessage()

func (*RpcProtocolVersions) ProtoReflect

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

func (*RpcProtocolVersions) Reset

func (x *RpcProtocolVersions) Reset()

func (*RpcProtocolVersions) String

func (x *RpcProtocolVersions) String() string

type RpcProtocolVersions_Version

type RpcProtocolVersions_Version struct {
	Major uint32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
	Minor uint32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
	// contains filtered or unexported fields
}

RPC version contains a major version and a minor version.

func (*RpcProtocolVersions_Version) Descriptor deprecated

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

Deprecated: Use RpcProtocolVersions_Version.ProtoReflect.Descriptor instead.

func (*RpcProtocolVersions_Version) GetMajor

func (x *RpcProtocolVersions_Version) GetMajor() uint32

func (*RpcProtocolVersions_Version) GetMinor

func (x *RpcProtocolVersions_Version) GetMinor() uint32

func (*RpcProtocolVersions_Version) ProtoMessage

func (*RpcProtocolVersions_Version) ProtoMessage()

func (*RpcProtocolVersions_Version) ProtoReflect

func (*RpcProtocolVersions_Version) Reset

func (x *RpcProtocolVersions_Version) Reset()

func (*RpcProtocolVersions_Version) String

func (x *RpcProtocolVersions_Version) String() string

type SecurityLevel

type SecurityLevel int32
const (
	SecurityLevel_SECURITY_NONE         SecurityLevel = 0
	SecurityLevel_INTEGRITY_ONLY        SecurityLevel = 1
	SecurityLevel_INTEGRITY_AND_PRIVACY SecurityLevel = 2
)

func (SecurityLevel) Descriptor

func (SecurityLevel) Enum

func (x SecurityLevel) Enum() *SecurityLevel

func (SecurityLevel) EnumDescriptor deprecated

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

Deprecated: Use SecurityLevel.Descriptor instead.

func (SecurityLevel) Number

func (SecurityLevel) String

func (x SecurityLevel) String() string

func (SecurityLevel) Type

type ServerHandshakeParameters

type ServerHandshakeParameters struct {
	RecordProtocols []string    `protobuf:"bytes,1,rep,name=record_protocols,json=recordProtocols,proto3" json:"record_protocols,omitempty"`
	LocalIdentities []*Identity `protobuf:"bytes,2,rep,name=local_identities,json=localIdentities,proto3" json:"local_identities,omitempty"`
	Token           *string     `protobuf:"bytes,3,opt,name=token,proto3,oneof" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerHandshakeParameters) Descriptor deprecated

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

Deprecated: Use ServerHandshakeParameters.ProtoReflect.Descriptor instead.

func (*ServerHandshakeParameters) GetLocalIdentities

func (x *ServerHandshakeParameters) GetLocalIdentities() []*Identity

func (*ServerHandshakeParameters) GetRecordProtocols

func (x *ServerHandshakeParameters) GetRecordProtocols() []string

func (*ServerHandshakeParameters) GetToken

func (x *ServerHandshakeParameters) GetToken() string

func (*ServerHandshakeParameters) ProtoMessage

func (*ServerHandshakeParameters) ProtoMessage()

func (*ServerHandshakeParameters) ProtoReflect

func (*ServerHandshakeParameters) Reset

func (x *ServerHandshakeParameters) Reset()

func (*ServerHandshakeParameters) String

func (x *ServerHandshakeParameters) String() string

type StartClientHandshakeReq

type StartClientHandshakeReq struct {
	HandshakeSecurityProtocol HandshakeProtocol    `` /* 172-byte string literal not displayed */
	ApplicationProtocols      []string             `protobuf:"bytes,2,rep,name=application_protocols,json=applicationProtocols,proto3" json:"application_protocols,omitempty"`
	RecordProtocols           []string             `protobuf:"bytes,3,rep,name=record_protocols,json=recordProtocols,proto3" json:"record_protocols,omitempty"`
	TargetIdentities          []*Identity          `protobuf:"bytes,4,rep,name=target_identities,json=targetIdentities,proto3" json:"target_identities,omitempty"`
	LocalIdentity             *Identity            `protobuf:"bytes,5,opt,name=local_identity,json=localIdentity,proto3" json:"local_identity,omitempty"`
	LocalEndpoint             *Endpoint            `protobuf:"bytes,6,opt,name=local_endpoint,json=localEndpoint,proto3" json:"local_endpoint,omitempty"`
	RemoteEndpoint            *Endpoint            `protobuf:"bytes,7,opt,name=remote_endpoint,json=remoteEndpoint,proto3" json:"remote_endpoint,omitempty"`
	TargetName                string               `protobuf:"bytes,8,opt,name=target_name,json=targetName,proto3" json:"target_name,omitempty"`
	RpcVersions               *RpcProtocolVersions `protobuf:"bytes,9,opt,name=rpc_versions,json=rpcVersions,proto3" json:"rpc_versions,omitempty"`
	MaxFrameSize              uint32               `protobuf:"varint,10,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"`
	AccessToken               string               `protobuf:"bytes,11,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	// contains filtered or unexported fields
}

func (*StartClientHandshakeReq) Descriptor deprecated

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

Deprecated: Use StartClientHandshakeReq.ProtoReflect.Descriptor instead.

func (*StartClientHandshakeReq) GetAccessToken

func (x *StartClientHandshakeReq) GetAccessToken() string

func (*StartClientHandshakeReq) GetApplicationProtocols

func (x *StartClientHandshakeReq) GetApplicationProtocols() []string

func (*StartClientHandshakeReq) GetHandshakeSecurityProtocol

func (x *StartClientHandshakeReq) GetHandshakeSecurityProtocol() HandshakeProtocol

func (*StartClientHandshakeReq) GetLocalEndpoint

func (x *StartClientHandshakeReq) GetLocalEndpoint() *Endpoint

func (*StartClientHandshakeReq) GetLocalIdentity

func (x *StartClientHandshakeReq) GetLocalIdentity() *Identity

func (*StartClientHandshakeReq) GetMaxFrameSize

func (x *StartClientHandshakeReq) GetMaxFrameSize() uint32

func (*StartClientHandshakeReq) GetRecordProtocols

func (x *StartClientHandshakeReq) GetRecordProtocols() []string

func (*StartClientHandshakeReq) GetRemoteEndpoint

func (x *StartClientHandshakeReq) GetRemoteEndpoint() *Endpoint

func (*StartClientHandshakeReq) GetRpcVersions

func (x *StartClientHandshakeReq) GetRpcVersions() *RpcProtocolVersions

func (*StartClientHandshakeReq) GetTargetIdentities

func (x *StartClientHandshakeReq) GetTargetIdentities() []*Identity

func (*StartClientHandshakeReq) GetTargetName

func (x *StartClientHandshakeReq) GetTargetName() string

func (*StartClientHandshakeReq) ProtoMessage

func (*StartClientHandshakeReq) ProtoMessage()

func (*StartClientHandshakeReq) ProtoReflect

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

func (*StartClientHandshakeReq) Reset

func (x *StartClientHandshakeReq) Reset()

func (*StartClientHandshakeReq) String

func (x *StartClientHandshakeReq) String() string

type StartServerHandshakeReq

type StartServerHandshakeReq struct {
	ApplicationProtocols []string                             `protobuf:"bytes,1,rep,name=application_protocols,json=applicationProtocols,proto3" json:"application_protocols,omitempty"`
	HandshakeParameters  map[int32]*ServerHandshakeParameters `` /* 207-byte string literal not displayed */
	InBytes              []byte                               `protobuf:"bytes,3,opt,name=in_bytes,json=inBytes,proto3" json:"in_bytes,omitempty"`
	LocalEndpoint        *Endpoint                            `protobuf:"bytes,4,opt,name=local_endpoint,json=localEndpoint,proto3" json:"local_endpoint,omitempty"`
	RemoteEndpoint       *Endpoint                            `protobuf:"bytes,5,opt,name=remote_endpoint,json=remoteEndpoint,proto3" json:"remote_endpoint,omitempty"`
	RpcVersions          *RpcProtocolVersions                 `protobuf:"bytes,6,opt,name=rpc_versions,json=rpcVersions,proto3" json:"rpc_versions,omitempty"`
	MaxFrameSize         uint32                               `protobuf:"varint,7,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"`
	// contains filtered or unexported fields
}

func (*StartServerHandshakeReq) Descriptor deprecated

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

Deprecated: Use StartServerHandshakeReq.ProtoReflect.Descriptor instead.

func (*StartServerHandshakeReq) GetApplicationProtocols

func (x *StartServerHandshakeReq) GetApplicationProtocols() []string

func (*StartServerHandshakeReq) GetHandshakeParameters

func (x *StartServerHandshakeReq) GetHandshakeParameters() map[int32]*ServerHandshakeParameters

func (*StartServerHandshakeReq) GetInBytes

func (x *StartServerHandshakeReq) GetInBytes() []byte

func (*StartServerHandshakeReq) GetLocalEndpoint

func (x *StartServerHandshakeReq) GetLocalEndpoint() *Endpoint

func (*StartServerHandshakeReq) GetMaxFrameSize

func (x *StartServerHandshakeReq) GetMaxFrameSize() uint32

func (*StartServerHandshakeReq) GetRemoteEndpoint

func (x *StartServerHandshakeReq) GetRemoteEndpoint() *Endpoint

func (*StartServerHandshakeReq) GetRpcVersions

func (x *StartServerHandshakeReq) GetRpcVersions() *RpcProtocolVersions

func (*StartServerHandshakeReq) ProtoMessage

func (*StartServerHandshakeReq) ProtoMessage()

func (*StartServerHandshakeReq) ProtoReflect

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

func (*StartServerHandshakeReq) Reset

func (x *StartServerHandshakeReq) Reset()

func (*StartServerHandshakeReq) String

func (x *StartServerHandshakeReq) String() string

type UnimplementedHandshakerServiceServer

type UnimplementedHandshakerServiceServer struct {
}

UnimplementedHandshakerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedHandshakerServiceServer) DoHandshake

type UnsafeHandshakerServiceServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL