Documentation ¶
Index ¶
- Variables
- func RegisterHandshakerServiceServer(s *grpc.Server, srv HandshakerServiceServer)
- type AltsContext
- func (*AltsContext) Descriptor() ([]byte, []int)
- func (m *AltsContext) GetApplicationProtocol() string
- func (m *AltsContext) GetLocalServiceAccount() string
- func (m *AltsContext) GetPeerRpcVersions() *RpcProtocolVersions
- func (m *AltsContext) GetPeerServiceAccount() string
- func (m *AltsContext) GetRecordProtocol() string
- func (m *AltsContext) GetSecurityLevel() SecurityLevel
- func (*AltsContext) ProtoMessage()
- func (m *AltsContext) Reset()
- func (m *AltsContext) String() string
- func (m *AltsContext) XXX_DiscardUnknown()
- func (m *AltsContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *AltsContext) XXX_Merge(src proto.Message)
- func (m *AltsContext) XXX_Size() int
- func (m *AltsContext) XXX_Unmarshal(b []byte) error
- type Endpoint
- func (*Endpoint) Descriptor() ([]byte, []int)
- func (m *Endpoint) GetIpAddress() string
- func (m *Endpoint) GetPort() int32
- func (m *Endpoint) GetProtocol() NetworkProtocol
- func (*Endpoint) ProtoMessage()
- func (m *Endpoint) Reset()
- func (m *Endpoint) String() string
- func (m *Endpoint) XXX_DiscardUnknown()
- func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Endpoint) XXX_Merge(src proto.Message)
- func (m *Endpoint) XXX_Size() int
- func (m *Endpoint) XXX_Unmarshal(b []byte) error
- type HandshakeProtocol
- type HandshakerReq
- func (*HandshakerReq) Descriptor() ([]byte, []int)
- func (m *HandshakerReq) GetClientStart() *StartClientHandshakeReq
- func (m *HandshakerReq) GetNext() *NextHandshakeMessageReq
- func (m *HandshakerReq) GetReqOneof() isHandshakerReq_ReqOneof
- func (m *HandshakerReq) GetServerStart() *StartServerHandshakeReq
- func (*HandshakerReq) ProtoMessage()
- func (m *HandshakerReq) Reset()
- func (m *HandshakerReq) String() string
- func (m *HandshakerReq) XXX_DiscardUnknown()
- func (m *HandshakerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HandshakerReq) XXX_Merge(src proto.Message)
- func (*HandshakerReq) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *HandshakerReq) XXX_Size() int
- func (m *HandshakerReq) XXX_Unmarshal(b []byte) error
- type HandshakerReq_ClientStart
- type HandshakerReq_Next
- type HandshakerReq_ServerStart
- type HandshakerResp
- func (*HandshakerResp) Descriptor() ([]byte, []int)
- func (m *HandshakerResp) GetBytesConsumed() uint32
- func (m *HandshakerResp) GetOutFrames() []byte
- func (m *HandshakerResp) GetResult() *HandshakerResult
- func (m *HandshakerResp) GetStatus() *HandshakerStatus
- func (*HandshakerResp) ProtoMessage()
- func (m *HandshakerResp) Reset()
- func (m *HandshakerResp) String() string
- func (m *HandshakerResp) XXX_DiscardUnknown()
- func (m *HandshakerResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HandshakerResp) XXX_Merge(src proto.Message)
- func (m *HandshakerResp) XXX_Size() int
- func (m *HandshakerResp) XXX_Unmarshal(b []byte) error
- type HandshakerResult
- func (*HandshakerResult) Descriptor() ([]byte, []int)
- func (m *HandshakerResult) GetApplicationProtocol() string
- func (m *HandshakerResult) GetKeepChannelOpen() bool
- func (m *HandshakerResult) GetKeyData() []byte
- func (m *HandshakerResult) GetLocalIdentity() *Identity
- func (m *HandshakerResult) GetPeerIdentity() *Identity
- func (m *HandshakerResult) GetPeerRpcVersions() *RpcProtocolVersions
- func (m *HandshakerResult) GetRecordProtocol() string
- func (*HandshakerResult) ProtoMessage()
- func (m *HandshakerResult) Reset()
- func (m *HandshakerResult) String() string
- func (m *HandshakerResult) XXX_DiscardUnknown()
- func (m *HandshakerResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HandshakerResult) XXX_Merge(src proto.Message)
- func (m *HandshakerResult) XXX_Size() int
- func (m *HandshakerResult) XXX_Unmarshal(b []byte) error
- type HandshakerServiceClient
- type HandshakerServiceServer
- type HandshakerService_DoHandshakeClient
- type HandshakerService_DoHandshakeServer
- type HandshakerStatus
- func (*HandshakerStatus) Descriptor() ([]byte, []int)
- func (m *HandshakerStatus) GetCode() uint32
- func (m *HandshakerStatus) GetDetails() string
- func (*HandshakerStatus) ProtoMessage()
- func (m *HandshakerStatus) Reset()
- func (m *HandshakerStatus) String() string
- func (m *HandshakerStatus) XXX_DiscardUnknown()
- func (m *HandshakerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HandshakerStatus) XXX_Merge(src proto.Message)
- func (m *HandshakerStatus) XXX_Size() int
- func (m *HandshakerStatus) XXX_Unmarshal(b []byte) error
- type Identity
- func (*Identity) Descriptor() ([]byte, []int)
- func (m *Identity) GetHostname() string
- func (m *Identity) GetIdentityOneof() isIdentity_IdentityOneof
- func (m *Identity) GetServiceAccount() string
- func (*Identity) ProtoMessage()
- func (m *Identity) Reset()
- func (m *Identity) String() string
- func (m *Identity) XXX_DiscardUnknown()
- func (m *Identity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Identity) XXX_Merge(src proto.Message)
- func (*Identity) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Identity) XXX_Size() int
- func (m *Identity) XXX_Unmarshal(b []byte) error
- type Identity_Hostname
- type Identity_ServiceAccount
- type NetworkProtocol
- type NextHandshakeMessageReq
- func (*NextHandshakeMessageReq) Descriptor() ([]byte, []int)
- func (m *NextHandshakeMessageReq) GetInBytes() []byte
- func (*NextHandshakeMessageReq) ProtoMessage()
- func (m *NextHandshakeMessageReq) Reset()
- func (m *NextHandshakeMessageReq) String() string
- func (m *NextHandshakeMessageReq) XXX_DiscardUnknown()
- func (m *NextHandshakeMessageReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NextHandshakeMessageReq) XXX_Merge(src proto.Message)
- func (m *NextHandshakeMessageReq) XXX_Size() int
- func (m *NextHandshakeMessageReq) XXX_Unmarshal(b []byte) error
- type RpcProtocolVersions
- func (*RpcProtocolVersions) Descriptor() ([]byte, []int)
- func (m *RpcProtocolVersions) GetMaxRpcVersion() *RpcProtocolVersions_Version
- func (m *RpcProtocolVersions) GetMinRpcVersion() *RpcProtocolVersions_Version
- func (*RpcProtocolVersions) ProtoMessage()
- func (m *RpcProtocolVersions) Reset()
- func (m *RpcProtocolVersions) String() string
- func (m *RpcProtocolVersions) XXX_DiscardUnknown()
- func (m *RpcProtocolVersions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RpcProtocolVersions) XXX_Merge(src proto.Message)
- func (m *RpcProtocolVersions) XXX_Size() int
- func (m *RpcProtocolVersions) XXX_Unmarshal(b []byte) error
- type RpcProtocolVersions_Version
- func (*RpcProtocolVersions_Version) Descriptor() ([]byte, []int)
- func (m *RpcProtocolVersions_Version) GetMajor() uint32
- func (m *RpcProtocolVersions_Version) GetMinor() uint32
- func (*RpcProtocolVersions_Version) ProtoMessage()
- func (m *RpcProtocolVersions_Version) Reset()
- func (m *RpcProtocolVersions_Version) String() string
- func (m *RpcProtocolVersions_Version) XXX_DiscardUnknown()
- func (m *RpcProtocolVersions_Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RpcProtocolVersions_Version) XXX_Merge(src proto.Message)
- func (m *RpcProtocolVersions_Version) XXX_Size() int
- func (m *RpcProtocolVersions_Version) XXX_Unmarshal(b []byte) error
- type SecurityLevel
- type ServerHandshakeParameters
- func (*ServerHandshakeParameters) Descriptor() ([]byte, []int)
- func (m *ServerHandshakeParameters) GetLocalIdentities() []*Identity
- func (m *ServerHandshakeParameters) GetRecordProtocols() []string
- func (*ServerHandshakeParameters) ProtoMessage()
- func (m *ServerHandshakeParameters) Reset()
- func (m *ServerHandshakeParameters) String() string
- func (m *ServerHandshakeParameters) XXX_DiscardUnknown()
- func (m *ServerHandshakeParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ServerHandshakeParameters) XXX_Merge(src proto.Message)
- func (m *ServerHandshakeParameters) XXX_Size() int
- func (m *ServerHandshakeParameters) XXX_Unmarshal(b []byte) error
- type StartClientHandshakeReq
- func (*StartClientHandshakeReq) Descriptor() ([]byte, []int)
- func (m *StartClientHandshakeReq) GetApplicationProtocols() []string
- func (m *StartClientHandshakeReq) GetHandshakeSecurityProtocol() HandshakeProtocol
- func (m *StartClientHandshakeReq) GetLocalEndpoint() *Endpoint
- func (m *StartClientHandshakeReq) GetLocalIdentity() *Identity
- func (m *StartClientHandshakeReq) GetRecordProtocols() []string
- func (m *StartClientHandshakeReq) GetRemoteEndpoint() *Endpoint
- func (m *StartClientHandshakeReq) GetRpcVersions() *RpcProtocolVersions
- func (m *StartClientHandshakeReq) GetTargetIdentities() []*Identity
- func (m *StartClientHandshakeReq) GetTargetName() string
- func (*StartClientHandshakeReq) ProtoMessage()
- func (m *StartClientHandshakeReq) Reset()
- func (m *StartClientHandshakeReq) String() string
- func (m *StartClientHandshakeReq) XXX_DiscardUnknown()
- func (m *StartClientHandshakeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StartClientHandshakeReq) XXX_Merge(src proto.Message)
- func (m *StartClientHandshakeReq) XXX_Size() int
- func (m *StartClientHandshakeReq) XXX_Unmarshal(b []byte) error
- type StartServerHandshakeReq
- func (*StartServerHandshakeReq) Descriptor() ([]byte, []int)
- func (m *StartServerHandshakeReq) GetApplicationProtocols() []string
- func (m *StartServerHandshakeReq) GetHandshakeParameters() map[int32]*ServerHandshakeParameters
- func (m *StartServerHandshakeReq) GetInBytes() []byte
- func (m *StartServerHandshakeReq) GetLocalEndpoint() *Endpoint
- func (m *StartServerHandshakeReq) GetRemoteEndpoint() *Endpoint
- func (m *StartServerHandshakeReq) GetRpcVersions() *RpcProtocolVersions
- func (*StartServerHandshakeReq) ProtoMessage()
- func (m *StartServerHandshakeReq) Reset()
- func (m *StartServerHandshakeReq) String() string
- func (m *StartServerHandshakeReq) XXX_DiscardUnknown()
- func (m *StartServerHandshakeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StartServerHandshakeReq) XXX_Merge(src proto.Message)
- func (m *StartServerHandshakeReq) XXX_Size() int
- func (m *StartServerHandshakeReq) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var HandshakeProtocol_name = map[int32]string{
0: "HANDSHAKE_PROTOCOL_UNSPECIFIED",
1: "TLS",
2: "ALTS",
}
View Source
var HandshakeProtocol_value = map[string]int32{
"HANDSHAKE_PROTOCOL_UNSPECIFIED": 0,
"TLS": 1,
"ALTS": 2,
}
View Source
var NetworkProtocol_name = map[int32]string{
0: "NETWORK_PROTOCOL_UNSPECIFIED",
1: "TCP",
2: "UDP",
}
View Source
var NetworkProtocol_value = map[string]int32{
"NETWORK_PROTOCOL_UNSPECIFIED": 0,
"TCP": 1,
"UDP": 2,
}
View Source
var SecurityLevel_name = map[int32]string{
0: "SECURITY_NONE",
1: "INTEGRITY_ONLY",
2: "INTEGRITY_AND_PRIVACY",
}
View Source
var SecurityLevel_value = map[string]int32{
"SECURITY_NONE": 0,
"INTEGRITY_ONLY": 1,
"INTEGRITY_AND_PRIVACY": 2,
}
Functions ¶
func RegisterHandshakerServiceServer ¶
func RegisterHandshakerServiceServer(s *grpc.Server, 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 `` /* 129-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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AltsContext) Descriptor ¶
func (*AltsContext) Descriptor() ([]byte, []int)
func (*AltsContext) GetApplicationProtocol ¶
func (m *AltsContext) GetApplicationProtocol() string
func (*AltsContext) GetLocalServiceAccount ¶
func (m *AltsContext) GetLocalServiceAccount() string
func (*AltsContext) GetPeerRpcVersions ¶
func (m *AltsContext) GetPeerRpcVersions() *RpcProtocolVersions
func (*AltsContext) GetPeerServiceAccount ¶
func (m *AltsContext) GetPeerServiceAccount() string
func (*AltsContext) GetRecordProtocol ¶
func (m *AltsContext) GetRecordProtocol() string
func (*AltsContext) GetSecurityLevel ¶
func (m *AltsContext) GetSecurityLevel() SecurityLevel
func (*AltsContext) ProtoMessage ¶
func (*AltsContext) ProtoMessage()
func (*AltsContext) Reset ¶
func (m *AltsContext) Reset()
func (*AltsContext) String ¶
func (m *AltsContext) String() string
func (*AltsContext) XXX_DiscardUnknown ¶
func (m *AltsContext) XXX_DiscardUnknown()
func (*AltsContext) XXX_Marshal ¶
func (m *AltsContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AltsContext) XXX_Merge ¶
func (dst *AltsContext) XXX_Merge(src proto.Message)
func (*AltsContext) XXX_Size ¶
func (m *AltsContext) XXX_Size() int
func (*AltsContext) XXX_Unmarshal ¶
func (m *AltsContext) XXX_Unmarshal(b []byte) error
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.gcp.NetworkProtocol" json:"protocol,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Endpoint) Descriptor ¶
func (*Endpoint) GetIpAddress ¶
func (*Endpoint) GetProtocol ¶
func (m *Endpoint) GetProtocol() NetworkProtocol
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) XXX_DiscardUnknown ¶
func (m *Endpoint) XXX_DiscardUnknown()
func (*Endpoint) XXX_Marshal ¶
func (*Endpoint) XXX_Unmarshal ¶
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) EnumDescriptor ¶
func (HandshakeProtocol) EnumDescriptor() ([]byte, []int)
func (HandshakeProtocol) String ¶
func (x HandshakeProtocol) String() string
type HandshakerReq ¶
type HandshakerReq struct { // Types that are valid to be assigned to ReqOneof: // *HandshakerReq_ClientStart // *HandshakerReq_ServerStart // *HandshakerReq_Next ReqOneof isHandshakerReq_ReqOneof `protobuf_oneof:"req_oneof"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HandshakerReq) Descriptor ¶
func (*HandshakerReq) Descriptor() ([]byte, []int)
func (*HandshakerReq) GetClientStart ¶
func (m *HandshakerReq) GetClientStart() *StartClientHandshakeReq
func (*HandshakerReq) GetNext ¶
func (m *HandshakerReq) GetNext() *NextHandshakeMessageReq
func (*HandshakerReq) GetReqOneof ¶
func (m *HandshakerReq) GetReqOneof() isHandshakerReq_ReqOneof
func (*HandshakerReq) GetServerStart ¶
func (m *HandshakerReq) GetServerStart() *StartServerHandshakeReq
func (*HandshakerReq) ProtoMessage ¶
func (*HandshakerReq) ProtoMessage()
func (*HandshakerReq) Reset ¶
func (m *HandshakerReq) Reset()
func (*HandshakerReq) String ¶
func (m *HandshakerReq) String() string
func (*HandshakerReq) XXX_DiscardUnknown ¶
func (m *HandshakerReq) XXX_DiscardUnknown()
func (*HandshakerReq) XXX_Marshal ¶
func (m *HandshakerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HandshakerReq) XXX_Merge ¶
func (dst *HandshakerReq) XXX_Merge(src proto.Message)
func (*HandshakerReq) XXX_OneofFuncs ¶
func (*HandshakerReq) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*HandshakerReq) XXX_Size ¶
func (m *HandshakerReq) XXX_Size() int
func (*HandshakerReq) XXX_Unmarshal ¶
func (m *HandshakerReq) XXX_Unmarshal(b []byte) error
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 { // Frames to be given to the peer for the NextHandshakeMessageReq. May be // empty if no out_frames have to be sent to the peer or if in_bytes in the // HandshakerReq are incomplete. All the non-empty out frames must be sent to // the peer even if the handshaker status is not OK as these frames may // contain the alert frames. OutFrames []byte `protobuf:"bytes,1,opt,name=out_frames,json=outFrames,proto3" json:"out_frames,omitempty"` // Number of bytes in the in_bytes consumed by the handshaker. It is possible // that part of in_bytes in HandshakerReq was unrelated to the handshake // process. BytesConsumed uint32 `protobuf:"varint,2,opt,name=bytes_consumed,json=bytesConsumed,proto3" json:"bytes_consumed,omitempty"` // This is set iff the handshake was successful. out_frames may still be set // to frames that needs to be forwarded to the peer. Result *HandshakerResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` // Status of the handshaker. Status *HandshakerStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HandshakerResp) Descriptor ¶
func (*HandshakerResp) Descriptor() ([]byte, []int)
func (*HandshakerResp) GetBytesConsumed ¶
func (m *HandshakerResp) GetBytesConsumed() uint32
func (*HandshakerResp) GetOutFrames ¶
func (m *HandshakerResp) GetOutFrames() []byte
func (*HandshakerResp) GetResult ¶
func (m *HandshakerResp) GetResult() *HandshakerResult
func (*HandshakerResp) GetStatus ¶
func (m *HandshakerResp) GetStatus() *HandshakerStatus
func (*HandshakerResp) ProtoMessage ¶
func (*HandshakerResp) ProtoMessage()
func (*HandshakerResp) Reset ¶
func (m *HandshakerResp) Reset()
func (*HandshakerResp) String ¶
func (m *HandshakerResp) String() string
func (*HandshakerResp) XXX_DiscardUnknown ¶
func (m *HandshakerResp) XXX_DiscardUnknown()
func (*HandshakerResp) XXX_Marshal ¶
func (m *HandshakerResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HandshakerResp) XXX_Merge ¶
func (dst *HandshakerResp) XXX_Merge(src proto.Message)
func (*HandshakerResp) XXX_Size ¶
func (m *HandshakerResp) XXX_Size() int
func (*HandshakerResp) XXX_Unmarshal ¶
func (m *HandshakerResp) XXX_Unmarshal(b []byte) error
type HandshakerResult ¶
type HandshakerResult 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"` // Cryptographic key data. The key data may be more than the key length // required for the record protocol, thus the client of the handshaker // service needs to truncate the key data into the right key length. KeyData []byte `protobuf:"bytes,3,opt,name=key_data,json=keyData,proto3" json:"key_data,omitempty"` // The authenticated identity of the peer. PeerIdentity *Identity `protobuf:"bytes,4,opt,name=peer_identity,json=peerIdentity,proto3" json:"peer_identity,omitempty"` // The local identity used in the handshake. LocalIdentity *Identity `protobuf:"bytes,5,opt,name=local_identity,json=localIdentity,proto3" json:"local_identity,omitempty"` // Indicate whether the handshaker service client should keep the channel // between the handshaker service open, e.g., in order to handle // post-handshake messages in the future. KeepChannelOpen bool `protobuf:"varint,6,opt,name=keep_channel_open,json=keepChannelOpen,proto3" json:"keep_channel_open,omitempty"` // The RPC protocol versions supported by the peer. PeerRpcVersions *RpcProtocolVersions `protobuf:"bytes,7,opt,name=peer_rpc_versions,json=peerRpcVersions,proto3" json:"peer_rpc_versions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HandshakerResult) Descriptor ¶
func (*HandshakerResult) Descriptor() ([]byte, []int)
func (*HandshakerResult) GetApplicationProtocol ¶
func (m *HandshakerResult) GetApplicationProtocol() string
func (*HandshakerResult) GetKeepChannelOpen ¶
func (m *HandshakerResult) GetKeepChannelOpen() bool
func (*HandshakerResult) GetKeyData ¶
func (m *HandshakerResult) GetKeyData() []byte
func (*HandshakerResult) GetLocalIdentity ¶
func (m *HandshakerResult) GetLocalIdentity() *Identity
func (*HandshakerResult) GetPeerIdentity ¶
func (m *HandshakerResult) GetPeerIdentity() *Identity
func (*HandshakerResult) GetPeerRpcVersions ¶
func (m *HandshakerResult) GetPeerRpcVersions() *RpcProtocolVersions
func (*HandshakerResult) GetRecordProtocol ¶
func (m *HandshakerResult) GetRecordProtocol() string
func (*HandshakerResult) ProtoMessage ¶
func (*HandshakerResult) ProtoMessage()
func (*HandshakerResult) Reset ¶
func (m *HandshakerResult) Reset()
func (*HandshakerResult) String ¶
func (m *HandshakerResult) String() string
func (*HandshakerResult) XXX_DiscardUnknown ¶
func (m *HandshakerResult) XXX_DiscardUnknown()
func (*HandshakerResult) XXX_Marshal ¶
func (m *HandshakerResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HandshakerResult) XXX_Merge ¶
func (dst *HandshakerResult) XXX_Merge(src proto.Message)
func (*HandshakerResult) XXX_Size ¶
func (m *HandshakerResult) XXX_Size() int
func (*HandshakerResult) XXX_Unmarshal ¶
func (m *HandshakerResult) XXX_Unmarshal(b []byte) error
type HandshakerServiceClient ¶
type HandshakerServiceClient interface { // Handshaker service accepts a stream of handshaker request, returning a // stream of handshaker response. Client is expected to send exactly one // message with either client_start or server_start followed by one or more // messages with next. Each time client sends a request, the handshaker // service expects to respond. Client does not have to wait for service's // response before sending next request. 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://godoc.org/github.com/micro/grpc-go#ClientConn.NewStream.
func NewHandshakerServiceClient ¶
func NewHandshakerServiceClient(cc *grpc.ClientConn) HandshakerServiceClient
type HandshakerServiceServer ¶
type HandshakerServiceServer interface { // Handshaker service accepts a stream of handshaker request, returning a // stream of handshaker response. Client is expected to send exactly one // message with either client_start or server_start followed by one or more // messages with next. Each time client sends a request, the handshaker // service expects to respond. Client does not have to wait for service's // response before sending next request. DoHandshake(HandshakerService_DoHandshakeServer) error }
HandshakerServiceServer is the server API for HandshakerService service.
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 { // The status code. This could be the gRPC status code. Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // The status details. Details string `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HandshakerStatus) Descriptor ¶
func (*HandshakerStatus) Descriptor() ([]byte, []int)
func (*HandshakerStatus) GetCode ¶
func (m *HandshakerStatus) GetCode() uint32
func (*HandshakerStatus) GetDetails ¶
func (m *HandshakerStatus) GetDetails() string
func (*HandshakerStatus) ProtoMessage ¶
func (*HandshakerStatus) ProtoMessage()
func (*HandshakerStatus) Reset ¶
func (m *HandshakerStatus) Reset()
func (*HandshakerStatus) String ¶
func (m *HandshakerStatus) String() string
func (*HandshakerStatus) XXX_DiscardUnknown ¶
func (m *HandshakerStatus) XXX_DiscardUnknown()
func (*HandshakerStatus) XXX_Marshal ¶
func (m *HandshakerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HandshakerStatus) XXX_Merge ¶
func (dst *HandshakerStatus) XXX_Merge(src proto.Message)
func (*HandshakerStatus) XXX_Size ¶
func (m *HandshakerStatus) XXX_Size() int
func (*HandshakerStatus) XXX_Unmarshal ¶
func (m *HandshakerStatus) XXX_Unmarshal(b []byte) error
type Identity ¶
type Identity struct { // Types that are valid to be assigned to IdentityOneof: // *Identity_ServiceAccount // *Identity_Hostname IdentityOneof isIdentity_IdentityOneof `protobuf_oneof:"identity_oneof"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Identity) Descriptor ¶
func (*Identity) GetHostname ¶
func (*Identity) GetIdentityOneof ¶
func (m *Identity) GetIdentityOneof() isIdentity_IdentityOneof
func (*Identity) GetServiceAccount ¶
func (*Identity) ProtoMessage ¶
func (*Identity) ProtoMessage()
func (*Identity) XXX_DiscardUnknown ¶
func (m *Identity) XXX_DiscardUnknown()
func (*Identity) XXX_Marshal ¶
func (*Identity) XXX_OneofFuncs ¶
func (*Identity) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Identity) XXX_Unmarshal ¶
type Identity_Hostname ¶
type Identity_Hostname struct {
Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3,oneof"`
}
type Identity_ServiceAccount ¶
type Identity_ServiceAccount struct {
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) EnumDescriptor ¶
func (NetworkProtocol) EnumDescriptor() ([]byte, []int)
func (NetworkProtocol) String ¶
func (x NetworkProtocol) String() string
type NextHandshakeMessageReq ¶
type NextHandshakeMessageReq struct { // Bytes in out_frames returned from the peer's HandshakerResp. It is possible // that the peer's out_frames are split into multiple NextHandshakerMessageReq // messages. InBytes []byte `protobuf:"bytes,1,opt,name=in_bytes,json=inBytes,proto3" json:"in_bytes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NextHandshakeMessageReq) Descriptor ¶
func (*NextHandshakeMessageReq) Descriptor() ([]byte, []int)
func (*NextHandshakeMessageReq) GetInBytes ¶
func (m *NextHandshakeMessageReq) GetInBytes() []byte
func (*NextHandshakeMessageReq) ProtoMessage ¶
func (*NextHandshakeMessageReq) ProtoMessage()
func (*NextHandshakeMessageReq) Reset ¶
func (m *NextHandshakeMessageReq) Reset()
func (*NextHandshakeMessageReq) String ¶
func (m *NextHandshakeMessageReq) String() string
func (*NextHandshakeMessageReq) XXX_DiscardUnknown ¶
func (m *NextHandshakeMessageReq) XXX_DiscardUnknown()
func (*NextHandshakeMessageReq) XXX_Marshal ¶
func (m *NextHandshakeMessageReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NextHandshakeMessageReq) XXX_Merge ¶
func (dst *NextHandshakeMessageReq) XXX_Merge(src proto.Message)
func (*NextHandshakeMessageReq) XXX_Size ¶
func (m *NextHandshakeMessageReq) XXX_Size() int
func (*NextHandshakeMessageReq) XXX_Unmarshal ¶
func (m *NextHandshakeMessageReq) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Max and min supported RPC protocol versions.
func (*RpcProtocolVersions) Descriptor ¶
func (*RpcProtocolVersions) Descriptor() ([]byte, []int)
func (*RpcProtocolVersions) GetMaxRpcVersion ¶
func (m *RpcProtocolVersions) GetMaxRpcVersion() *RpcProtocolVersions_Version
func (*RpcProtocolVersions) GetMinRpcVersion ¶
func (m *RpcProtocolVersions) GetMinRpcVersion() *RpcProtocolVersions_Version
func (*RpcProtocolVersions) ProtoMessage ¶
func (*RpcProtocolVersions) ProtoMessage()
func (*RpcProtocolVersions) Reset ¶
func (m *RpcProtocolVersions) Reset()
func (*RpcProtocolVersions) String ¶
func (m *RpcProtocolVersions) String() string
func (*RpcProtocolVersions) XXX_DiscardUnknown ¶
func (m *RpcProtocolVersions) XXX_DiscardUnknown()
func (*RpcProtocolVersions) XXX_Marshal ¶
func (m *RpcProtocolVersions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RpcProtocolVersions) XXX_Merge ¶
func (dst *RpcProtocolVersions) XXX_Merge(src proto.Message)
func (*RpcProtocolVersions) XXX_Size ¶
func (m *RpcProtocolVersions) XXX_Size() int
func (*RpcProtocolVersions) XXX_Unmarshal ¶
func (m *RpcProtocolVersions) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RPC version contains a major version and a minor version.
func (*RpcProtocolVersions_Version) Descriptor ¶
func (*RpcProtocolVersions_Version) Descriptor() ([]byte, []int)
func (*RpcProtocolVersions_Version) GetMajor ¶
func (m *RpcProtocolVersions_Version) GetMajor() uint32
func (*RpcProtocolVersions_Version) GetMinor ¶
func (m *RpcProtocolVersions_Version) GetMinor() uint32
func (*RpcProtocolVersions_Version) ProtoMessage ¶
func (*RpcProtocolVersions_Version) ProtoMessage()
func (*RpcProtocolVersions_Version) Reset ¶
func (m *RpcProtocolVersions_Version) Reset()
func (*RpcProtocolVersions_Version) String ¶
func (m *RpcProtocolVersions_Version) String() string
func (*RpcProtocolVersions_Version) XXX_DiscardUnknown ¶
func (m *RpcProtocolVersions_Version) XXX_DiscardUnknown()
func (*RpcProtocolVersions_Version) XXX_Marshal ¶
func (m *RpcProtocolVersions_Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RpcProtocolVersions_Version) XXX_Merge ¶
func (dst *RpcProtocolVersions_Version) XXX_Merge(src proto.Message)
func (*RpcProtocolVersions_Version) XXX_Size ¶
func (m *RpcProtocolVersions_Version) XXX_Size() int
func (*RpcProtocolVersions_Version) XXX_Unmarshal ¶
func (m *RpcProtocolVersions_Version) XXX_Unmarshal(b []byte) error
type SecurityLevel ¶
type SecurityLevel int32
The security level of the created channel. The list is sorted in increasing level of security. This order must always be maintained.
const ( SecurityLevel_SECURITY_NONE SecurityLevel = 0 SecurityLevel_INTEGRITY_ONLY SecurityLevel = 1 SecurityLevel_INTEGRITY_AND_PRIVACY SecurityLevel = 2 )
func (SecurityLevel) EnumDescriptor ¶
func (SecurityLevel) EnumDescriptor() ([]byte, []int)
func (SecurityLevel) String ¶
func (x SecurityLevel) String() string
type ServerHandshakeParameters ¶
type ServerHandshakeParameters struct { // The record protocols supported by the server, e.g., // "ALTSRP_GCM_AES128". RecordProtocols []string `protobuf:"bytes,1,rep,name=record_protocols,json=recordProtocols,proto3" json:"record_protocols,omitempty"` // (Optional) A list of local identities supported by the server, if // specified. Otherwise, the handshaker chooses a default local identity. LocalIdentities []*Identity `protobuf:"bytes,2,rep,name=local_identities,json=localIdentities,proto3" json:"local_identities,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServerHandshakeParameters) Descriptor ¶
func (*ServerHandshakeParameters) Descriptor() ([]byte, []int)
func (*ServerHandshakeParameters) GetLocalIdentities ¶
func (m *ServerHandshakeParameters) GetLocalIdentities() []*Identity
func (*ServerHandshakeParameters) GetRecordProtocols ¶
func (m *ServerHandshakeParameters) GetRecordProtocols() []string
func (*ServerHandshakeParameters) ProtoMessage ¶
func (*ServerHandshakeParameters) ProtoMessage()
func (*ServerHandshakeParameters) Reset ¶
func (m *ServerHandshakeParameters) Reset()
func (*ServerHandshakeParameters) String ¶
func (m *ServerHandshakeParameters) String() string
func (*ServerHandshakeParameters) XXX_DiscardUnknown ¶
func (m *ServerHandshakeParameters) XXX_DiscardUnknown()
func (*ServerHandshakeParameters) XXX_Marshal ¶
func (m *ServerHandshakeParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerHandshakeParameters) XXX_Merge ¶
func (dst *ServerHandshakeParameters) XXX_Merge(src proto.Message)
func (*ServerHandshakeParameters) XXX_Size ¶
func (m *ServerHandshakeParameters) XXX_Size() int
func (*ServerHandshakeParameters) XXX_Unmarshal ¶
func (m *ServerHandshakeParameters) XXX_Unmarshal(b []byte) error
type StartClientHandshakeReq ¶
type StartClientHandshakeReq struct { // Handshake security protocol requested by the client. HandshakeSecurityProtocol HandshakeProtocol `` /* 171-byte string literal not displayed */ // The application protocols supported by the client, e.g., "h2" (for http2), // "grpc". ApplicationProtocols []string `protobuf:"bytes,2,rep,name=application_protocols,json=applicationProtocols,proto3" json:"application_protocols,omitempty"` // The record protocols supported by the client, e.g., // "ALTSRP_GCM_AES128". RecordProtocols []string `protobuf:"bytes,3,rep,name=record_protocols,json=recordProtocols,proto3" json:"record_protocols,omitempty"` // (Optional) Describes which server identities are acceptable by the client. // If target identities are provided and none of them matches the peer // identity of the server, handshake will fail. TargetIdentities []*Identity `protobuf:"bytes,4,rep,name=target_identities,json=targetIdentities,proto3" json:"target_identities,omitempty"` // (Optional) Application may specify a local identity. Otherwise, the // handshaker chooses a default local identity. LocalIdentity *Identity `protobuf:"bytes,5,opt,name=local_identity,json=localIdentity,proto3" json:"local_identity,omitempty"` // (Optional) Local endpoint information of the connection to the server, // such as local IP address, port number, and network protocol. LocalEndpoint *Endpoint `protobuf:"bytes,6,opt,name=local_endpoint,json=localEndpoint,proto3" json:"local_endpoint,omitempty"` // (Optional) Endpoint information of the remote server, such as IP address, // port number, and network protocol. RemoteEndpoint *Endpoint `protobuf:"bytes,7,opt,name=remote_endpoint,json=remoteEndpoint,proto3" json:"remote_endpoint,omitempty"` // (Optional) If target name is provided, a secure naming check is performed // to verify that the peer authenticated identity is indeed authorized to run // the target name. TargetName string `protobuf:"bytes,8,opt,name=target_name,json=targetName,proto3" json:"target_name,omitempty"` // (Optional) RPC protocol versions supported by the client. RpcVersions *RpcProtocolVersions `protobuf:"bytes,9,opt,name=rpc_versions,json=rpcVersions,proto3" json:"rpc_versions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartClientHandshakeReq) Descriptor ¶
func (*StartClientHandshakeReq) Descriptor() ([]byte, []int)
func (*StartClientHandshakeReq) GetApplicationProtocols ¶
func (m *StartClientHandshakeReq) GetApplicationProtocols() []string
func (*StartClientHandshakeReq) GetHandshakeSecurityProtocol ¶
func (m *StartClientHandshakeReq) GetHandshakeSecurityProtocol() HandshakeProtocol
func (*StartClientHandshakeReq) GetLocalEndpoint ¶
func (m *StartClientHandshakeReq) GetLocalEndpoint() *Endpoint
func (*StartClientHandshakeReq) GetLocalIdentity ¶
func (m *StartClientHandshakeReq) GetLocalIdentity() *Identity
func (*StartClientHandshakeReq) GetRecordProtocols ¶
func (m *StartClientHandshakeReq) GetRecordProtocols() []string
func (*StartClientHandshakeReq) GetRemoteEndpoint ¶
func (m *StartClientHandshakeReq) GetRemoteEndpoint() *Endpoint
func (*StartClientHandshakeReq) GetRpcVersions ¶
func (m *StartClientHandshakeReq) GetRpcVersions() *RpcProtocolVersions
func (*StartClientHandshakeReq) GetTargetIdentities ¶
func (m *StartClientHandshakeReq) GetTargetIdentities() []*Identity
func (*StartClientHandshakeReq) GetTargetName ¶
func (m *StartClientHandshakeReq) GetTargetName() string
func (*StartClientHandshakeReq) ProtoMessage ¶
func (*StartClientHandshakeReq) ProtoMessage()
func (*StartClientHandshakeReq) Reset ¶
func (m *StartClientHandshakeReq) Reset()
func (*StartClientHandshakeReq) String ¶
func (m *StartClientHandshakeReq) String() string
func (*StartClientHandshakeReq) XXX_DiscardUnknown ¶
func (m *StartClientHandshakeReq) XXX_DiscardUnknown()
func (*StartClientHandshakeReq) XXX_Marshal ¶
func (m *StartClientHandshakeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartClientHandshakeReq) XXX_Merge ¶
func (dst *StartClientHandshakeReq) XXX_Merge(src proto.Message)
func (*StartClientHandshakeReq) XXX_Size ¶
func (m *StartClientHandshakeReq) XXX_Size() int
func (*StartClientHandshakeReq) XXX_Unmarshal ¶
func (m *StartClientHandshakeReq) XXX_Unmarshal(b []byte) error
type StartServerHandshakeReq ¶
type StartServerHandshakeReq struct { // The application protocols supported by the server, e.g., "h2" (for http2), // "grpc". ApplicationProtocols []string `protobuf:"bytes,1,rep,name=application_protocols,json=applicationProtocols,proto3" json:"application_protocols,omitempty"` // Handshake parameters (record protocols and local identities supported by // the server) mapped by the handshake protocol. Each handshake security // protocol (e.g., TLS or ALTS) has its own set of record protocols and local // identities. Since protobuf does not support enum as key to the map, the key // to handshake_parameters is the integer value of HandshakeProtocol enum. HandshakeParameters map[int32]*ServerHandshakeParameters `` /* 207-byte string literal not displayed */ // Bytes in out_frames returned from the peer's HandshakerResp. It is possible // that the peer's out_frames are split into multiple HandshakReq messages. InBytes []byte `protobuf:"bytes,3,opt,name=in_bytes,json=inBytes,proto3" json:"in_bytes,omitempty"` // (Optional) Local endpoint information of the connection to the client, // such as local IP address, port number, and network protocol. LocalEndpoint *Endpoint `protobuf:"bytes,4,opt,name=local_endpoint,json=localEndpoint,proto3" json:"local_endpoint,omitempty"` // (Optional) Endpoint information of the remote client, such as IP address, // port number, and network protocol. RemoteEndpoint *Endpoint `protobuf:"bytes,5,opt,name=remote_endpoint,json=remoteEndpoint,proto3" json:"remote_endpoint,omitempty"` // (Optional) RPC protocol versions supported by the server. RpcVersions *RpcProtocolVersions `protobuf:"bytes,6,opt,name=rpc_versions,json=rpcVersions,proto3" json:"rpc_versions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartServerHandshakeReq) Descriptor ¶
func (*StartServerHandshakeReq) Descriptor() ([]byte, []int)
func (*StartServerHandshakeReq) GetApplicationProtocols ¶
func (m *StartServerHandshakeReq) GetApplicationProtocols() []string
func (*StartServerHandshakeReq) GetHandshakeParameters ¶
func (m *StartServerHandshakeReq) GetHandshakeParameters() map[int32]*ServerHandshakeParameters
func (*StartServerHandshakeReq) GetInBytes ¶
func (m *StartServerHandshakeReq) GetInBytes() []byte
func (*StartServerHandshakeReq) GetLocalEndpoint ¶
func (m *StartServerHandshakeReq) GetLocalEndpoint() *Endpoint
func (*StartServerHandshakeReq) GetRemoteEndpoint ¶
func (m *StartServerHandshakeReq) GetRemoteEndpoint() *Endpoint
func (*StartServerHandshakeReq) GetRpcVersions ¶
func (m *StartServerHandshakeReq) GetRpcVersions() *RpcProtocolVersions
func (*StartServerHandshakeReq) ProtoMessage ¶
func (*StartServerHandshakeReq) ProtoMessage()
func (*StartServerHandshakeReq) Reset ¶
func (m *StartServerHandshakeReq) Reset()
func (*StartServerHandshakeReq) String ¶
func (m *StartServerHandshakeReq) String() string
func (*StartServerHandshakeReq) XXX_DiscardUnknown ¶
func (m *StartServerHandshakeReq) XXX_DiscardUnknown()
func (*StartServerHandshakeReq) XXX_Marshal ¶
func (m *StartServerHandshakeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartServerHandshakeReq) XXX_Merge ¶
func (dst *StartServerHandshakeReq) XXX_Merge(src proto.Message)
func (*StartServerHandshakeReq) XXX_Size ¶
func (m *StartServerHandshakeReq) XXX_Size() int
func (*StartServerHandshakeReq) XXX_Unmarshal ¶
func (m *StartServerHandshakeReq) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.