grpc_gcp

package
v1.33.0 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 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 added in v1.16.0 

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 added in v1.24.0 

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 added in v1.26.0 

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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
	// contains filtered or unexported methods
}

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

type HandshakerService_DoHandshakeClient 

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

type HandshakerService_DoHandshakeServer 

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

type HandshakerStatus 

type HandshakerStatus struct {
	// 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 added in v1.16.0 

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 added in v1.24.0 

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 added in v1.26.0 

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 added in v1.26.0 

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 added in v1.24.0 

type UnimplementedHandshakerServiceServer struct {
}

UnimplementedHandshakerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedHandshakerServiceServer) DoHandshake added in v1.24.0 

func (UnimplementedHandshakerServiceServer) DoHandshake(HandshakerService_DoHandshakeServer) error

type UnsafeHandshakerServiceServer added in v1.33.0 

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

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

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.