Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterChannelServiceServer(s grpc.ServiceRegistrar, srv ChannelServiceServer)
- type ChannelRequest
- func (*ChannelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelRequest) GetData() *Data
- func (m *ChannelRequest) GetReq() isChannelRequest_Req
- func (x *ChannelRequest) GetSetKey() *SetKey
- func (*ChannelRequest) ProtoMessage()
- func (x *ChannelRequest) ProtoReflect() protoreflect.Message
- func (x *ChannelRequest) Reset()
- func (x *ChannelRequest) String() string
- func (m *ChannelRequest) Validate() error
- func (m *ChannelRequest) ValidateAll() error
- type ChannelRequestMultiError
- type ChannelRequestValidationError
- func (e ChannelRequestValidationError) Cause() error
- func (e ChannelRequestValidationError) Error() string
- func (e ChannelRequestValidationError) ErrorName() string
- func (e ChannelRequestValidationError) Field() string
- func (e ChannelRequestValidationError) Key() bool
- func (e ChannelRequestValidationError) Reason() string
- type ChannelRequest_Data
- type ChannelRequest_SetKey
- type ChannelServiceClient
- type ChannelServiceServer
- type ChannelService_ChannelClient
- type ChannelService_ChannelServer
- type Data
- func (*Data) Descriptor() ([]byte, []int)deprecated
- func (x *Data) GetData() []byte
- func (x *Data) GetDstKey() string
- func (x *Data) GetSrcKey() string
- func (*Data) ProtoMessage()
- func (x *Data) ProtoReflect() protoreflect.Message
- func (x *Data) Reset()
- func (x *Data) String() string
- func (m *Data) Validate() error
- func (m *Data) ValidateAll() error
- type DataMultiError
- type DataValidationError
- type KeyAccepted
- func (*KeyAccepted) Descriptor() ([]byte, []int)deprecated
- func (*KeyAccepted) ProtoMessage()
- func (x *KeyAccepted) ProtoReflect() protoreflect.Message
- func (x *KeyAccepted) Reset()
- func (x *KeyAccepted) String() string
- func (m *KeyAccepted) Validate() error
- func (m *KeyAccepted) ValidateAll() error
- type KeyAcceptedMultiError
- type KeyAcceptedValidationError
- func (e KeyAcceptedValidationError) Cause() error
- func (e KeyAcceptedValidationError) Error() string
- func (e KeyAcceptedValidationError) ErrorName() string
- func (e KeyAcceptedValidationError) Field() string
- func (e KeyAcceptedValidationError) Key() bool
- func (e KeyAcceptedValidationError) Reason() string
- type ReceiveResponse
- func (*ReceiveResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReceiveResponse) GetData() *Data
- func (x *ReceiveResponse) GetKeyAccepted() *KeyAccepted
- func (m *ReceiveResponse) GetResp() isReceiveResponse_Resp
- func (*ReceiveResponse) ProtoMessage()
- func (x *ReceiveResponse) ProtoReflect() protoreflect.Message
- func (x *ReceiveResponse) Reset()
- func (x *ReceiveResponse) String() string
- func (m *ReceiveResponse) Validate() error
- func (m *ReceiveResponse) ValidateAll() error
- type ReceiveResponseMultiError
- type ReceiveResponseValidationError
- func (e ReceiveResponseValidationError) Cause() error
- func (e ReceiveResponseValidationError) Error() string
- func (e ReceiveResponseValidationError) ErrorName() string
- func (e ReceiveResponseValidationError) Field() string
- func (e ReceiveResponseValidationError) Key() bool
- func (e ReceiveResponseValidationError) Reason() string
- type ReceiveResponse_Data
- type ReceiveResponse_KeyAccepted
- type SetKey
- type SetKeyMultiError
- type SetKeyValidationError
- type UnimplementedChannelServiceServer
- type UnsafeChannelServiceServer
Constants ¶
const ( ChannelService_Test_FullMethodName = "/channel.api.ChannelService/Test" ChannelService_Channel_FullMethodName = "/channel.api.ChannelService/Channel" )
Variables ¶
var ChannelService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "channel.api.ChannelService", HandlerType: (*ChannelServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Test", Handler: _ChannelService_Test_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Channel", Handler: _ChannelService_Channel_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "proto/channel/channel.proto", }
ChannelService_ServiceDesc is the grpc.ServiceDesc for ChannelService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_channel_channel_proto protoreflect.FileDescriptor
Functions ¶
func RegisterChannelServiceServer ¶
func RegisterChannelServiceServer(s grpc.ServiceRegistrar, srv ChannelServiceServer)
Types ¶
type ChannelRequest ¶
type ChannelRequest struct { // Types that are assignable to Req: // // *ChannelRequest_SetKey // *ChannelRequest_Data Req isChannelRequest_Req `protobuf_oneof:"Req"` // contains filtered or unexported fields }
func (*ChannelRequest) Descriptor
deprecated
func (*ChannelRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChannelRequest.ProtoReflect.Descriptor instead.
func (*ChannelRequest) GetData ¶
func (x *ChannelRequest) GetData() *Data
func (*ChannelRequest) GetReq ¶
func (m *ChannelRequest) GetReq() isChannelRequest_Req
func (*ChannelRequest) GetSetKey ¶
func (x *ChannelRequest) GetSetKey() *SetKey
func (*ChannelRequest) ProtoMessage ¶
func (*ChannelRequest) ProtoMessage()
func (*ChannelRequest) ProtoReflect ¶
func (x *ChannelRequest) ProtoReflect() protoreflect.Message
func (*ChannelRequest) Reset ¶
func (x *ChannelRequest) Reset()
func (*ChannelRequest) String ¶
func (x *ChannelRequest) String() string
func (*ChannelRequest) Validate ¶
func (m *ChannelRequest) Validate() error
Validate checks the field values on ChannelRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ChannelRequest) ValidateAll ¶
func (m *ChannelRequest) ValidateAll() error
ValidateAll checks the field values on ChannelRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ChannelRequestMultiError, or nil if none found.
type ChannelRequestMultiError ¶
type ChannelRequestMultiError []error
ChannelRequestMultiError is an error wrapping multiple validation errors returned by ChannelRequest.ValidateAll() if the designated constraints aren't met.
func (ChannelRequestMultiError) AllErrors ¶
func (m ChannelRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ChannelRequestMultiError) Error ¶
func (m ChannelRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ChannelRequestValidationError ¶
type ChannelRequestValidationError struct {
// contains filtered or unexported fields
}
ChannelRequestValidationError is the validation error returned by ChannelRequest.Validate if the designated constraints aren't met.
func (ChannelRequestValidationError) Cause ¶
func (e ChannelRequestValidationError) Cause() error
Cause function returns cause value.
func (ChannelRequestValidationError) Error ¶
func (e ChannelRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ChannelRequestValidationError) ErrorName ¶
func (e ChannelRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ChannelRequestValidationError) Field ¶
func (e ChannelRequestValidationError) Field() string
Field function returns field value.
func (ChannelRequestValidationError) Key ¶
func (e ChannelRequestValidationError) Key() bool
Key function returns key value.
func (ChannelRequestValidationError) Reason ¶
func (e ChannelRequestValidationError) Reason() string
Reason function returns reason value.
type ChannelRequest_Data ¶
type ChannelRequest_Data struct {
Data *Data `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}
type ChannelRequest_SetKey ¶
type ChannelRequest_SetKey struct {
SetKey *SetKey `protobuf:"bytes,1,opt,name=set_key,json=setKey,proto3,oneof"`
}
type ChannelServiceClient ¶
type ChannelServiceClient interface { Test(ctx context.Context, in *protorepo_share_go.Empty, opts ...grpc.CallOption) (*protorepo_share_go.Empty, error) Channel(ctx context.Context, opts ...grpc.CallOption) (ChannelService_ChannelClient, error) }
ChannelServiceClient is the client API for ChannelService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewChannelServiceClient ¶
func NewChannelServiceClient(cc grpc.ClientConnInterface) ChannelServiceClient
type ChannelServiceServer ¶
type ChannelServiceServer interface { Test(context.Context, *protorepo_share_go.Empty) (*protorepo_share_go.Empty, error) Channel(ChannelService_ChannelServer) error // contains filtered or unexported methods }
ChannelServiceServer is the server API for ChannelService service. All implementations must embed UnimplementedChannelServiceServer for forward compatibility
type ChannelService_ChannelClient ¶
type ChannelService_ChannelClient interface { Send(*ChannelRequest) error Recv() (*ReceiveResponse, error) grpc.ClientStream }
type ChannelService_ChannelServer ¶
type ChannelService_ChannelServer interface { Send(*ReceiveResponse) error Recv() (*ChannelRequest, error) grpc.ServerStream }
type Data ¶
type Data struct { SrcKey string `protobuf:"bytes,1,opt,name=src_key,json=srcKey,proto3" json:"src_key,omitempty"` DstKey string `protobuf:"bytes,2,opt,name=dst_key,json=dstKey,proto3" json:"dst_key,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Data) Descriptor
deprecated
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) ProtoReflect ¶
func (x *Data) ProtoReflect() protoreflect.Message
func (*Data) Validate ¶
Validate checks the field values on Data with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Data) ValidateAll ¶
ValidateAll checks the field values on Data with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DataMultiError, or nil if none found.
type DataMultiError ¶
type DataMultiError []error
DataMultiError is an error wrapping multiple validation errors returned by Data.ValidateAll() if the designated constraints aren't met.
func (DataMultiError) AllErrors ¶
func (m DataMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DataMultiError) Error ¶
func (m DataMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DataValidationError ¶
type DataValidationError struct {
// contains filtered or unexported fields
}
DataValidationError is the validation error returned by Data.Validate if the designated constraints aren't met.
func (DataValidationError) Cause ¶
func (e DataValidationError) Cause() error
Cause function returns cause value.
func (DataValidationError) Error ¶
func (e DataValidationError) Error() string
Error satisfies the builtin error interface
func (DataValidationError) ErrorName ¶
func (e DataValidationError) ErrorName() string
ErrorName returns error name.
func (DataValidationError) Field ¶
func (e DataValidationError) Field() string
Field function returns field value.
func (DataValidationError) Key ¶
func (e DataValidationError) Key() bool
Key function returns key value.
func (DataValidationError) Reason ¶
func (e DataValidationError) Reason() string
Reason function returns reason value.
type KeyAccepted ¶
type KeyAccepted struct {
// contains filtered or unexported fields
}
func (*KeyAccepted) Descriptor
deprecated
func (*KeyAccepted) Descriptor() ([]byte, []int)
Deprecated: Use KeyAccepted.ProtoReflect.Descriptor instead.
func (*KeyAccepted) ProtoMessage ¶
func (*KeyAccepted) ProtoMessage()
func (*KeyAccepted) ProtoReflect ¶
func (x *KeyAccepted) ProtoReflect() protoreflect.Message
func (*KeyAccepted) Reset ¶
func (x *KeyAccepted) Reset()
func (*KeyAccepted) String ¶
func (x *KeyAccepted) String() string
func (*KeyAccepted) Validate ¶
func (m *KeyAccepted) Validate() error
Validate checks the field values on KeyAccepted with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*KeyAccepted) ValidateAll ¶
func (m *KeyAccepted) ValidateAll() error
ValidateAll checks the field values on KeyAccepted with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KeyAcceptedMultiError, or nil if none found.
type KeyAcceptedMultiError ¶
type KeyAcceptedMultiError []error
KeyAcceptedMultiError is an error wrapping multiple validation errors returned by KeyAccepted.ValidateAll() if the designated constraints aren't met.
func (KeyAcceptedMultiError) AllErrors ¶
func (m KeyAcceptedMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (KeyAcceptedMultiError) Error ¶
func (m KeyAcceptedMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type KeyAcceptedValidationError ¶
type KeyAcceptedValidationError struct {
// contains filtered or unexported fields
}
KeyAcceptedValidationError is the validation error returned by KeyAccepted.Validate if the designated constraints aren't met.
func (KeyAcceptedValidationError) Cause ¶
func (e KeyAcceptedValidationError) Cause() error
Cause function returns cause value.
func (KeyAcceptedValidationError) Error ¶
func (e KeyAcceptedValidationError) Error() string
Error satisfies the builtin error interface
func (KeyAcceptedValidationError) ErrorName ¶
func (e KeyAcceptedValidationError) ErrorName() string
ErrorName returns error name.
func (KeyAcceptedValidationError) Field ¶
func (e KeyAcceptedValidationError) Field() string
Field function returns field value.
func (KeyAcceptedValidationError) Key ¶
func (e KeyAcceptedValidationError) Key() bool
Key function returns key value.
func (KeyAcceptedValidationError) Reason ¶
func (e KeyAcceptedValidationError) Reason() string
Reason function returns reason value.
type ReceiveResponse ¶
type ReceiveResponse struct { // Types that are assignable to Resp: // // *ReceiveResponse_KeyAccepted // *ReceiveResponse_Data Resp isReceiveResponse_Resp `protobuf_oneof:"Resp"` // contains filtered or unexported fields }
func (*ReceiveResponse) Descriptor
deprecated
func (*ReceiveResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReceiveResponse.ProtoReflect.Descriptor instead.
func (*ReceiveResponse) GetData ¶
func (x *ReceiveResponse) GetData() *Data
func (*ReceiveResponse) GetKeyAccepted ¶
func (x *ReceiveResponse) GetKeyAccepted() *KeyAccepted
func (*ReceiveResponse) GetResp ¶
func (m *ReceiveResponse) GetResp() isReceiveResponse_Resp
func (*ReceiveResponse) ProtoMessage ¶
func (*ReceiveResponse) ProtoMessage()
func (*ReceiveResponse) ProtoReflect ¶
func (x *ReceiveResponse) ProtoReflect() protoreflect.Message
func (*ReceiveResponse) Reset ¶
func (x *ReceiveResponse) Reset()
func (*ReceiveResponse) String ¶
func (x *ReceiveResponse) String() string
func (*ReceiveResponse) Validate ¶
func (m *ReceiveResponse) Validate() error
Validate checks the field values on ReceiveResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ReceiveResponse) ValidateAll ¶
func (m *ReceiveResponse) ValidateAll() error
ValidateAll checks the field values on ReceiveResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReceiveResponseMultiError, or nil if none found.
type ReceiveResponseMultiError ¶
type ReceiveResponseMultiError []error
ReceiveResponseMultiError is an error wrapping multiple validation errors returned by ReceiveResponse.ValidateAll() if the designated constraints aren't met.
func (ReceiveResponseMultiError) AllErrors ¶
func (m ReceiveResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ReceiveResponseMultiError) Error ¶
func (m ReceiveResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ReceiveResponseValidationError ¶
type ReceiveResponseValidationError struct {
// contains filtered or unexported fields
}
ReceiveResponseValidationError is the validation error returned by ReceiveResponse.Validate if the designated constraints aren't met.
func (ReceiveResponseValidationError) Cause ¶
func (e ReceiveResponseValidationError) Cause() error
Cause function returns cause value.
func (ReceiveResponseValidationError) Error ¶
func (e ReceiveResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ReceiveResponseValidationError) ErrorName ¶
func (e ReceiveResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ReceiveResponseValidationError) Field ¶
func (e ReceiveResponseValidationError) Field() string
Field function returns field value.
func (ReceiveResponseValidationError) Key ¶
func (e ReceiveResponseValidationError) Key() bool
Key function returns key value.
func (ReceiveResponseValidationError) Reason ¶
func (e ReceiveResponseValidationError) Reason() string
Reason function returns reason value.
type ReceiveResponse_Data ¶
type ReceiveResponse_Data struct {
Data *Data `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}
type ReceiveResponse_KeyAccepted ¶
type ReceiveResponse_KeyAccepted struct {
KeyAccepted *KeyAccepted `protobuf:"bytes,1,opt,name=key_accepted,json=keyAccepted,proto3,oneof"`
}
type SetKey ¶
type SetKey struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*SetKey) Descriptor
deprecated
func (*SetKey) ProtoMessage ¶
func (*SetKey) ProtoMessage()
func (*SetKey) ProtoReflect ¶
func (x *SetKey) ProtoReflect() protoreflect.Message
func (*SetKey) Validate ¶
Validate checks the field values on SetKey with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*SetKey) ValidateAll ¶
ValidateAll checks the field values on SetKey with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SetKeyMultiError, or nil if none found.
type SetKeyMultiError ¶
type SetKeyMultiError []error
SetKeyMultiError is an error wrapping multiple validation errors returned by SetKey.ValidateAll() if the designated constraints aren't met.
func (SetKeyMultiError) AllErrors ¶
func (m SetKeyMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SetKeyMultiError) Error ¶
func (m SetKeyMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SetKeyValidationError ¶
type SetKeyValidationError struct {
// contains filtered or unexported fields
}
SetKeyValidationError is the validation error returned by SetKey.Validate if the designated constraints aren't met.
func (SetKeyValidationError) Cause ¶
func (e SetKeyValidationError) Cause() error
Cause function returns cause value.
func (SetKeyValidationError) Error ¶
func (e SetKeyValidationError) Error() string
Error satisfies the builtin error interface
func (SetKeyValidationError) ErrorName ¶
func (e SetKeyValidationError) ErrorName() string
ErrorName returns error name.
func (SetKeyValidationError) Field ¶
func (e SetKeyValidationError) Field() string
Field function returns field value.
func (SetKeyValidationError) Key ¶
func (e SetKeyValidationError) Key() bool
Key function returns key value.
func (SetKeyValidationError) Reason ¶
func (e SetKeyValidationError) Reason() string
Reason function returns reason value.
type UnimplementedChannelServiceServer ¶
type UnimplementedChannelServiceServer struct { }
UnimplementedChannelServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedChannelServiceServer) Channel ¶
func (UnimplementedChannelServiceServer) Channel(ChannelService_ChannelServer) error
func (UnimplementedChannelServiceServer) Test ¶
func (UnimplementedChannelServiceServer) Test(context.Context, *protorepo_share_go.Empty) (*protorepo_share_go.Empty, error)
type UnsafeChannelServiceServer ¶
type UnsafeChannelServiceServer interface {
// contains filtered or unexported methods
}
UnsafeChannelServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChannelServiceServer will result in compilation errors.