package grpc_gcp
import "google.golang.org/grpc/credentials/alts/internal/proto/grpc_gcp"
Index ¶
- Variables
- func RegisterHandshakerServiceServer(s *grpc.Server, srv HandshakerServiceServer)
- func RegisterHandshakerServiceService(s grpc.ServiceRegistrar, srv *HandshakerServiceService)
- type AltsContext
- func (*AltsContext) Descriptor() ([]byte, []int)
- func (m *AltsContext) GetApplicationProtocol() string
- func (m *AltsContext) GetLocalServiceAccount() string
- func (m *AltsContext) GetPeerAttributes() map[string]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 (m *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 (m *Endpoint) XXX_Merge(src proto.Message)
- func (m *Endpoint) XXX_Size() int
- func (m *Endpoint) XXX_Unmarshal(b []byte) error
- type HandshakeProtocol
- func (HandshakeProtocol) EnumDescriptor() ([]byte, []int)
- func (x HandshakeProtocol) String() string
- 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 (m *HandshakerReq) XXX_Merge(src proto.Message)
- func (*HandshakerReq) XXX_OneofWrappers() []interface{}
- 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 (m *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) GetMaxFrameSize() uint32
- 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 (m *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 HandshakerServiceService
- 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 (m *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) GetAttributes() map[string]string
- 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 (m *Identity) XXX_Merge(src proto.Message)
- func (*Identity) XXX_OneofWrappers() []interface{}
- 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 (m *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 (m *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 (m *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 (m *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) GetMaxFrameSize() uint32
- 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 (m *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) GetMaxFrameSize() uint32
- 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 (m *StartServerHandshakeReq) XXX_Merge(src proto.Message)
- func (m *StartServerHandshakeReq) XXX_Size() int
- func (m *StartServerHandshakeReq) XXX_Unmarshal(b []byte) error
- type UnimplementedHandshakerServiceServer
- type UnstableHandshakerServiceService
Variables ¶
var HandshakeProtocol_name = map[int32]string{ 0: "HANDSHAKE_PROTOCOL_UNSPECIFIED", 1: "TLS", 2: "ALTS", }
var HandshakeProtocol_value = map[string]int32{ "HANDSHAKE_PROTOCOL_UNSPECIFIED": 0, "TLS": 1, "ALTS": 2, }
var NetworkProtocol_name = map[int32]string{ 0: "NETWORK_PROTOCOL_UNSPECIFIED", 1: "TCP", 2: "UDP", }
var NetworkProtocol_value = map[string]int32{ "NETWORK_PROTOCOL_UNSPECIFIED": 0, "TCP": 1, "UDP": 2, }
var SecurityLevel_name = map[int32]string{ 0: "SECURITY_NONE", 1: "INTEGRITY_ONLY", 2: "INTEGRITY_AND_PRIVACY", }
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)
func RegisterHandshakerServiceService ¶
func RegisterHandshakerServiceService(s grpc.ServiceRegistrar, srv *HandshakerServiceService)
RegisterHandshakerServiceService registers a service implementation with a gRPC server.
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 `protobuf:"varint,3,opt,name=security_level,json=securityLevel,proto3,enum=grpc.gcp.SecurityLevel" json:"security_level,omitempty"` // 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 `protobuf:"bytes,7,rep,name=peer_attributes,json=peerAttributes,proto3" json:"peer_attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 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) GetPeerAttributes ¶
func (m *AltsContext) GetPeerAttributes() map[string]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 (m *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) GetPort ¶
func (*Endpoint) GetProtocol ¶
func (m *Endpoint) GetProtocol() NetworkProtocol
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) Reset ¶
func (m *Endpoint) Reset()
func (*Endpoint) String ¶
func (*Endpoint) XXX_DiscardUnknown ¶
func (m *Endpoint) XXX_DiscardUnknown()
func (*Endpoint) XXX_Marshal ¶
func (*Endpoint) XXX_Merge ¶
func (*Endpoint) XXX_Size ¶
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 (m *HandshakerReq) XXX_Merge(src proto.Message)
func (*HandshakerReq) XXX_OneofWrappers ¶
func (*HandshakerReq) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers 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 (m *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"` // The maximum frame size of the peer. MaxFrameSize uint32 `protobuf:"varint,8,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,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) GetMaxFrameSize ¶
func (m *HandshakerResult) GetMaxFrameSize() uint32
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 (m *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/google.golang.org/grpc#ClientConn.NewStream.
func NewHandshakerServiceClient ¶
func NewHandshakerServiceClient(cc grpc.ClientConnInterface) 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 HandshakerServiceService ¶
type HandshakerServiceService struct { // 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 func(HandshakerService_DoHandshakeServer) error }
HandshakerServiceService is the service API for HandshakerService service. Fields should be assigned to their respective handler implementations only before RegisterHandshakerServiceService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.
func NewHandshakerServiceService ¶
func NewHandshakerServiceService(s interface{}) *HandshakerServiceService
NewHandshakerServiceService creates a new HandshakerServiceService containing the implemented methods of the HandshakerService service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.
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 (m *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"` // Additional attributes of the identity. Attributes map[string]string `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Identity) Descriptor ¶
func (*Identity) GetAttributes ¶
func (*Identity) GetHostname ¶
func (*Identity) GetIdentityOneof ¶
func (m *Identity) GetIdentityOneof() isIdentity_IdentityOneof
func (*Identity) GetServiceAccount ¶
func (*Identity) ProtoMessage ¶
func (*Identity) ProtoMessage()
func (*Identity) Reset ¶
func (m *Identity) Reset()
func (*Identity) String ¶
func (*Identity) XXX_DiscardUnknown ¶
func (m *Identity) XXX_DiscardUnknown()
func (*Identity) XXX_Marshal ¶
func (*Identity) XXX_Merge ¶
func (*Identity) XXX_OneofWrappers ¶
func (*Identity) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Identity) XXX_Size ¶
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 (m *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 (m *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 (m *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 (m *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 `protobuf:"varint,1,opt,name=handshake_security_protocol,json=handshakeSecurityProtocol,proto3,enum=grpc.gcp.HandshakeProtocol" json:"handshake_security_protocol,omitempty"` // 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"` // (Optional) Maximum frame size supported by the client. MaxFrameSize uint32 `protobuf:"varint,10,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,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) GetMaxFrameSize ¶
func (m *StartClientHandshakeReq) GetMaxFrameSize() uint32
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 (m *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 `protobuf:"bytes,2,rep,name=handshake_parameters,json=handshakeParameters,proto3" json:"handshake_parameters,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` // 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"` // (Optional) Maximum frame size supported by the server. MaxFrameSize uint32 `protobuf:"varint,7,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,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) GetMaxFrameSize ¶
func (m *StartServerHandshakeReq) GetMaxFrameSize() uint32
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 (m *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
type UnimplementedHandshakerServiceServer ¶
type UnimplementedHandshakerServiceServer struct { }
UnimplementedHandshakerServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedHandshakerServiceServer) DoHandshake ¶
func (*UnimplementedHandshakerServiceServer) DoHandshake(srv HandshakerService_DoHandshakeServer) error
type UnstableHandshakerServiceService ¶
type UnstableHandshakerServiceService 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 }
UnstableHandshakerServiceService is the service API for HandshakerService service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.
Source Files ¶
altscontext.pb.go handshaker.pb.go handshaker_grpc.pb.go transport_security_common.pb.go
- Version
- v1.33.0-dev
- Published
- Aug 25, 2020
- Platform
- linux/amd64
- Imports
- 7 packages
- Last checked
- 38 minutes ago –
Tools for package owners.