Movatterモバイル変換

[0]ホーム
URL:

grpc_gcp

package
v1.77.0Latest Latest
Warning

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

Go to latest Published: Nov 17, 2025 License:Apache-2.0Imports:9Imported by:0

Details

Repository

github.com/grpc/grpc-go

Links

Documentation

Index

Constants

View Source
const (HandshakerService_DoHandshake_FullMethodName = "/grpc.gcp.HandshakerService/DoHandshake")

Variables

View Source
var (HandshakeProtocol_name = map[int32]string{0: "HANDSHAKE_PROTOCOL_UNSPECIFIED",1: "TLS",2: "ALTS",}HandshakeProtocol_value = map[string]int32{"HANDSHAKE_PROTOCOL_UNSPECIFIED": 0,"TLS":                            1,"ALTS":                           2,})

Enum value maps for HandshakeProtocol.

View Source
var (NetworkProtocol_name = map[int32]string{0: "NETWORK_PROTOCOL_UNSPECIFIED",1: "TCP",2: "UDP",}NetworkProtocol_value = map[string]int32{"NETWORK_PROTOCOL_UNSPECIFIED": 0,"TCP":                          1,"UDP":                          2,})

Enum value maps for NetworkProtocol.

View Source
var (SecurityLevel_name = map[int32]string{0: "SECURITY_NONE",1: "INTEGRITY_ONLY",2: "INTEGRITY_AND_PRIVACY",}SecurityLevel_value = map[string]int32{"SECURITY_NONE":         0,"INTEGRITY_ONLY":        1,"INTEGRITY_AND_PRIVACY": 2,})

Enum value maps for SecurityLevel.

View Source
var File_grpc_gcp_altscontext_protoprotoreflect.FileDescriptor
View Source
var File_grpc_gcp_handshaker_protoprotoreflect.FileDescriptor
View Source
var File_grpc_gcp_transport_security_common_protoprotoreflect.FileDescriptor
View Source
var HandshakerService_ServiceDesc =grpc.ServiceDesc{ServiceName: "grpc.gcp.HandshakerService",HandlerType: (*HandshakerServiceServer)(nil),Methods:     []grpc.MethodDesc{},Streams: []grpc.StreamDesc{{StreamName:    "DoHandshake",Handler:       _HandshakerService_DoHandshake_Handler,ServerStreams:true,ClientStreams:true,},},Metadata: "grpc/gcp/handshaker.proto",}

HandshakerService_ServiceDesc is the grpc.ServiceDesc for HandshakerService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)

Functions

Types

typeAltsContext

