grpc_gcp

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

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"`
	// Additional attributes of the peer.
	PeerAttributes       map[string]string `` /* 191-byte string literal not displayed */
	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) Descriptor() ([]byte, []int)

func (*Endpoint) GetIpAddress 

func (m *Endpoint) GetIpAddress() string

func (*Endpoint) GetPort 

func (m *Endpoint) GetPort() int32

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 (m *Endpoint) String() string

func (*Endpoint) XXX_DiscardUnknown 

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal 

func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Endpoint) XXX_Merge 

func (m *Endpoint) XXX_Merge(src proto.Message)

func (*Endpoint) XXX_Size 

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal 

func (m *Endpoint) XXX_Unmarshal(b []byte) error

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/code.aliyun.com/yjkj.ink/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 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 `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Identity) Descriptor 

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

func (*Identity) GetAttributes 

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

func (*Identity) GetHostname 

func (m *Identity) GetHostname() string

func (*Identity) GetIdentityOneof 

func (m *Identity) GetIdentityOneof() isIdentity_IdentityOneof

func (*Identity) GetServiceAccount 

func (m *Identity) GetServiceAccount() string

func (*Identity) ProtoMessage 

func (*Identity) ProtoMessage()

func (*Identity) Reset 

func (m *Identity) Reset()

func (*Identity) String 

func (m *Identity) String() string

func (*Identity) XXX_DiscardUnknown 

func (m *Identity) XXX_DiscardUnknown()

func (*Identity) XXX_Marshal 

func (m *Identity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Identity) XXX_Merge 

func (m *Identity) XXX_Merge(src proto.Message)

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 (m *Identity) XXX_Size() int

func (*Identity) XXX_Unmarshal 

func (m *Identity) XXX_Unmarshal(b []byte) error

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 `` /* 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"`
	// (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 `` /* 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"`
	// (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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.