Documentation
¶
Overview ¶
Package grpc_gcp is a generated protocol buffer package.
It is generated from these files:
altscontext.proto handshaker.proto transport_security_common.proto
It has these top-level messages:
AltsContext Endpoint Identity StartClientHandshakeReq ServerHandshakeParameters StartServerHandshakeReq NextHandshakeMessageReq HandshakerReq HandshakerResult HandshakerStatus HandshakerResp RpcProtocolVersions
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
- type Endpoint
- 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 (*HandshakerReq) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) 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
- 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
- type HandshakerServiceClient
- type HandshakerServiceServer
- type HandshakerService_DoHandshakeClient
- type HandshakerService_DoHandshakeServer
- type HandshakerStatus
- 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 (*Identity) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Identity_Hostname
- type Identity_ServiceAccount
- type NetworkProtocol
- type NextHandshakeMessageReq
- 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
- 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
- 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
- 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
- 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
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" json:"application_protocol,omitempty"`
// The record protocol negotiated for this connection.
RecordProtocol string `protobuf:"bytes,2,opt,name=record_protocol,json=recordProtocol" json:"record_protocol,omitempty"`
// The security level of the created secure channel.
SecurityLevel SecurityLevel `protobuf:"varint,3,opt,name=security_level,json=securityLevel,enum=grpc.gcp.SecurityLevel" json:"security_level,omitempty"`
// The peer service account.
PeerServiceAccount string `protobuf:"bytes,4,opt,name=peer_service_account,json=peerServiceAccount" json:"peer_service_account,omitempty"`
// The local service account.
LocalServiceAccount string `protobuf:"bytes,5,opt,name=local_service_account,json=localServiceAccount" 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" json:"peer_rpc_versions,omitempty"`
}
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
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" json:"ip_address,omitempty"`
// Port number.
Port int32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
// Network protocol (e.g., TCP, UDP) associated with this endpoint.
Protocol NetworkProtocol `protobuf:"varint,3,opt,name=protocol,enum=grpc.gcp.NetworkProtocol" json:"protocol,omitempty"`
}
func (*Endpoint) Descriptor ¶
func (*Endpoint) GetIpAddress ¶
func (*Endpoint) GetProtocol ¶
func (m *Endpoint) GetProtocol() NetworkProtocol
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
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"`
}
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_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.
type HandshakerReq_ClientStart ¶
type HandshakerReq_ClientStart struct {
ClientStart *StartClientHandshakeReq `protobuf:"bytes,1,opt,name=client_start,json=clientStart,oneof"`
}
type HandshakerReq_Next ¶
type HandshakerReq_Next struct {
Next *NextHandshakeMessageReq `protobuf:"bytes,3,opt,name=next,oneof"`
}
type HandshakerReq_ServerStart ¶
type HandshakerReq_ServerStart struct {
ServerStart *StartServerHandshakeReq `protobuf:"bytes,2,opt,name=server_start,json=serverStart,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" 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" json:"result,omitempty"`
// Status of the handshaker.
Status *HandshakerStatus `protobuf:"bytes,4,opt,name=status" json:"status,omitempty"`
}
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
type HandshakerResult ¶
type HandshakerResult struct {
// The application protocol negotiated for this connection.
ApplicationProtocol string `protobuf:"bytes,1,opt,name=application_protocol,json=applicationProtocol" json:"application_protocol,omitempty"`
// The record protocol negotiated for this connection.
RecordProtocol string `protobuf:"bytes,2,opt,name=record_protocol,json=recordProtocol" 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" json:"peer_identity,omitempty"`
// The local identity used in the handshake.
LocalIdentity *Identity `protobuf:"bytes,5,opt,name=local_identity,json=localIdentity" 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" 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" json:"peer_rpc_versions,omitempty"`
}
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
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)
}
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
}
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" json:"code,omitempty"`
// The status details.
Details string `protobuf:"bytes,2,opt,name=details" json:"details,omitempty"`
}
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
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"`
}
func (*Identity) Descriptor ¶
func (*Identity) GetHostname ¶
func (*Identity) GetIdentityOneof ¶
func (m *Identity) GetIdentityOneof() isIdentity_IdentityOneof
func (*Identity) GetServiceAccount ¶
func (*Identity) ProtoMessage ¶
func (*Identity) ProtoMessage()
type Identity_Hostname ¶
type Identity_Hostname struct {
Hostname string `protobuf:"bytes,2,opt,name=hostname,oneof"`
}
type Identity_ServiceAccount ¶
type Identity_ServiceAccount struct {
ServiceAccount string `protobuf:"bytes,1,opt,name=service_account,json=serviceAccount,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"`
}
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
type RpcProtocolVersions ¶
type RpcProtocolVersions struct {
// Maximum supported RPC version.
MaxRpcVersion *RpcProtocolVersions_Version `protobuf:"bytes,1,opt,name=max_rpc_version,json=maxRpcVersion" json:"max_rpc_version,omitempty"`
// Minimum supported RPC version.
MinRpcVersion *RpcProtocolVersions_Version `protobuf:"bytes,2,opt,name=min_rpc_version,json=minRpcVersion" json:"min_rpc_version,omitempty"`
}
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
type RpcProtocolVersions_Version ¶
type RpcProtocolVersions_Version struct {
Major uint32 `protobuf:"varint,1,opt,name=major" json:"major,omitempty"`
Minor uint32 `protobuf:"varint,2,opt,name=minor" json:"minor,omitempty"`
}
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
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" 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" json:"local_identities,omitempty"`
}
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
type StartClientHandshakeReq ¶
type StartClientHandshakeReq struct {
// Handshake security protocol requested by the client.
HandshakeSecurityProtocol HandshakeProtocol `` /* 164-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" 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" 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" 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" 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" 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" 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" json:"target_name,omitempty"`
// (Optional) RPC protocol versions supported by the client.
RpcVersions *RpcProtocolVersions `protobuf:"bytes,9,opt,name=rpc_versions,json=rpcVersions" json:"rpc_versions,omitempty"`
}
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
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" 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 `` /* 186-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" 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" json:"remote_endpoint,omitempty"`
// (Optional) RPC protocol versions supported by the server.
RpcVersions *RpcProtocolVersions `protobuf:"bytes,6,opt,name=rpc_versions,json=rpcVersions" json:"rpc_versions,omitempty"`
}
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
Click to show internal directories.
Click to hide internal directories.