type AltsContext struct {// The application protocol negotiated for this connection.ApplicationProtocolstring `protobuf:"bytes,1,opt,name=application_protocol,json=applicationProtocol,proto3" json:"application_protocol,omitempty"`// The record protocol negotiated for this connection.RecordProtocolstring `protobuf:"bytes,2,opt,name=record_protocol,json=recordProtocol,proto3" json:"record_protocol,omitempty"`// The security level of the created secure channel.SecurityLevelSecurityLevel ``/* 129-byte string literal not displayed */// The peer service account.PeerServiceAccountstring `protobuf:"bytes,4,opt,name=peer_service_account,json=peerServiceAccount,proto3" json:"peer_service_account,omitempty"`// The local service account.LocalServiceAccountstring `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 ``/* 177-byte string literal not displayed */// contains filtered or unexported fields}

func (*AltsContext)Descriptordeprecated

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

Deprecated: Use AltsContext.ProtoReflect.Descriptor instead.

func (*AltsContext)GetApplicationProtocol

func (x *AltsContext) GetApplicationProtocol()string

func (*AltsContext)GetLocalServiceAccount

func (x *AltsContext) GetLocalServiceAccount()string

func (*AltsContext)GetPeerAttributesadded inv1.16.0

func (x *AltsContext) GetPeerAttributes() map[string]string

func (*AltsContext)GetPeerRpcVersions

func (x *AltsContext) GetPeerRpcVersions() *RpcProtocolVersions

func (*AltsContext)GetPeerServiceAccount

func (x *AltsContext) GetPeerServiceAccount()string

func (*AltsContext)GetRecordProtocol

func (x *AltsContext) GetRecordProtocol()string

func (*AltsContext)GetSecurityLevel

func (x *AltsContext) GetSecurityLevel()SecurityLevel

func (*AltsContext)ProtoMessage

func (*AltsContext) ProtoMessage()

func (*AltsContext)ProtoReflectadded inv1.33.2

func (x *AltsContext) ProtoReflect()protoreflect.Message

func (*AltsContext)Reset

func (x *AltsContext) Reset()

func (*AltsContext)String

func (x *AltsContext) String()string

typeEndpoint

type Endpoint struct {// IP address. It should contain an IPv4 or IPv6 string literal, e.g.// "192.168.0.1" or "2001:db8::1".IpAddressstring `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`// Port number.Portint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`// Network protocol (e.g., TCP, UDP) associated with this endpoint.ProtocolNetworkProtocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=grpc.gcp.NetworkProtocol" json:"protocol,omitempty"`// contains filtered or unexported fields}

func (*Endpoint)Descriptordeprecated

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint)GetIpAddress

func (x *Endpoint) GetIpAddress()string

func (*Endpoint)GetPort

func (x *Endpoint) GetPort()int32

func (*Endpoint)GetProtocol

func (x *Endpoint) GetProtocol()NetworkProtocol

func (*Endpoint)ProtoMessage

func (*Endpoint) ProtoMessage()

func (*Endpoint)ProtoReflectadded inv1.33.2

func (x *Endpoint) ProtoReflect()protoreflect.Message

func (*Endpoint)Reset

func (x *Endpoint) Reset()

func (*Endpoint)String

func (x *Endpoint) String()string

typeHandshakeProtocol

type HandshakeProtocolint32
const (// Default value.HandshakeProtocol_HANDSHAKE_PROTOCOL_UNSPECIFIEDHandshakeProtocol = 0// TLS handshake protocol.HandshakeProtocol_TLSHandshakeProtocol = 1// Application Layer Transport Security handshake protocol.HandshakeProtocol_ALTSHandshakeProtocol = 2)

func (HandshakeProtocol)Descriptoradded inv1.33.2

func (HandshakeProtocol)Enumadded inv1.33.2

func (HandshakeProtocol)EnumDescriptordeprecated

func (HandshakeProtocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use HandshakeProtocol.Descriptor instead.

func (HandshakeProtocol)Numberadded inv1.33.2

func (HandshakeProtocol)String

func (xHandshakeProtocol) String()string

func (HandshakeProtocol)Typeadded inv1.33.2

typeHandshakerReq

type HandshakerReq struct {// Types that are valid to be assigned to ReqOneof:////*HandshakerReq_ClientStart//*HandshakerReq_ServerStart//*HandshakerReq_NextReqOneof isHandshakerReq_ReqOneof `protobuf_oneof:"req_oneof"`// contains filtered or unexported fields}

func (*HandshakerReq)Descriptordeprecated

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

Deprecated: Use HandshakerReq.ProtoReflect.Descriptor instead.

func (*HandshakerReq)GetClientStart

func (x *HandshakerReq) GetClientStart() *StartClientHandshakeReq

func (*HandshakerReq)GetNext

func (*HandshakerReq)GetReqOneof

func (x *HandshakerReq) GetReqOneof() isHandshakerReq_ReqOneof

func (*HandshakerReq)GetServerStart

func (x *HandshakerReq) GetServerStart() *StartServerHandshakeReq

func (*HandshakerReq)ProtoMessage

func (*HandshakerReq) ProtoMessage()

func (*HandshakerReq)ProtoReflectadded inv1.33.2

func (x *HandshakerReq) ProtoReflect()protoreflect.Message

func (*HandshakerReq)Reset

func (x *HandshakerReq) Reset()

func (*HandshakerReq)String

func (x *HandshakerReq) String()string

typeHandshakerReq_ClientStart

type HandshakerReq_ClientStart struct {// The start client handshake request message.ClientStart *StartClientHandshakeReq `protobuf:"bytes,1,opt,name=client_start,json=clientStart,proto3,oneof"`}

typeHandshakerReq_Next

type HandshakerReq_Next struct {// The next handshake request message.Next *NextHandshakeMessageReq `protobuf:"bytes,3,opt,name=next,proto3,oneof"`}

typeHandshakerReq_ServerStart

type HandshakerReq_ServerStart struct {// The start server handshake request message.ServerStart *StartServerHandshakeReq `protobuf:"bytes,2,opt,name=server_start,json=serverStart,proto3,oneof"`}

typeHandshakerResp

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.BytesConsumeduint32 `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"`// contains filtered or unexported fields}

func (*HandshakerResp)Descriptordeprecated

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

Deprecated: Use HandshakerResp.ProtoReflect.Descriptor instead.

func (*HandshakerResp)GetBytesConsumed

func (x *HandshakerResp) GetBytesConsumed()uint32

func (*HandshakerResp)GetOutFrames

func (x *HandshakerResp) GetOutFrames() []byte

func (*HandshakerResp)GetResult

func (x *HandshakerResp) GetResult() *HandshakerResult

func (*HandshakerResp)GetStatus

func (x *HandshakerResp) GetStatus() *HandshakerStatus

func (*HandshakerResp)ProtoMessage

func (*HandshakerResp) ProtoMessage()

func (*HandshakerResp)ProtoReflectadded inv1.33.2

func (x *HandshakerResp) ProtoReflect()protoreflect.Message

func (*HandshakerResp)Reset

func (x *HandshakerResp) Reset()

func (*HandshakerResp)String

func (x *HandshakerResp) String()string

typeHandshakerResult

type HandshakerResult struct {// The application protocol negotiated for this connection.ApplicationProtocolstring `protobuf:"bytes,1,opt,name=application_protocol,json=applicationProtocol,proto3" json:"application_protocol,omitempty"`// The record protocol negotiated for this connection.RecordProtocolstring `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.KeepChannelOpenbool `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.MaxFrameSizeuint32 `protobuf:"varint,8,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"`// (Optional) The transport protocol negotiated for this connection.TransportProtocol *NegotiatedTransportProtocol `protobuf:"bytes,9,opt,name=transport_protocol,json=transportProtocol,proto3" json:"transport_protocol,omitempty"`// contains filtered or unexported fields}

func (*HandshakerResult)Descriptordeprecated

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

Deprecated: Use HandshakerResult.ProtoReflect.Descriptor instead.

func (*HandshakerResult)GetApplicationProtocol

func (x *HandshakerResult) GetApplicationProtocol()string

func (*HandshakerResult)GetKeepChannelOpen

func (x *HandshakerResult) GetKeepChannelOpen()bool

func (*HandshakerResult)GetKeyData

func (x *HandshakerResult) GetKeyData() []byte

func (*HandshakerResult)GetLocalIdentity

func (x *HandshakerResult) GetLocalIdentity() *Identity

func (*HandshakerResult)GetMaxFrameSizeadded inv1.26.0

func (x *HandshakerResult) GetMaxFrameSize()uint32

func (*HandshakerResult)GetPeerIdentity

func (x *HandshakerResult) GetPeerIdentity() *Identity

func (*HandshakerResult)GetPeerRpcVersions

func (x *HandshakerResult) GetPeerRpcVersions() *RpcProtocolVersions

func (*HandshakerResult)GetRecordProtocol

func (x *HandshakerResult) GetRecordProtocol()string

func (*HandshakerResult)GetTransportProtocoladded inv1.73.0

func (x *HandshakerResult) GetTransportProtocol() *NegotiatedTransportProtocol

func (*HandshakerResult)ProtoMessage

func (*HandshakerResult) ProtoMessage()

func (*HandshakerResult)ProtoReflectadded inv1.33.2

func (x *HandshakerResult) ProtoReflect()protoreflect.Message

func (*HandshakerResult)Reset

func (x *HandshakerResult) Reset()

func (*HandshakerResult)String

func (x *HandshakerResult) String()string

typeHandshakerServiceClient

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(ctxcontext.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[HandshakerReq,HandshakerResp],error)}

HandshakerServiceClient is the client API for HandshakerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

typeHandshakerServiceServer

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(grpc.BidiStreamingServer[HandshakerReq,HandshakerResp])error// contains filtered or unexported methods}

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

typeHandshakerService_DoHandshakeClient

type HandshakerService_DoHandshakeClient =grpc.BidiStreamingClient[HandshakerReq,HandshakerResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeHandshakerService_DoHandshakeServer

type HandshakerService_DoHandshakeServer =grpc.BidiStreamingServer[HandshakerReq,HandshakerResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

typeHandshakerStatus

type HandshakerStatus struct {// The status code. This could be the gRPC status code.Codeuint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`// The status details.Detailsstring `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`// contains filtered or unexported fields}

func (*HandshakerStatus)Descriptordeprecated

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

Deprecated: Use HandshakerStatus.ProtoReflect.Descriptor instead.

func (*HandshakerStatus)GetCode

func (x *HandshakerStatus) GetCode()uint32

func (*HandshakerStatus)GetDetails

func (x *HandshakerStatus) GetDetails()string

func (*HandshakerStatus)ProtoMessage

func (*HandshakerStatus) ProtoMessage()

func (*HandshakerStatus)ProtoReflectadded inv1.33.2

func (x *HandshakerStatus) ProtoReflect()protoreflect.Message

func (*HandshakerStatus)Reset

func (x *HandshakerStatus) Reset()

func (*HandshakerStatus)String

func (x *HandshakerStatus) String()string

typeIdentity

type Identity struct {// Types that are valid to be assigned to IdentityOneof:////*Identity_ServiceAccount//*Identity_HostnameIdentityOneof isIdentity_IdentityOneof `protobuf_oneof:"identity_oneof"`// Additional attributes of the identity.Attributes map[string]string ``/* 147-byte string literal not displayed */// contains filtered or unexported fields}

func (*Identity)Descriptordeprecated

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

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity)GetAttributesadded inv1.16.0

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

func (*Identity)GetHostname

func (x *Identity) GetHostname()string

func (*Identity)GetIdentityOneof

func (x *Identity) GetIdentityOneof() isIdentity_IdentityOneof

func (*Identity)GetServiceAccount

func (x *Identity) GetServiceAccount()string

func (*Identity)ProtoMessage

func (*Identity) ProtoMessage()

func (*Identity)ProtoReflectadded inv1.33.2

func (x *Identity) ProtoReflect()protoreflect.Message

func (*Identity)Reset

func (x *Identity) Reset()

func (*Identity)String

func (x *Identity) String()string

typeIdentity_Hostname

type Identity_Hostname struct {// Hostname of a connection endpoint.Hostnamestring `protobuf:"bytes,2,opt,name=hostname,proto3,oneof"`}

typeIdentity_ServiceAccount

type Identity_ServiceAccount struct {// Service account of a connection endpoint.ServiceAccountstring `protobuf:"bytes,1,opt,name=service_account,json=serviceAccount,proto3,oneof"`}

typeNegotiatedTransportProtocoladded inv1.73.0

type NegotiatedTransportProtocol struct {TransportProtocolstring `protobuf:"bytes,1,opt,name=transport_protocol,json=transportProtocol,proto3" json:"transport_protocol,omitempty"`// contains filtered or unexported fields}

The negotiated transport protocol.

func (*NegotiatedTransportProtocol)Descriptordeprecatedadded inv1.73.0

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

Deprecated: Use NegotiatedTransportProtocol.ProtoReflect.Descriptor instead.

func (*NegotiatedTransportProtocol)GetTransportProtocoladded inv1.73.0

func (x *NegotiatedTransportProtocol) GetTransportProtocol()string

func (*NegotiatedTransportProtocol)ProtoMessageadded inv1.73.0

func (*NegotiatedTransportProtocol) ProtoMessage()

func (*NegotiatedTransportProtocol)ProtoReflectadded inv1.73.0

func (*NegotiatedTransportProtocol)Resetadded inv1.73.0

func (x *NegotiatedTransportProtocol) Reset()

func (*NegotiatedTransportProtocol)Stringadded inv1.73.0

typeNetworkProtocol

type NetworkProtocolint32
const (NetworkProtocol_NETWORK_PROTOCOL_UNSPECIFIEDNetworkProtocol = 0NetworkProtocol_TCPNetworkProtocol = 1NetworkProtocol_UDPNetworkProtocol = 2)

func (NetworkProtocol)Descriptoradded inv1.33.2

func (NetworkProtocol)Enumadded inv1.33.2

func (NetworkProtocol)EnumDescriptordeprecated

func (NetworkProtocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use NetworkProtocol.Descriptor instead.

func (NetworkProtocol)Numberadded inv1.33.2

func (NetworkProtocol)String

func (xNetworkProtocol) String()string

func (NetworkProtocol)Typeadded inv1.33.2

typeNextHandshakeMessageReq

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"`// Number of milliseconds between when the application send the last handshake// message to the peer and when the application received the current handshake// message (in the in_bytes field) from the peer.NetworkLatencyMsuint32 `protobuf:"varint,2,opt,name=network_latency_ms,json=networkLatencyMs,proto3" json:"network_latency_ms,omitempty"`// contains filtered or unexported fields}

func (*NextHandshakeMessageReq)Descriptordeprecated

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

Deprecated: Use NextHandshakeMessageReq.ProtoReflect.Descriptor instead.

func (*NextHandshakeMessageReq)GetInBytes

func (x *NextHandshakeMessageReq) GetInBytes() []byte

func (*NextHandshakeMessageReq)GetNetworkLatencyMsadded inv1.61.0

func (x *NextHandshakeMessageReq) GetNetworkLatencyMs()uint32

func (*NextHandshakeMessageReq)ProtoMessage

func (*NextHandshakeMessageReq) ProtoMessage()

func (*NextHandshakeMessageReq)ProtoReflectadded inv1.33.2

func (*NextHandshakeMessageReq)Reset

func (x *NextHandshakeMessageReq) Reset()

func (*NextHandshakeMessageReq)String

typeRpcProtocolVersions

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"`// contains filtered or unexported fields}

Max and min supported RPC protocol versions.

func (*RpcProtocolVersions)Descriptordeprecated

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

Deprecated: Use RpcProtocolVersions.ProtoReflect.Descriptor instead.

func (*RpcProtocolVersions)GetMaxRpcVersion

func (x *RpcProtocolVersions) GetMaxRpcVersion() *RpcProtocolVersions_Version

func (*RpcProtocolVersions)GetMinRpcVersion

func (x *RpcProtocolVersions) GetMinRpcVersion() *RpcProtocolVersions_Version

func (*RpcProtocolVersions)ProtoMessage

func (*RpcProtocolVersions) ProtoMessage()

func (*RpcProtocolVersions)ProtoReflectadded inv1.33.2

func (x *RpcProtocolVersions) ProtoReflect()protoreflect.Message

func (*RpcProtocolVersions)Reset

func (x *RpcProtocolVersions) Reset()

func (*RpcProtocolVersions)String

func (x *RpcProtocolVersions) String()string

typeRpcProtocolVersions_Version

type RpcProtocolVersions_Version struct {Majoruint32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`Minoruint32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`// contains filtered or unexported fields}

RPC version contains a major version and a minor version.

func (*RpcProtocolVersions_Version)Descriptordeprecated

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

Deprecated: Use RpcProtocolVersions_Version.ProtoReflect.Descriptor instead.

func (*RpcProtocolVersions_Version)GetMajor

func (*RpcProtocolVersions_Version)GetMinor

func (*RpcProtocolVersions_Version)ProtoMessage

func (*RpcProtocolVersions_Version) ProtoMessage()

func (*RpcProtocolVersions_Version)ProtoReflectadded inv1.33.2

func (*RpcProtocolVersions_Version)Reset

func (x *RpcProtocolVersions_Version) Reset()

func (*RpcProtocolVersions_Version)String

typeSecurityLevel

type SecurityLevelint32

The security level of the created channel. The list is sorted in increasinglevel of security. This order must always be maintained.

const (SecurityLevel_SECURITY_NONESecurityLevel = 0SecurityLevel_INTEGRITY_ONLYSecurityLevel = 1SecurityLevel_INTEGRITY_AND_PRIVACYSecurityLevel = 2)

func (SecurityLevel)Descriptoradded inv1.33.2

func (SecurityLevel)Enumadded inv1.33.2

func (SecurityLevel)EnumDescriptordeprecated

func (SecurityLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use SecurityLevel.Descriptor instead.

func (SecurityLevel)Numberadded inv1.33.2

func (SecurityLevel)String

func (xSecurityLevel) String()string

func (SecurityLevel)Typeadded inv1.33.2

typeServerHandshakeParameters

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"`// A token created by the caller only intended for use in// ALTS connections. The token should be used to authenticate to// the peer. The token MUST be strongly bound to the ALTS credentials// used to establish the connection that the token is sent over.Token *string `protobuf:"bytes,3,opt,name=token,proto3,oneof" json:"token,omitempty"`// contains filtered or unexported fields}

func (*ServerHandshakeParameters)Descriptordeprecated

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

Deprecated: Use ServerHandshakeParameters.ProtoReflect.Descriptor instead.

func (*ServerHandshakeParameters)GetLocalIdentities

func (x *ServerHandshakeParameters) GetLocalIdentities() []*Identity

func (*ServerHandshakeParameters)GetRecordProtocols

func (x *ServerHandshakeParameters) GetRecordProtocols() []string

func (*ServerHandshakeParameters)GetTokenadded inv1.64.0

func (x *ServerHandshakeParameters) GetToken()string

func (*ServerHandshakeParameters)ProtoMessage

func (*ServerHandshakeParameters) ProtoMessage()

func (*ServerHandshakeParameters)ProtoReflectadded inv1.33.2

func (*ServerHandshakeParameters)Reset

func (x *ServerHandshakeParameters) Reset()

func (*ServerHandshakeParameters)String

typeStartClientHandshakeReq

type StartClientHandshakeReq struct {// Handshake security protocol requested by the client.HandshakeSecurityProtocolHandshakeProtocol ``/* 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.TargetNamestring `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.MaxFrameSizeuint32 `protobuf:"varint,10,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"`// (Optional) An access token created by the caller only intended for use in// ALTS connections. The access token that should be used to authenticate to// the peer. The access token MUST be strongly bound to the ALTS credentials// used to establish the connection that the token is sent over.AccessTokenstring `protobuf:"bytes,11,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`// (Optional) Ordered transport protocol preferences supported by the client.TransportProtocolPreferences *TransportProtocolPreferences ``/* 148-byte string literal not displayed */// contains filtered or unexported fields}

func (*StartClientHandshakeReq)Descriptordeprecated

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

Deprecated: Use StartClientHandshakeReq.ProtoReflect.Descriptor instead.

func (*StartClientHandshakeReq)GetAccessTokenadded inv1.63.0

func (x *StartClientHandshakeReq) GetAccessToken()string

func (*StartClientHandshakeReq)GetApplicationProtocols

func (x *StartClientHandshakeReq) GetApplicationProtocols() []string

func (*StartClientHandshakeReq)GetHandshakeSecurityProtocol

func (x *StartClientHandshakeReq) GetHandshakeSecurityProtocol()HandshakeProtocol

func (*StartClientHandshakeReq)GetLocalEndpoint

func (x *StartClientHandshakeReq) GetLocalEndpoint() *Endpoint

func (*StartClientHandshakeReq)GetLocalIdentity

func (x *StartClientHandshakeReq) GetLocalIdentity() *Identity

func (*StartClientHandshakeReq)GetMaxFrameSizeadded inv1.26.0

func (x *StartClientHandshakeReq) GetMaxFrameSize()uint32

func (*StartClientHandshakeReq)GetRecordProtocols

func (x *StartClientHandshakeReq) GetRecordProtocols() []string

func (*StartClientHandshakeReq)GetRemoteEndpoint

func (x *StartClientHandshakeReq) GetRemoteEndpoint() *Endpoint

func (*StartClientHandshakeReq)GetRpcVersions

func (x *StartClientHandshakeReq) GetRpcVersions() *RpcProtocolVersions

func (*StartClientHandshakeReq)GetTargetIdentities

func (x *StartClientHandshakeReq) GetTargetIdentities() []*Identity

func (*StartClientHandshakeReq)GetTargetName

func (x *StartClientHandshakeReq) GetTargetName()string

func (*StartClientHandshakeReq)GetTransportProtocolPreferencesadded inv1.73.0

func (x *StartClientHandshakeReq) GetTransportProtocolPreferences() *TransportProtocolPreferences

func (*StartClientHandshakeReq)ProtoMessage

func (*StartClientHandshakeReq) ProtoMessage()

func (*StartClientHandshakeReq)ProtoReflectadded inv1.33.2

func (*StartClientHandshakeReq)Reset

func (x *StartClientHandshakeReq) Reset()

func (*StartClientHandshakeReq)String

typeStartServerHandshakeReq

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 ``/* 193-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 HandshakeReq 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.MaxFrameSizeuint32 `protobuf:"varint,7,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"`// (Optional) Transport protocol preferences supported by the server.TransportProtocolPreferences *TransportProtocolPreferences ``/* 147-byte string literal not displayed */// contains filtered or unexported fields}

func (*StartServerHandshakeReq)Descriptordeprecated

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

Deprecated: Use StartServerHandshakeReq.ProtoReflect.Descriptor instead.

func (*StartServerHandshakeReq)GetApplicationProtocols

func (x *StartServerHandshakeReq) GetApplicationProtocols() []string

func (*StartServerHandshakeReq)GetHandshakeParameters

func (x *StartServerHandshakeReq) GetHandshakeParameters() map[int32]*ServerHandshakeParameters

func (*StartServerHandshakeReq)GetInBytes

func (x *StartServerHandshakeReq) GetInBytes() []byte

func (*StartServerHandshakeReq)GetLocalEndpoint

func (x *StartServerHandshakeReq) GetLocalEndpoint() *Endpoint

func (*StartServerHandshakeReq)GetMaxFrameSizeadded inv1.26.0

func (x *StartServerHandshakeReq) GetMaxFrameSize()uint32

func (*StartServerHandshakeReq)GetRemoteEndpoint

func (x *StartServerHandshakeReq) GetRemoteEndpoint() *Endpoint

func (*StartServerHandshakeReq)GetRpcVersions

func (x *StartServerHandshakeReq) GetRpcVersions() *RpcProtocolVersions

func (*StartServerHandshakeReq)GetTransportProtocolPreferencesadded inv1.73.0

func (x *StartServerHandshakeReq) GetTransportProtocolPreferences() *TransportProtocolPreferences

func (*StartServerHandshakeReq)ProtoMessage

func (*StartServerHandshakeReq) ProtoMessage()

func (*StartServerHandshakeReq)ProtoReflectadded inv1.33.2

func (*StartServerHandshakeReq)Reset

func (x *StartServerHandshakeReq) Reset()

func (*StartServerHandshakeReq)String

typeTransportProtocolPreferencesadded inv1.73.0

type TransportProtocolPreferences struct {TransportProtocol []string `protobuf:"bytes,1,rep,name=transport_protocol,json=transportProtocol,proto3" json:"transport_protocol,omitempty"`// contains filtered or unexported fields}

The ordered list of protocols that the client wishes to use, or the setthat the server supports.

func (*TransportProtocolPreferences)Descriptordeprecatedadded inv1.73.0

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

Deprecated: Use TransportProtocolPreferences.ProtoReflect.Descriptor instead.

func (*TransportProtocolPreferences)GetTransportProtocoladded inv1.73.0

func (x *TransportProtocolPreferences) GetTransportProtocol() []string

func (*TransportProtocolPreferences)ProtoMessageadded inv1.73.0

func (*TransportProtocolPreferences) ProtoMessage()

func (*TransportProtocolPreferences)ProtoReflectadded inv1.73.0

func (*TransportProtocolPreferences)Resetadded inv1.73.0

func (*TransportProtocolPreferences)Stringadded inv1.73.0

typeUnimplementedHandshakerServiceServeradded inv1.24.0

type UnimplementedHandshakerServiceServer struct{}

UnimplementedHandshakerServiceServer must be embedded to haveforward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nilpointer dereference when methods are called.

func (UnimplementedHandshakerServiceServer)DoHandshakeadded inv1.24.0

typeUnsafeHandshakerServiceServeradded inv1.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 willresult in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f orF : Jump to
y orY : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic.Learn more.
[8]ページ先頭
©2009-2025 Movatter.jp