| // Copyright 2018 The gRPC Authors |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| // The canonical version of this proto can be found at |
| // https://github.com/grpc/grpc-proto/blob/master/grpc/gcp/handshaker.proto |
| |
| // Code generated by protoc-gen-go. DO NOT EDIT. |
| // versions: |
| // protoc-gen-go v1.28.1 |
| // protoc v3.14.0 |
| // source: grpc/gcp/handshaker.proto |
| |
| package grpc_gcp |
| |
| import ( |
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" |
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" |
| reflect "reflect" |
| sync "sync" |
| ) |
| |
| const ( |
| // Verify that this generated code is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) |
| // Verify that runtime/protoimpl is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) |
| ) |
| |
| 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 |
| ) |
| |
| // Enum value maps for HandshakeProtocol. |
| 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, |
| } |
| ) |
| |
| func (x HandshakeProtocol) Enum() *HandshakeProtocol { |
| p := new(HandshakeProtocol) |
| *p = x |
| return p |
| } |
| |
| func (x HandshakeProtocol) String() string { |
| return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) |
| } |
| |
| func (HandshakeProtocol) Descriptor() protoreflect.EnumDescriptor { |
| return file_grpc_gcp_handshaker_proto_enumTypes[0].Descriptor() |
| } |
| |
| func (HandshakeProtocol) Type() protoreflect.EnumType { |
| return &file_grpc_gcp_handshaker_proto_enumTypes[0] |
| } |
| |
| func (x HandshakeProtocol) Number() protoreflect.EnumNumber { |
| return protoreflect.EnumNumber(x) |
| } |
| |
| // Deprecated: Use HandshakeProtocol.Descriptor instead. |
| func (HandshakeProtocol) EnumDescriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{0} |
| } |
| |
| type NetworkProtocol int32 |
| |
| const ( |
| NetworkProtocol_NETWORK_PROTOCOL_UNSPECIFIED NetworkProtocol = 0 |
| NetworkProtocol_TCP NetworkProtocol = 1 |
| NetworkProtocol_UDP NetworkProtocol = 2 |
| ) |
| |
| // Enum value maps for NetworkProtocol. |
| 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, |
| } |
| ) |
| |
| func (x NetworkProtocol) Enum() *NetworkProtocol { |
| p := new(NetworkProtocol) |
| *p = x |
| return p |
| } |
| |
| func (x NetworkProtocol) String() string { |
| return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) |
| } |
| |
| func (NetworkProtocol) Descriptor() protoreflect.EnumDescriptor { |
| return file_grpc_gcp_handshaker_proto_enumTypes[1].Descriptor() |
| } |
| |
| func (NetworkProtocol) Type() protoreflect.EnumType { |
| return &file_grpc_gcp_handshaker_proto_enumTypes[1] |
| } |
| |
| func (x NetworkProtocol) Number() protoreflect.EnumNumber { |
| return protoreflect.EnumNumber(x) |
| } |
| |
| // Deprecated: Use NetworkProtocol.Descriptor instead. |
| func (NetworkProtocol) EnumDescriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{1} |
| } |
| |
| type Endpoint struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // 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"` |
| } |
| |
| func (x *Endpoint) Reset() { |
| *x = Endpoint{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[0] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Endpoint) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Endpoint) ProtoMessage() {} |
| |
| func (x *Endpoint) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[0] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Endpoint.ProtoReflect.Descriptor instead. |
| func (*Endpoint) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{0} |
| } |
| |
| func (x *Endpoint) GetIpAddress() string { |
| if x != nil { |
| return x.IpAddress |
| } |
| return "" |
| } |
| |
| func (x *Endpoint) GetPort() int32 { |
| if x != nil { |
| return x.Port |
| } |
| return 0 |
| } |
| |
| func (x *Endpoint) GetProtocol() NetworkProtocol { |
| if x != nil { |
| return x.Protocol |
| } |
| return NetworkProtocol_NETWORK_PROTOCOL_UNSPECIFIED |
| } |
| |
| type Identity struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // Types that are assignable to IdentityOneof: |
| // |
| // *Identity_ServiceAccount |
| // *Identity_Hostname |
| IdentityOneof isIdentity_IdentityOneof `protobuf_oneof:"identity_oneof"` |
| // Additional attributes of the identity. |
| Attributes map[string]string `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` |
| } |
| |
| func (x *Identity) Reset() { |
| *x = Identity{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[1] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *Identity) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Identity) ProtoMessage() {} |
| |
| func (x *Identity) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[1] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Identity.ProtoReflect.Descriptor instead. |
| func (*Identity) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{1} |
| } |
| |
| func (m *Identity) GetIdentityOneof() isIdentity_IdentityOneof { |
| if m != nil { |
| return m.IdentityOneof |
| } |
| return nil |
| } |
| |
| func (x *Identity) GetServiceAccount() string { |
| if x, ok := x.GetIdentityOneof().(*Identity_ServiceAccount); ok { |
| return x.ServiceAccount |
| } |
| return "" |
| } |
| |
| func (x *Identity) GetHostname() string { |
| if x, ok := x.GetIdentityOneof().(*Identity_Hostname); ok { |
| return x.Hostname |
| } |
| return "" |
| } |
| |
| func (x *Identity) GetAttributes() map[string]string { |
| if x != nil { |
| return x.Attributes |
| } |
| return nil |
| } |
| |
| type isIdentity_IdentityOneof interface { |
| isIdentity_IdentityOneof() |
| } |
| |
| type Identity_ServiceAccount struct { |
| // Service account of a connection endpoint. |
| ServiceAccount string `protobuf:"bytes,1,opt,name=service_account,json=serviceAccount,proto3,oneof"` |
| } |
| |
| type Identity_Hostname struct { |
| // Hostname of a connection endpoint. |
| Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3,oneof"` |
| } |
| |
| func (*Identity_ServiceAccount) isIdentity_IdentityOneof() {} |
| |
| func (*Identity_Hostname) isIdentity_IdentityOneof() {} |
| |
| type StartClientHandshakeReq struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // Handshake security protocol requested by the client. |
| HandshakeSecurityProtocol HandshakeProtocol `protobuf:"varint,1,opt,name=handshake_security_protocol,json=handshakeSecurityProtocol,proto3,enum=grpc.gcp.HandshakeProtocol" json:"handshake_security_protocol,omitempty"` |
| // The application protocols supported by the client, e.g., "h2" (for http2), |
| // "grpc". |
| ApplicationProtocols []string `protobuf:"bytes,2,rep,name=application_protocols,json=applicationProtocols,proto3" json:"application_protocols,omitempty"` |
| // The record protocols supported by the client, e.g., |
| // "ALTSRP_GCM_AES128". |
| RecordProtocols []string `protobuf:"bytes,3,rep,name=record_protocols,json=recordProtocols,proto3" json:"record_protocols,omitempty"` |
| // (Optional) Describes which server identities are acceptable by the client. |
| // If target identities are provided and none of them matches the peer |
| // identity of the server, handshake will fail. |
| TargetIdentities []*Identity `protobuf:"bytes,4,rep,name=target_identities,json=targetIdentities,proto3" json:"target_identities,omitempty"` |
| // (Optional) Application may specify a local identity. Otherwise, the |
| // handshaker chooses a default local identity. |
| LocalIdentity *Identity `protobuf:"bytes,5,opt,name=local_identity,json=localIdentity,proto3" json:"local_identity,omitempty"` |
| // (Optional) Local endpoint information of the connection to the server, |
| // such as local IP address, port number, and network protocol. |
| LocalEndpoint *Endpoint `protobuf:"bytes,6,opt,name=local_endpoint,json=localEndpoint,proto3" json:"local_endpoint,omitempty"` |
| // (Optional) Endpoint information of the remote server, such as IP address, |
| // port number, and network protocol. |
| RemoteEndpoint *Endpoint `protobuf:"bytes,7,opt,name=remote_endpoint,json=remoteEndpoint,proto3" json:"remote_endpoint,omitempty"` |
| // (Optional) If target name is provided, a secure naming check is performed |
| // to verify that the peer authenticated identity is indeed authorized to run |
| // the target name. |
| TargetName string `protobuf:"bytes,8,opt,name=target_name,json=targetName,proto3" json:"target_name,omitempty"` |
| // (Optional) RPC protocol versions supported by the client. |
| RpcVersions *RpcProtocolVersions `protobuf:"bytes,9,opt,name=rpc_versions,json=rpcVersions,proto3" json:"rpc_versions,omitempty"` |
| // (Optional) Maximum frame size supported by the client. |
| MaxFrameSize uint32 `protobuf:"varint,10,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"` |
| } |
| |
| func (x *StartClientHandshakeReq) Reset() { |
| *x = StartClientHandshakeReq{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[2] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *StartClientHandshakeReq) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*StartClientHandshakeReq) ProtoMessage() {} |
| |
| func (x *StartClientHandshakeReq) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[2] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use StartClientHandshakeReq.ProtoReflect.Descriptor instead. |
| func (*StartClientHandshakeReq) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{2} |
| } |
| |
| func (x *StartClientHandshakeReq) GetHandshakeSecurityProtocol() HandshakeProtocol { |
| if x != nil { |
| return x.HandshakeSecurityProtocol |
| } |
| return HandshakeProtocol_HANDSHAKE_PROTOCOL_UNSPECIFIED |
| } |
| |
| func (x *StartClientHandshakeReq) GetApplicationProtocols() []string { |
| if x != nil { |
| return x.ApplicationProtocols |
| } |
| return nil |
| } |
| |
| func (x *StartClientHandshakeReq) GetRecordProtocols() []string { |
| if x != nil { |
| return x.RecordProtocols |
| } |
| return nil |
| } |
| |
| func (x *StartClientHandshakeReq) GetTargetIdentities() []*Identity { |
| if x != nil { |
| return x.TargetIdentities |
| } |
| return nil |
| } |
| |
| func (x *StartClientHandshakeReq) GetLocalIdentity() *Identity { |
| if x != nil { |
| return x.LocalIdentity |
| } |
| return nil |
| } |
| |
| func (x *StartClientHandshakeReq) GetLocalEndpoint() *Endpoint { |
| if x != nil { |
| return x.LocalEndpoint |
| } |
| return nil |
| } |
| |
| func (x *StartClientHandshakeReq) GetRemoteEndpoint() *Endpoint { |
| if x != nil { |
| return x.RemoteEndpoint |
| } |
| return nil |
| } |
| |
| func (x *StartClientHandshakeReq) GetTargetName() string { |
| if x != nil { |
| return x.TargetName |
| } |
| return "" |
| } |
| |
| func (x *StartClientHandshakeReq) GetRpcVersions() *RpcProtocolVersions { |
| if x != nil { |
| return x.RpcVersions |
| } |
| return nil |
| } |
| |
| func (x *StartClientHandshakeReq) GetMaxFrameSize() uint32 { |
| if x != nil { |
| return x.MaxFrameSize |
| } |
| return 0 |
| } |
| |
| type ServerHandshakeParameters struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // 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"` |
| } |
| |
| func (x *ServerHandshakeParameters) Reset() { |
| *x = ServerHandshakeParameters{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[3] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ServerHandshakeParameters) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ServerHandshakeParameters) ProtoMessage() {} |
| |
| func (x *ServerHandshakeParameters) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[3] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ServerHandshakeParameters.ProtoReflect.Descriptor instead. |
| func (*ServerHandshakeParameters) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{3} |
| } |
| |
| func (x *ServerHandshakeParameters) GetRecordProtocols() []string { |
| if x != nil { |
| return x.RecordProtocols |
| } |
| return nil |
| } |
| |
| func (x *ServerHandshakeParameters) GetLocalIdentities() []*Identity { |
| if x != nil { |
| return x.LocalIdentities |
| } |
| return nil |
| } |
| |
| type StartServerHandshakeReq struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // The application protocols supported by the server, e.g., "h2" (for http2), |
| // "grpc". |
| ApplicationProtocols []string `protobuf:"bytes,1,rep,name=application_protocols,json=applicationProtocols,proto3" json:"application_protocols,omitempty"` |
| // Handshake parameters (record protocols and local identities supported by |
| // the server) mapped by the handshake protocol. Each handshake security |
| // protocol (e.g., TLS or ALTS) has its own set of record protocols and local |
| // identities. Since protobuf does not support enum as key to the map, the key |
| // to handshake_parameters is the integer value of HandshakeProtocol enum. |
| HandshakeParameters map[int32]*ServerHandshakeParameters `protobuf:"bytes,2,rep,name=handshake_parameters,json=handshakeParameters,proto3" json:"handshake_parameters,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` |
| // Bytes in out_frames returned from the peer's HandshakerResp. It is possible |
| // that the peer's out_frames are split into multiple HandshakReq messages. |
| InBytes []byte `protobuf:"bytes,3,opt,name=in_bytes,json=inBytes,proto3" json:"in_bytes,omitempty"` |
| // (Optional) Local endpoint information of the connection to the client, |
| // such as local IP address, port number, and network protocol. |
| LocalEndpoint *Endpoint `protobuf:"bytes,4,opt,name=local_endpoint,json=localEndpoint,proto3" json:"local_endpoint,omitempty"` |
| // (Optional) Endpoint information of the remote client, such as IP address, |
| // port number, and network protocol. |
| RemoteEndpoint *Endpoint `protobuf:"bytes,5,opt,name=remote_endpoint,json=remoteEndpoint,proto3" json:"remote_endpoint,omitempty"` |
| // (Optional) RPC protocol versions supported by the server. |
| RpcVersions *RpcProtocolVersions `protobuf:"bytes,6,opt,name=rpc_versions,json=rpcVersions,proto3" json:"rpc_versions,omitempty"` |
| // (Optional) Maximum frame size supported by the server. |
| MaxFrameSize uint32 `protobuf:"varint,7,opt,name=max_frame_size,json=maxFrameSize,proto3" json:"max_frame_size,omitempty"` |
| } |
| |
| func (x *StartServerHandshakeReq) Reset() { |
| *x = StartServerHandshakeReq{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[4] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *StartServerHandshakeReq) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*StartServerHandshakeReq) ProtoMessage() {} |
| |
| func (x *StartServerHandshakeReq) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[4] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use StartServerHandshakeReq.ProtoReflect.Descriptor instead. |
| func (*StartServerHandshakeReq) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{4} |
| } |
| |
| func (x *StartServerHandshakeReq) GetApplicationProtocols() []string { |
| if x != nil { |
| return x.ApplicationProtocols |
| } |
| return nil |
| } |
| |
| func (x *StartServerHandshakeReq) GetHandshakeParameters() map[int32]*ServerHandshakeParameters { |
| if x != nil { |
| return x.HandshakeParameters |
| } |
| return nil |
| } |
| |
| func (x *StartServerHandshakeReq) GetInBytes() []byte { |
| if x != nil { |
| return x.InBytes |
| } |
| return nil |
| } |
| |
| func (x *StartServerHandshakeReq) GetLocalEndpoint() *Endpoint { |
| if x != nil { |
| return x.LocalEndpoint |
| } |
| return nil |
| } |
| |
| func (x *StartServerHandshakeReq) GetRemoteEndpoint() *Endpoint { |
| if x != nil { |
| return x.RemoteEndpoint |
| } |
| return nil |
| } |
| |
| func (x *StartServerHandshakeReq) GetRpcVersions() *RpcProtocolVersions { |
| if x != nil { |
| return x.RpcVersions |
| } |
| return nil |
| } |
| |
| func (x *StartServerHandshakeReq) GetMaxFrameSize() uint32 { |
| if x != nil { |
| return x.MaxFrameSize |
| } |
| return 0 |
| } |
| |
| type NextHandshakeMessageReq struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // Bytes in out_frames returned from the peer's HandshakerResp. It is possible |
| // that the peer's out_frames are split into multiple NextHandshakerMessageReq |
| // messages. |
| InBytes []byte `protobuf:"bytes,1,opt,name=in_bytes,json=inBytes,proto3" json:"in_bytes,omitempty"` |
| } |
| |
| func (x *NextHandshakeMessageReq) Reset() { |
| *x = NextHandshakeMessageReq{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[5] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *NextHandshakeMessageReq) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*NextHandshakeMessageReq) ProtoMessage() {} |
| |
| func (x *NextHandshakeMessageReq) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[5] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use NextHandshakeMessageReq.ProtoReflect.Descriptor instead. |
| func (*NextHandshakeMessageReq) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{5} |
| } |
| |
| func (x *NextHandshakeMessageReq) GetInBytes() []byte { |
| if x != nil { |
| return x.InBytes |
| } |
| return nil |
| } |
| |
| type HandshakerReq struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // Types that are assignable to ReqOneof: |
| // |
| // *HandshakerReq_ClientStart |
| // *HandshakerReq_ServerStart |
| // *HandshakerReq_Next |
| ReqOneof isHandshakerReq_ReqOneof `protobuf_oneof:"req_oneof"` |
| } |
| |
| func (x *HandshakerReq) Reset() { |
| *x = HandshakerReq{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[6] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *HandshakerReq) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*HandshakerReq) ProtoMessage() {} |
| |
| func (x *HandshakerReq) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[6] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use HandshakerReq.ProtoReflect.Descriptor instead. |
| func (*HandshakerReq) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{6} |
| } |
| |
| func (m *HandshakerReq) GetReqOneof() isHandshakerReq_ReqOneof { |
| if m != nil { |
| return m.ReqOneof |
| } |
| return nil |
| } |
| |
| func (x *HandshakerReq) GetClientStart() *StartClientHandshakeReq { |
| if x, ok := x.GetReqOneof().(*HandshakerReq_ClientStart); ok { |
| return x.ClientStart |
| } |
| return nil |
| } |
| |
| func (x *HandshakerReq) GetServerStart() *StartServerHandshakeReq { |
| if x, ok := x.GetReqOneof().(*HandshakerReq_ServerStart); ok { |
| return x.ServerStart |
| } |
| return nil |
| } |
| |
| func (x *HandshakerReq) GetNext() *NextHandshakeMessageReq { |
| if x, ok := x.GetReqOneof().(*HandshakerReq_Next); ok { |
| return x.Next |
| } |
| return nil |
| } |
| |
| type isHandshakerReq_ReqOneof interface { |
| isHandshakerReq_ReqOneof() |
| } |
| |
| type HandshakerReq_ClientStart struct { |
| // The start client handshake request message. |
| ClientStart *StartClientHandshakeReq `protobuf:"bytes,1,opt,name=client_start,json=clientStart,proto3,oneof"` |
| } |
| |
| type HandshakerReq_ServerStart struct { |
| // The start server handshake request message. |
| ServerStart *StartServerHandshakeReq `protobuf:"bytes,2,opt,name=server_start,json=serverStart,proto3,oneof"` |
| } |
| |
| type HandshakerReq_Next struct { |
| // The next handshake request message. |
| Next *NextHandshakeMessageReq `protobuf:"bytes,3,opt,name=next,proto3,oneof"` |
| } |
| |
| func (*HandshakerReq_ClientStart) isHandshakerReq_ReqOneof() {} |
| |
| func (*HandshakerReq_ServerStart) isHandshakerReq_ReqOneof() {} |
| |
| func (*HandshakerReq_Next) isHandshakerReq_ReqOneof() {} |
| |
| type HandshakerResult struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // 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"` |
| } |
| |
| func (x *HandshakerResult) Reset() { |
| *x = HandshakerResult{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[7] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *HandshakerResult) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*HandshakerResult) ProtoMessage() {} |
| |
| func (x *HandshakerResult) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[7] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use HandshakerResult.ProtoReflect.Descriptor instead. |
| func (*HandshakerResult) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{7} |
| } |
| |
| func (x *HandshakerResult) GetApplicationProtocol() string { |
| if x != nil { |
| return x.ApplicationProtocol |
| } |
| return "" |
| } |
| |
| func (x *HandshakerResult) GetRecordProtocol() string { |
| if x != nil { |
| return x.RecordProtocol |
| } |
| return "" |
| } |
| |
| func (x *HandshakerResult) GetKeyData() []byte { |
| if x != nil { |
| return x.KeyData |
| } |
| return nil |
| } |
| |
| func (x *HandshakerResult) GetPeerIdentity() *Identity { |
| if x != nil { |
| return x.PeerIdentity |
| } |
| return nil |
| } |
| |
| func (x *HandshakerResult) GetLocalIdentity() *Identity { |
| if x != nil { |
| return x.LocalIdentity |
| } |
| return nil |
| } |
| |
| func (x *HandshakerResult) GetKeepChannelOpen() bool { |
| if x != nil { |
| return x.KeepChannelOpen |
| } |
| return false |
| } |
| |
| func (x *HandshakerResult) GetPeerRpcVersions() *RpcProtocolVersions { |
| if x != nil { |
| return x.PeerRpcVersions |
| } |
| return nil |
| } |
| |
| func (x *HandshakerResult) GetMaxFrameSize() uint32 { |
| if x != nil { |
| return x.MaxFrameSize |
| } |
| return 0 |
| } |
| |
| type HandshakerStatus struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // 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"` |
| } |
| |
| func (x *HandshakerStatus) Reset() { |
| *x = HandshakerStatus{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[8] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *HandshakerStatus) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*HandshakerStatus) ProtoMessage() {} |
| |
| func (x *HandshakerStatus) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[8] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use HandshakerStatus.ProtoReflect.Descriptor instead. |
| func (*HandshakerStatus) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{8} |
| } |
| |
| func (x *HandshakerStatus) GetCode() uint32 { |
| if x != nil { |
| return x.Code |
| } |
| return 0 |
| } |
| |
| func (x *HandshakerStatus) GetDetails() string { |
| if x != nil { |
| return x.Details |
| } |
| return "" |
| } |
| |
| type HandshakerResp struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| // 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"` |
| } |
| |
| func (x *HandshakerResp) Reset() { |
| *x = HandshakerResp{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[9] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *HandshakerResp) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*HandshakerResp) ProtoMessage() {} |
| |
| func (x *HandshakerResp) ProtoReflect() protoreflect.Message { |
| mi := &file_grpc_gcp_handshaker_proto_msgTypes[9] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use HandshakerResp.ProtoReflect.Descriptor instead. |
| func (*HandshakerResp) Descriptor() ([]byte, []int) { |
| return file_grpc_gcp_handshaker_proto_rawDescGZIP(), []int{9} |
| } |
| |
| func (x *HandshakerResp) GetOutFrames() []byte { |
| if x != nil { |
| return x.OutFrames |
| } |
| return nil |
| } |
| |
| func (x *HandshakerResp) GetBytesConsumed() uint32 { |
| if x != nil { |
| return x.BytesConsumed |
| } |
| return 0 |
| } |
| |
| func (x *HandshakerResp) GetResult() *HandshakerResult { |
| if x != nil { |
| return x.Result |
| } |
| return nil |
| } |
| |
| func (x *HandshakerResp) GetStatus() *HandshakerStatus { |
| if x != nil { |
| return x.Status |
| } |
| return nil |
| } |
| |
| var File_grpc_gcp_handshaker_proto protoreflect.FileDescriptor |
| |
| var file_grpc_gcp_handshaker_proto_rawDesc = []byte{ |
| 0x0a, 0x19, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x67, 0x63, 0x70, 0x2f, 0x68, 0x61, 0x6e, 0x64, 0x73, |
| 0x68, 0x61, 0x6b, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x08, 0x67, 0x72, 0x70, |
| 0x63, 0x2e, 0x67, 0x63, 0x70, 0x1a, 0x28, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x67, 0x63, 0x70, 0x2f, |
| 0x74, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72, 0x74, 0x5f, 0x73, 0x65, 0x63, 0x75, 0x72, 0x69, |
| 0x74, 0x79, 0x5f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, |
| 0x74, 0x0a, 0x08, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x69, |
| 0x70, 0x5f, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, |
| 0x09, 0x69, 0x70, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, |
| 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x35, |
| 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, |
| 0x32, 0x19, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x4e, 0x65, 0x74, 0x77, |
| 0x6f, 0x72, 0x6b, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x52, 0x08, 0x70, 0x72, 0x6f, |
| 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x22, 0xe8, 0x01, 0x0a, 0x08, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, |
| 0x74, 0x79, 0x12, 0x29, 0x0a, 0x0f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x61, 0x63, |
| 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0e, 0x73, |
| 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1c, 0x0a, |
| 0x08, 0x68, 0x6f, 0x73, 0x74, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x48, |
| 0x00, 0x52, 0x08, 0x68, 0x6f, 0x73, 0x74, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x42, 0x0a, 0x0a, 0x61, |
| 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, |
| 0x22, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, |
| 0x69, 0x74, 0x79, 0x2e, 0x41, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x45, 0x6e, |
| 0x74, 0x72, 0x79, 0x52, 0x0a, 0x61, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x1a, |
| 0x3d, 0x0a, 0x0f, 0x41, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x45, 0x6e, 0x74, |
| 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, |
| 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, |
| 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x42, 0x10, |
| 0x0a, 0x0e, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x5f, 0x6f, 0x6e, 0x65, 0x6f, 0x66, |
| 0x22, 0xd3, 0x04, 0x0a, 0x17, 0x53, 0x74, 0x61, 0x72, 0x74, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, |
| 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x71, 0x12, 0x5b, 0x0a, 0x1b, |
| 0x68, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x5f, 0x73, 0x65, 0x63, 0x75, 0x72, 0x69, |
| 0x74, 0x79, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, |
| 0x0e, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x48, 0x61, 0x6e, |
| 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x52, 0x19, |
| 0x68, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x53, 0x65, 0x63, 0x75, 0x72, 0x69, 0x74, |
| 0x79, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x33, 0x0a, 0x15, 0x61, 0x70, 0x70, |
| 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, |
| 0x6c, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x14, 0x61, 0x70, 0x70, 0x6c, 0x69, 0x63, |
| 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x73, 0x12, 0x29, |
| 0x0a, 0x10, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, |
| 0x6c, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0f, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, |
| 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x73, 0x12, 0x3f, 0x0a, 0x11, 0x74, 0x61, 0x72, |
| 0x67, 0x65, 0x74, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x18, 0x04, |
| 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, |
| 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x10, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, |
| 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x12, 0x39, 0x0a, 0x0e, 0x6c, 0x6f, |
| 0x63, 0x61, 0x6c, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x18, 0x05, 0x20, 0x01, |
| 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x49, 0x64, |
| 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x0d, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x49, 0x64, 0x65, |
| 0x6e, 0x74, 0x69, 0x74, 0x79, 0x12, 0x39, 0x0a, 0x0e, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x5f, 0x65, |
| 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, |
| 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, |
| 0x74, 0x52, 0x0d, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, |
| 0x12, 0x3b, 0x0a, 0x0f, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x5f, 0x65, 0x6e, 0x64, 0x70, 0x6f, |
| 0x69, 0x6e, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63, |
| 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x0e, 0x72, |
| 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x1f, 0x0a, |
| 0x0b, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x08, 0x20, 0x01, |
| 0x28, 0x09, 0x52, 0x0a, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x40, |
| 0x0a, 0x0c, 0x72, 0x70, 0x63, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x09, |
| 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, |
| 0x52, 0x70, 0x63, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, |
| 0x6f, 0x6e, 0x73, 0x52, 0x0b, 0x72, 0x70, 0x63, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, |
| 0x12, 0x24, 0x0a, 0x0e, 0x6d, 0x61, 0x78, 0x5f, 0x66, 0x72, 0x61, 0x6d, 0x65, 0x5f, 0x73, 0x69, |
| 0x7a, 0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x6d, 0x61, 0x78, 0x46, 0x72, 0x61, |
| 0x6d, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x22, 0x85, 0x01, 0x0a, 0x19, 0x53, 0x65, 0x72, 0x76, 0x65, |
| 0x72, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, |
| 0x74, 0x65, 0x72, 0x73, 0x12, 0x29, 0x0a, 0x10, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x5f, 0x70, |
| 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0f, |
| 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x73, 0x12, |
| 0x3d, 0x0a, 0x10, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, |
| 0x69, 0x65, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63, |
| 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x0f, 0x6c, |
| 0x6f, 0x63, 0x61, 0x6c, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x69, 0x65, 0x73, 0x22, 0xa5, |
| 0x04, 0x0a, 0x17, 0x53, 0x74, 0x61, 0x72, 0x74, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x61, |
| 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x71, 0x12, 0x33, 0x0a, 0x15, 0x61, 0x70, |
| 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, |
| 0x6f, 0x6c, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x14, 0x61, 0x70, 0x70, 0x6c, 0x69, |
| 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x73, 0x12, |
| 0x6d, 0x0a, 0x14, 0x68, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x5f, 0x70, 0x61, 0x72, |
| 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3a, 0x2e, |
| 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x53, 0x65, |
| 0x72, 0x76, 0x65, 0x72, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x71, |
| 0x2e, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, |
| 0x74, 0x65, 0x72, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x13, 0x68, 0x61, 0x6e, 0x64, 0x73, |
| 0x68, 0x61, 0x6b, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x12, 0x19, |
| 0x0a, 0x08, 0x69, 0x6e, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, |
| 0x52, 0x07, 0x69, 0x6e, 0x42, 0x79, 0x74, 0x65, 0x73, 0x12, 0x39, 0x0a, 0x0e, 0x6c, 0x6f, 0x63, |
| 0x61, 0x6c, 0x5f, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, |
| 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x45, 0x6e, 0x64, |
| 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x52, 0x0d, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x45, 0x6e, 0x64, 0x70, |
| 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x3b, 0x0a, 0x0f, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x5f, 0x65, |
| 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, |
| 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, |
| 0x74, 0x52, 0x0e, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, |
| 0x74, 0x12, 0x40, 0x0a, 0x0c, 0x72, 0x70, 0x63, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, |
| 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, |
| 0x63, 0x70, 0x2e, 0x52, 0x70, 0x63, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x56, 0x65, |
| 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x0b, 0x72, 0x70, 0x63, 0x56, 0x65, 0x72, 0x73, 0x69, |
| 0x6f, 0x6e, 0x73, 0x12, 0x24, 0x0a, 0x0e, 0x6d, 0x61, 0x78, 0x5f, 0x66, 0x72, 0x61, 0x6d, 0x65, |
| 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x6d, 0x61, 0x78, |
| 0x46, 0x72, 0x61, 0x6d, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x1a, 0x6b, 0x0a, 0x18, 0x48, 0x61, 0x6e, |
| 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, |
| 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, |
| 0x28, 0x05, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x39, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, |
| 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, |
| 0x70, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, |
| 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x52, 0x05, 0x76, 0x61, 0x6c, |
| 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x34, 0x0a, 0x17, 0x4e, 0x65, 0x78, 0x74, 0x48, 0x61, |
| 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, |
| 0x71, 0x12, 0x19, 0x0a, 0x08, 0x69, 0x6e, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x01, 0x20, |
| 0x01, 0x28, 0x0c, 0x52, 0x07, 0x69, 0x6e, 0x42, 0x79, 0x74, 0x65, 0x73, 0x22, 0xe5, 0x01, 0x0a, |
| 0x0d, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x72, 0x52, 0x65, 0x71, 0x12, 0x46, |
| 0x0a, 0x0c, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x72, 0x74, 0x18, 0x01, |
| 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, |
| 0x53, 0x74, 0x61, 0x72, 0x74, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x48, 0x61, 0x6e, 0x64, 0x73, |
| 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x71, 0x48, 0x00, 0x52, 0x0b, 0x63, 0x6c, 0x69, 0x65, 0x6e, |
| 0x74, 0x53, 0x74, 0x61, 0x72, 0x74, 0x12, 0x46, 0x0a, 0x0c, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, |
| 0x5f, 0x73, 0x74, 0x61, 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, |
| 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x53, 0x65, 0x72, |
| 0x76, 0x65, 0x72, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x52, 0x65, 0x71, 0x48, |
| 0x00, 0x52, 0x0b, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x53, 0x74, 0x61, 0x72, 0x74, 0x12, 0x37, |
| 0x0a, 0x04, 0x6e, 0x65, 0x78, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, |
| 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x4e, 0x65, 0x78, 0x74, 0x48, 0x61, 0x6e, 0x64, |
| 0x73, 0x68, 0x61, 0x6b, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x48, |
| 0x00, 0x52, 0x04, 0x6e, 0x65, 0x78, 0x74, 0x42, 0x0b, 0x0a, 0x09, 0x72, 0x65, 0x71, 0x5f, 0x6f, |
| 0x6e, 0x65, 0x6f, 0x66, 0x22, 0x9a, 0x03, 0x0a, 0x10, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, |
| 0x6b, 0x65, 0x72, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x31, 0x0a, 0x14, 0x61, 0x70, 0x70, |
| 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, |
| 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x13, 0x61, 0x70, 0x70, 0x6c, 0x69, 0x63, 0x61, |
| 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x27, 0x0a, 0x0f, |
| 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x18, |
| 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x50, 0x72, 0x6f, |
| 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x19, 0x0a, 0x08, 0x6b, 0x65, 0x79, 0x5f, 0x64, 0x61, 0x74, |
| 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x6b, 0x65, 0x79, 0x44, 0x61, 0x74, 0x61, |
| 0x12, 0x37, 0x0a, 0x0d, 0x70, 0x65, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, |
| 0x79, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, |
| 0x63, 0x70, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x0c, 0x70, 0x65, 0x65, |
| 0x72, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x12, 0x39, 0x0a, 0x0e, 0x6c, 0x6f, 0x63, |
| 0x61, 0x6c, 0x5f, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x18, 0x05, 0x20, 0x01, 0x28, |
| 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x49, 0x64, 0x65, |
| 0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x0d, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x49, 0x64, 0x65, 0x6e, |
| 0x74, 0x69, 0x74, 0x79, 0x12, 0x2a, 0x0a, 0x11, 0x6b, 0x65, 0x65, 0x70, 0x5f, 0x63, 0x68, 0x61, |
| 0x6e, 0x6e, 0x65, 0x6c, 0x5f, 0x6f, 0x70, 0x65, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, |
| 0x0f, 0x6b, 0x65, 0x65, 0x70, 0x43, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x4f, 0x70, 0x65, 0x6e, |
| 0x12, 0x49, 0x0a, 0x11, 0x70, 0x65, 0x65, 0x72, 0x5f, 0x72, 0x70, 0x63, 0x5f, 0x76, 0x65, 0x72, |
| 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, |
| 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x52, 0x70, 0x63, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, |
| 0x6f, 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x0f, 0x70, 0x65, 0x65, 0x72, |
| 0x52, 0x70, 0x63, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x24, 0x0a, 0x0e, 0x6d, |
| 0x61, 0x78, 0x5f, 0x66, 0x72, 0x61, 0x6d, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x08, 0x20, |
| 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x6d, 0x61, 0x78, 0x46, 0x72, 0x61, 0x6d, 0x65, 0x53, 0x69, 0x7a, |
| 0x65, 0x22, 0x40, 0x0a, 0x10, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x72, 0x53, |
| 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, |
| 0x01, 0x28, 0x0d, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x64, 0x65, 0x74, |
| 0x61, 0x69, 0x6c, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x64, 0x65, 0x74, 0x61, |
| 0x69, 0x6c, 0x73, 0x22, 0xbe, 0x01, 0x0a, 0x0e, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, |
| 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x12, 0x1d, 0x0a, 0x0a, 0x6f, 0x75, 0x74, 0x5f, 0x66, 0x72, |
| 0x61, 0x6d, 0x65, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x09, 0x6f, 0x75, 0x74, 0x46, |
| 0x72, 0x61, 0x6d, 0x65, 0x73, 0x12, 0x25, 0x0a, 0x0e, 0x62, 0x79, 0x74, 0x65, 0x73, 0x5f, 0x63, |
| 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x62, |
| 0x79, 0x74, 0x65, 0x73, 0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x64, 0x12, 0x32, 0x0a, 0x06, |
| 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, |
| 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, |
| 0x65, 0x72, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, |
| 0x12, 0x32, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, |
| 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x48, 0x61, 0x6e, 0x64, |
| 0x73, 0x68, 0x61, 0x6b, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x06, 0x73, 0x74, |
| 0x61, 0x74, 0x75, 0x73, 0x2a, 0x4a, 0x0a, 0x11, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, |
| 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x12, 0x22, 0x0a, 0x1e, 0x48, 0x41, 0x4e, |
| 0x44, 0x53, 0x48, 0x41, 0x4b, 0x45, 0x5f, 0x50, 0x52, 0x4f, 0x54, 0x4f, 0x43, 0x4f, 0x4c, 0x5f, |
| 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x07, 0x0a, |
| 0x03, 0x54, 0x4c, 0x53, 0x10, 0x01, 0x12, 0x08, 0x0a, 0x04, 0x41, 0x4c, 0x54, 0x53, 0x10, 0x02, |
| 0x2a, 0x45, 0x0a, 0x0f, 0x4e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x50, 0x72, 0x6f, 0x74, 0x6f, |
| 0x63, 0x6f, 0x6c, 0x12, 0x20, 0x0a, 0x1c, 0x4e, 0x45, 0x54, 0x57, 0x4f, 0x52, 0x4b, 0x5f, 0x50, |
| 0x52, 0x4f, 0x54, 0x4f, 0x43, 0x4f, 0x4c, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, |
| 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x54, 0x43, 0x50, 0x10, 0x01, 0x12, 0x07, |
| 0x0a, 0x03, 0x55, 0x44, 0x50, 0x10, 0x02, 0x32, 0x5b, 0x0a, 0x11, 0x48, 0x61, 0x6e, 0x64, 0x73, |
| 0x68, 0x61, 0x6b, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x46, 0x0a, 0x0b, |
| 0x44, 0x6f, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x12, 0x17, 0x2e, 0x67, 0x72, |
| 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, |
| 0x72, 0x52, 0x65, 0x71, 0x1a, 0x18, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x67, 0x63, 0x70, 0x2e, |
| 0x48, 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, |
| 0x28, 0x01, 0x30, 0x01, 0x42, 0x6b, 0x0a, 0x15, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, |
| 0x61, 0x6c, 0x74, 0x73, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x42, 0x0f, 0x48, |
| 0x61, 0x6e, 0x64, 0x73, 0x68, 0x61, 0x6b, 0x65, 0x72, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, |
| 0x5a, 0x3f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, |
| 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x63, 0x72, 0x65, 0x64, 0x65, 0x6e, 0x74, |
| 0x69, 0x61, 0x6c, 0x73, 0x2f, 0x61, 0x6c, 0x74, 0x73, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, |
| 0x61, 0x6c, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x5f, 0x67, 0x63, |
| 0x70, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, |
| } |
| |
| var ( |
| file_grpc_gcp_handshaker_proto_rawDescOnce sync.Once |
| file_grpc_gcp_handshaker_proto_rawDescData = file_grpc_gcp_handshaker_proto_rawDesc |
| ) |
| |
| func file_grpc_gcp_handshaker_proto_rawDescGZIP() []byte { |
| file_grpc_gcp_handshaker_proto_rawDescOnce.Do(func() { |
| file_grpc_gcp_handshaker_proto_rawDescData = protoimpl.X.CompressGZIP(file_grpc_gcp_handshaker_proto_rawDescData) |
| }) |
| return file_grpc_gcp_handshaker_proto_rawDescData |
| } |
| |
| var file_grpc_gcp_handshaker_proto_enumTypes = make([]protoimpl.EnumInfo, 2) |
| var file_grpc_gcp_handshaker_proto_msgTypes = make([]protoimpl.MessageInfo, 12) |
| var file_grpc_gcp_handshaker_proto_goTypes = []interface{}{ |
| (HandshakeProtocol)(0), // 0: grpc.gcp.HandshakeProtocol |
| (NetworkProtocol)(0), // 1: grpc.gcp.NetworkProtocol |
| (*Endpoint)(nil), // 2: grpc.gcp.Endpoint |
| (*Identity)(nil), // 3: grpc.gcp.Identity |
| (*StartClientHandshakeReq)(nil), // 4: grpc.gcp.StartClientHandshakeReq |
| (*ServerHandshakeParameters)(nil), // 5: grpc.gcp.ServerHandshakeParameters |
| (*StartServerHandshakeReq)(nil), // 6: grpc.gcp.StartServerHandshakeReq |
| (*NextHandshakeMessageReq)(nil), // 7: grpc.gcp.NextHandshakeMessageReq |
| (*HandshakerReq)(nil), // 8: grpc.gcp.HandshakerReq |
| (*HandshakerResult)(nil), // 9: grpc.gcp.HandshakerResult |
| (*HandshakerStatus)(nil), // 10: grpc.gcp.HandshakerStatus |
| (*HandshakerResp)(nil), // 11: grpc.gcp.HandshakerResp |
| nil, // 12: grpc.gcp.Identity.AttributesEntry |
| nil, // 13: grpc.gcp.StartServerHandshakeReq.HandshakeParametersEntry |
| (*RpcProtocolVersions)(nil), // 14: grpc.gcp.RpcProtocolVersions |
| } |
| var file_grpc_gcp_handshaker_proto_depIdxs = []int32{ |
| 1, // 0: grpc.gcp.Endpoint.protocol:type_name -> grpc.gcp.NetworkProtocol |
| 12, // 1: grpc.gcp.Identity.attributes:type_name -> grpc.gcp.Identity.AttributesEntry |
| 0, // 2: grpc.gcp.StartClientHandshakeReq.handshake_security_protocol:type_name -> grpc.gcp.HandshakeProtocol |
| 3, // 3: grpc.gcp.StartClientHandshakeReq.target_identities:type_name -> grpc.gcp.Identity |
| 3, // 4: grpc.gcp.StartClientHandshakeReq.local_identity:type_name -> grpc.gcp.Identity |
| 2, // 5: grpc.gcp.StartClientHandshakeReq.local_endpoint:type_name -> grpc.gcp.Endpoint |
| 2, // 6: grpc.gcp.StartClientHandshakeReq.remote_endpoint:type_name -> grpc.gcp.Endpoint |
| 14, // 7: grpc.gcp.StartClientHandshakeReq.rpc_versions:type_name -> grpc.gcp.RpcProtocolVersions |
| 3, // 8: grpc.gcp.ServerHandshakeParameters.local_identities:type_name -> grpc.gcp.Identity |
| 13, // 9: grpc.gcp.StartServerHandshakeReq.handshake_parameters:type_name -> grpc.gcp.StartServerHandshakeReq.HandshakeParametersEntry |
| 2, // 10: grpc.gcp.StartServerHandshakeReq.local_endpoint:type_name -> grpc.gcp.Endpoint |
| 2, // 11: grpc.gcp.StartServerHandshakeReq.remote_endpoint:type_name -> grpc.gcp.Endpoint |
| 14, // 12: grpc.gcp.StartServerHandshakeReq.rpc_versions:type_name -> grpc.gcp.RpcProtocolVersions |
| 4, // 13: grpc.gcp.HandshakerReq.client_start:type_name -> grpc.gcp.StartClientHandshakeReq |
| 6, // 14: grpc.gcp.HandshakerReq.server_start:type_name -> grpc.gcp.StartServerHandshakeReq |
| 7, // 15: grpc.gcp.HandshakerReq.next:type_name -> grpc.gcp.NextHandshakeMessageReq |
| 3, // 16: grpc.gcp.HandshakerResult.peer_identity:type_name -> grpc.gcp.Identity |
| 3, // 17: grpc.gcp.HandshakerResult.local_identity:type_name -> grpc.gcp.Identity |
| 14, // 18: grpc.gcp.HandshakerResult.peer_rpc_versions:type_name -> grpc.gcp.RpcProtocolVersions |
| 9, // 19: grpc.gcp.HandshakerResp.result:type_name -> grpc.gcp.HandshakerResult |
| 10, // 20: grpc.gcp.HandshakerResp.status:type_name -> grpc.gcp.HandshakerStatus |
| 5, // 21: grpc.gcp.StartServerHandshakeReq.HandshakeParametersEntry.value:type_name -> grpc.gcp.ServerHandshakeParameters |
| 8, // 22: grpc.gcp.HandshakerService.DoHandshake:input_type -> grpc.gcp.HandshakerReq |
| 11, // 23: grpc.gcp.HandshakerService.DoHandshake:output_type -> grpc.gcp.HandshakerResp |
| 23, // [23:24] is the sub-list for method output_type |
| 22, // [22:23] is the sub-list for method input_type |
| 22, // [22:22] is the sub-list for extension type_name |
| 22, // [22:22] is the sub-list for extension extendee |
| 0, // [0:22] is the sub-list for field type_name |
| } |
| |
| func init() { file_grpc_gcp_handshaker_proto_init() } |
| func file_grpc_gcp_handshaker_proto_init() { |
| if File_grpc_gcp_handshaker_proto != nil { |
| return |
| } |
| file_grpc_gcp_transport_security_common_proto_init() |
| if !protoimpl.UnsafeEnabled { |
| file_grpc_gcp_handshaker_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Endpoint); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*Identity); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*StartClientHandshakeReq); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ServerHandshakeParameters); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*StartServerHandshakeReq); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*NextHandshakeMessageReq); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*HandshakerReq); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*HandshakerResult); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*HandshakerStatus); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*HandshakerResp); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[1].OneofWrappers = []interface{}{ |
| (*Identity_ServiceAccount)(nil), |
| (*Identity_Hostname)(nil), |
| } |
| file_grpc_gcp_handshaker_proto_msgTypes[6].OneofWrappers = []interface{}{ |
| (*HandshakerReq_ClientStart)(nil), |
| (*HandshakerReq_ServerStart)(nil), |
| (*HandshakerReq_Next)(nil), |
| } |
| type x struct{} |
| out := protoimpl.TypeBuilder{ |
| File: protoimpl.DescBuilder{ |
| GoPackagePath: reflect.TypeOf(x{}).PkgPath(), |
| RawDescriptor: file_grpc_gcp_handshaker_proto_rawDesc, |
| NumEnums: 2, |
| NumMessages: 12, |
| NumExtensions: 0, |
| NumServices: 1, |
| }, |
| GoTypes: file_grpc_gcp_handshaker_proto_goTypes, |
| DependencyIndexes: file_grpc_gcp_handshaker_proto_depIdxs, |
| EnumInfos: file_grpc_gcp_handshaker_proto_enumTypes, |
| MessageInfos: file_grpc_gcp_handshaker_proto_msgTypes, |
| }.Build() |
| File_grpc_gcp_handshaker_proto = out.File |
| file_grpc_gcp_handshaker_proto_rawDesc = nil |
| file_grpc_gcp_handshaker_proto_goTypes = nil |
| file_grpc_gcp_handshaker_proto_depIdxs = nil |
| } |