Documentation ¶
Index ¶
- Variables
- func RegisterTalkerServer(s grpc.ServiceRegistrar, srv TalkerServer)
- type AdditionRequest
- func (*AdditionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AdditionRequest) GetAddend() uint32
- func (x *AdditionRequest) GetTarget() string
- func (*AdditionRequest) ProtoMessage()
- func (x *AdditionRequest) ProtoReflect() protoreflect.Message
- func (x *AdditionRequest) Reset()
- func (x *AdditionRequest) String() string
- type AdditionResponse
- type ByeRequest
- type ByeResponse
- type FailOnFourRequest
- func (*FailOnFourRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FailOnFourRequest) GetTarget() string
- func (x *FailOnFourRequest) GetValue() uint32
- func (*FailOnFourRequest) ProtoMessage()
- func (x *FailOnFourRequest) ProtoReflect() protoreflect.Message
- func (x *FailOnFourRequest) Reset()
- func (x *FailOnFourRequest) String() string
- type FailOnFourResponse
- func (*FailOnFourResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FailOnFourResponse) GetMessage() string
- func (*FailOnFourResponse) ProtoMessage()
- func (x *FailOnFourResponse) ProtoReflect() protoreflect.Message
- func (x *FailOnFourResponse) Reset()
- func (x *FailOnFourResponse) String() string
- type FailRequest
- func (*FailRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FailRequest) GetMessage() string
- func (x *FailRequest) GetTarget() string
- func (*FailRequest) ProtoMessage()
- func (x *FailRequest) ProtoReflect() protoreflect.Message
- func (x *FailRequest) Reset()
- func (x *FailRequest) String() string
- type FailResponse
- type FibonacciRequest
- func (*FibonacciRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FibonacciRequest) GetPlaces() uint32
- func (x *FibonacciRequest) GetTarget() string
- func (*FibonacciRequest) ProtoMessage()
- func (x *FibonacciRequest) ProtoReflect() protoreflect.Message
- func (x *FibonacciRequest) Reset()
- func (x *FibonacciRequest) String() string
- type FibonacciResponse
- func (*FibonacciResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FibonacciResponse) GetPosition() uint32
- func (x *FibonacciResponse) GetValue() uint32
- func (*FibonacciResponse) ProtoMessage()
- func (x *FibonacciResponse) ProtoReflect() protoreflect.Message
- func (x *FibonacciResponse) Reset()
- func (x *FibonacciResponse) String() string
- type HelloRequest
- func (*HelloRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HelloRequest) GetMessage() string
- func (x *HelloRequest) GetTarget() string
- func (*HelloRequest) ProtoMessage()
- func (x *HelloRequest) ProtoReflect() protoreflect.Message
- func (x *HelloRequest) Reset()
- func (x *HelloRequest) String() string
- type HelloResponse
- type TalkerClient
- type TalkerServer
- type Talker_AdditionClient
- type Talker_AdditionServer
- type Talker_FailOnFourClient
- type Talker_FailOnFourServer
- type Talker_FibonacciClient
- type Talker_FibonacciServer
- type UnimplementedTalkerServer
- func (UnimplementedTalkerServer) Addition(Talker_AdditionServer) error
- func (UnimplementedTalkerServer) Bye(context.Context, *ByeRequest) (*ByeResponse, error)
- func (UnimplementedTalkerServer) Fail(context.Context, *FailRequest) (*FailResponse, error)
- func (UnimplementedTalkerServer) FailOnFour(Talker_FailOnFourServer) error
- func (UnimplementedTalkerServer) Fibonacci(*FibonacciRequest, Talker_FibonacciServer) error
- func (UnimplementedTalkerServer) Hello(context.Context, *HelloRequest) (*HelloResponse, error)
- func (UnimplementedTalkerServer) Whisper(context.Context, *WhisperRequest) (*WhisperResponse, error)
- type UnsafeTalkerServer
- type WhisperRequest
- func (*WhisperRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WhisperRequest) GetMessage() string
- func (x *WhisperRequest) GetTarget() string
- func (*WhisperRequest) ProtoMessage()
- func (x *WhisperRequest) ProtoReflect() protoreflect.Message
- func (x *WhisperRequest) Reset()
- func (x *WhisperRequest) String() string
- type WhisperResponse
Constants ¶
This section is empty.
Variables ¶
var File_talker_proto protoreflect.FileDescriptor
var Talker_ServiceDesc = grpc.ServiceDesc{ ServiceName: "abcxyz.test.Talker", HandlerType: (*TalkerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Hello", Handler: _Talker_Hello_Handler, }, { MethodName: "Whisper", Handler: _Talker_Whisper_Handler, }, { MethodName: "Bye", Handler: _Talker_Bye_Handler, }, { MethodName: "Fail", Handler: _Talker_Fail_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Fibonacci", Handler: _Talker_Fibonacci_Handler, ServerStreams: true, }, { StreamName: "Addition", Handler: _Talker_Addition_Handler, ClientStreams: true, }, { StreamName: "FailOnFour", Handler: _Talker_FailOnFour_Handler, ClientStreams: true, }, }, Metadata: "talker.proto", }
Talker_ServiceDesc is the grpc.ServiceDesc for Talker service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTalkerServer ¶
func RegisterTalkerServer(s grpc.ServiceRegistrar, srv TalkerServer)
Types ¶
type AdditionRequest ¶
type AdditionRequest struct { Addend uint32 `protobuf:"varint,1,opt,name=addend,proto3" json:"addend,omitempty"` Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` // contains filtered or unexported fields }
func (*AdditionRequest) Descriptor
deprecated
func (*AdditionRequest) Descriptor() ([]byte, []int)
Deprecated: Use AdditionRequest.ProtoReflect.Descriptor instead.
func (*AdditionRequest) GetAddend ¶
func (x *AdditionRequest) GetAddend() uint32
func (*AdditionRequest) GetTarget ¶
func (x *AdditionRequest) GetTarget() string
func (*AdditionRequest) ProtoMessage ¶
func (*AdditionRequest) ProtoMessage()
func (*AdditionRequest) ProtoReflect ¶
func (x *AdditionRequest) ProtoReflect() protoreflect.Message
func (*AdditionRequest) Reset ¶
func (x *AdditionRequest) Reset()
func (*AdditionRequest) String ¶
func (x *AdditionRequest) String() string
type AdditionResponse ¶
type AdditionResponse struct { Sum uint64 `protobuf:"varint,1,opt,name=sum,proto3" json:"sum,omitempty"` // contains filtered or unexported fields }
func (*AdditionResponse) Descriptor
deprecated
func (*AdditionResponse) Descriptor() ([]byte, []int)
Deprecated: Use AdditionResponse.ProtoReflect.Descriptor instead.
func (*AdditionResponse) GetSum ¶
func (x *AdditionResponse) GetSum() uint64
func (*AdditionResponse) ProtoMessage ¶
func (*AdditionResponse) ProtoMessage()
func (*AdditionResponse) ProtoReflect ¶
func (x *AdditionResponse) ProtoReflect() protoreflect.Message
func (*AdditionResponse) Reset ¶
func (x *AdditionResponse) Reset()
func (*AdditionResponse) String ¶
func (x *AdditionResponse) String() string
type ByeRequest ¶
type ByeRequest struct { Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ByeRequest) Descriptor
deprecated
func (*ByeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ByeRequest.ProtoReflect.Descriptor instead.
func (*ByeRequest) GetMessage ¶
func (x *ByeRequest) GetMessage() string
func (*ByeRequest) GetTarget ¶
func (x *ByeRequest) GetTarget() string
func (*ByeRequest) ProtoMessage ¶
func (*ByeRequest) ProtoMessage()
func (*ByeRequest) ProtoReflect ¶
func (x *ByeRequest) ProtoReflect() protoreflect.Message
func (*ByeRequest) Reset ¶
func (x *ByeRequest) Reset()
func (*ByeRequest) String ¶
func (x *ByeRequest) String() string
type ByeResponse ¶
type ByeResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ByeResponse) Descriptor
deprecated
func (*ByeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ByeResponse.ProtoReflect.Descriptor instead.
func (*ByeResponse) GetMessage ¶
func (x *ByeResponse) GetMessage() string
func (*ByeResponse) ProtoMessage ¶
func (*ByeResponse) ProtoMessage()
func (*ByeResponse) ProtoReflect ¶
func (x *ByeResponse) ProtoReflect() protoreflect.Message
func (*ByeResponse) Reset ¶
func (x *ByeResponse) Reset()
func (*ByeResponse) String ¶
func (x *ByeResponse) String() string
type FailOnFourRequest ¶
type FailOnFourRequest struct { Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` Value uint32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*FailOnFourRequest) Descriptor
deprecated
func (*FailOnFourRequest) Descriptor() ([]byte, []int)
Deprecated: Use FailOnFourRequest.ProtoReflect.Descriptor instead.
func (*FailOnFourRequest) GetTarget ¶
func (x *FailOnFourRequest) GetTarget() string
func (*FailOnFourRequest) GetValue ¶
func (x *FailOnFourRequest) GetValue() uint32
func (*FailOnFourRequest) ProtoMessage ¶
func (*FailOnFourRequest) ProtoMessage()
func (*FailOnFourRequest) ProtoReflect ¶
func (x *FailOnFourRequest) ProtoReflect() protoreflect.Message
func (*FailOnFourRequest) Reset ¶
func (x *FailOnFourRequest) Reset()
func (*FailOnFourRequest) String ¶
func (x *FailOnFourRequest) String() string
type FailOnFourResponse ¶
type FailOnFourResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*FailOnFourResponse) Descriptor
deprecated
func (*FailOnFourResponse) Descriptor() ([]byte, []int)
Deprecated: Use FailOnFourResponse.ProtoReflect.Descriptor instead.
func (*FailOnFourResponse) GetMessage ¶
func (x *FailOnFourResponse) GetMessage() string
func (*FailOnFourResponse) ProtoMessage ¶
func (*FailOnFourResponse) ProtoMessage()
func (*FailOnFourResponse) ProtoReflect ¶
func (x *FailOnFourResponse) ProtoReflect() protoreflect.Message
func (*FailOnFourResponse) Reset ¶
func (x *FailOnFourResponse) Reset()
func (*FailOnFourResponse) String ¶
func (x *FailOnFourResponse) String() string
type FailRequest ¶
type FailRequest struct { Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*FailRequest) Descriptor
deprecated
func (*FailRequest) Descriptor() ([]byte, []int)
Deprecated: Use FailRequest.ProtoReflect.Descriptor instead.
func (*FailRequest) GetMessage ¶
func (x *FailRequest) GetMessage() string
func (*FailRequest) GetTarget ¶
func (x *FailRequest) GetTarget() string
func (*FailRequest) ProtoMessage ¶
func (*FailRequest) ProtoMessage()
func (*FailRequest) ProtoReflect ¶
func (x *FailRequest) ProtoReflect() protoreflect.Message
func (*FailRequest) Reset ¶
func (x *FailRequest) Reset()
func (*FailRequest) String ¶
func (x *FailRequest) String() string
type FailResponse ¶
type FailResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*FailResponse) Descriptor
deprecated
func (*FailResponse) Descriptor() ([]byte, []int)
Deprecated: Use FailResponse.ProtoReflect.Descriptor instead.
func (*FailResponse) GetMessage ¶
func (x *FailResponse) GetMessage() string
func (*FailResponse) ProtoMessage ¶
func (*FailResponse) ProtoMessage()
func (*FailResponse) ProtoReflect ¶
func (x *FailResponse) ProtoReflect() protoreflect.Message
func (*FailResponse) Reset ¶
func (x *FailResponse) Reset()
func (*FailResponse) String ¶
func (x *FailResponse) String() string
type FibonacciRequest ¶
type FibonacciRequest struct { Places uint32 `protobuf:"varint,1,opt,name=places,proto3" json:"places,omitempty"` Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` // contains filtered or unexported fields }
func (*FibonacciRequest) Descriptor
deprecated
func (*FibonacciRequest) Descriptor() ([]byte, []int)
Deprecated: Use FibonacciRequest.ProtoReflect.Descriptor instead.
func (*FibonacciRequest) GetPlaces ¶
func (x *FibonacciRequest) GetPlaces() uint32
func (*FibonacciRequest) GetTarget ¶
func (x *FibonacciRequest) GetTarget() string
func (*FibonacciRequest) ProtoMessage ¶
func (*FibonacciRequest) ProtoMessage()
func (*FibonacciRequest) ProtoReflect ¶
func (x *FibonacciRequest) ProtoReflect() protoreflect.Message
func (*FibonacciRequest) Reset ¶
func (x *FibonacciRequest) Reset()
func (*FibonacciRequest) String ¶
func (x *FibonacciRequest) String() string
type FibonacciResponse ¶
type FibonacciResponse struct { Position uint32 `protobuf:"varint,1,opt,name=position,proto3" json:"position,omitempty"` Value uint32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*FibonacciResponse) Descriptor
deprecated
func (*FibonacciResponse) Descriptor() ([]byte, []int)
Deprecated: Use FibonacciResponse.ProtoReflect.Descriptor instead.
func (*FibonacciResponse) GetPosition ¶
func (x *FibonacciResponse) GetPosition() uint32
func (*FibonacciResponse) GetValue ¶
func (x *FibonacciResponse) GetValue() uint32
func (*FibonacciResponse) ProtoMessage ¶
func (*FibonacciResponse) ProtoMessage()
func (*FibonacciResponse) ProtoReflect ¶
func (x *FibonacciResponse) ProtoReflect() protoreflect.Message
func (*FibonacciResponse) Reset ¶
func (x *FibonacciResponse) Reset()
func (*FibonacciResponse) String ¶
func (x *FibonacciResponse) String() string
type HelloRequest ¶
type HelloRequest struct { Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*HelloRequest) Descriptor
deprecated
func (*HelloRequest) Descriptor() ([]byte, []int)
Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.
func (*HelloRequest) GetMessage ¶
func (x *HelloRequest) GetMessage() string
func (*HelloRequest) GetTarget ¶
func (x *HelloRequest) GetTarget() string
func (*HelloRequest) ProtoMessage ¶
func (*HelloRequest) ProtoMessage()
func (*HelloRequest) ProtoReflect ¶
func (x *HelloRequest) ProtoReflect() protoreflect.Message
func (*HelloRequest) Reset ¶
func (x *HelloRequest) Reset()
func (*HelloRequest) String ¶
func (x *HelloRequest) String() string
type HelloResponse ¶
type HelloResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*HelloResponse) Descriptor
deprecated
func (*HelloResponse) Descriptor() ([]byte, []int)
Deprecated: Use HelloResponse.ProtoReflect.Descriptor instead.
func (*HelloResponse) GetMessage ¶
func (x *HelloResponse) GetMessage() string
func (*HelloResponse) ProtoMessage ¶
func (*HelloResponse) ProtoMessage()
func (*HelloResponse) ProtoReflect ¶
func (x *HelloResponse) ProtoReflect() protoreflect.Message
func (*HelloResponse) Reset ¶
func (x *HelloResponse) Reset()
func (*HelloResponse) String ¶
func (x *HelloResponse) String() string
type TalkerClient ¶
type TalkerClient interface { // Say hello with something OK to audit log in request/response. Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error) // Whisper with something sensitive (shouldn't be audit logged) in // request/response. Whisper(ctx context.Context, in *WhisperRequest, opts ...grpc.CallOption) (*WhisperResponse, error) // Say bye with something OK to audit log in request, // but we don't care the response at all. Bye(ctx context.Context, in *ByeRequest, opts ...grpc.CallOption) (*ByeResponse, error) Fibonacci(ctx context.Context, in *FibonacciRequest, opts ...grpc.CallOption) (Talker_FibonacciClient, error) Addition(ctx context.Context, opts ...grpc.CallOption) (Talker_AdditionClient, error) // An api that is intended to always throw an error. Fail(ctx context.Context, in *FailRequest, opts ...grpc.CallOption) (*FailResponse, error) // API for client streaming that throws an error if 4 is sent FailOnFour(ctx context.Context, opts ...grpc.CallOption) (Talker_FailOnFourClient, error) }
TalkerClient is the client API for Talker 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 NewTalkerClient ¶
func NewTalkerClient(cc grpc.ClientConnInterface) TalkerClient
type TalkerServer ¶
type TalkerServer interface { // Say hello with something OK to audit log in request/response. Hello(context.Context, *HelloRequest) (*HelloResponse, error) // Whisper with something sensitive (shouldn't be audit logged) in // request/response. Whisper(context.Context, *WhisperRequest) (*WhisperResponse, error) // Say bye with something OK to audit log in request, // but we don't care the response at all. Bye(context.Context, *ByeRequest) (*ByeResponse, error) Fibonacci(*FibonacciRequest, Talker_FibonacciServer) error Addition(Talker_AdditionServer) error // An api that is intended to always throw an error. Fail(context.Context, *FailRequest) (*FailResponse, error) // API for client streaming that throws an error if 4 is sent FailOnFour(Talker_FailOnFourServer) error // contains filtered or unexported methods }
TalkerServer is the server API for Talker service. All implementations must embed UnimplementedTalkerServer for forward compatibility
type Talker_AdditionClient ¶
type Talker_AdditionClient interface { Send(*AdditionRequest) error CloseAndRecv() (*AdditionResponse, error) grpc.ClientStream }
type Talker_AdditionServer ¶
type Talker_AdditionServer interface { SendAndClose(*AdditionResponse) error Recv() (*AdditionRequest, error) grpc.ServerStream }
type Talker_FailOnFourClient ¶
type Talker_FailOnFourClient interface { Send(*FailOnFourRequest) error CloseAndRecv() (*FailOnFourResponse, error) grpc.ClientStream }
type Talker_FailOnFourServer ¶
type Talker_FailOnFourServer interface { SendAndClose(*FailOnFourResponse) error Recv() (*FailOnFourRequest, error) grpc.ServerStream }
type Talker_FibonacciClient ¶
type Talker_FibonacciClient interface { Recv() (*FibonacciResponse, error) grpc.ClientStream }
type Talker_FibonacciServer ¶
type Talker_FibonacciServer interface { Send(*FibonacciResponse) error grpc.ServerStream }
type UnimplementedTalkerServer ¶
type UnimplementedTalkerServer struct { }
UnimplementedTalkerServer must be embedded to have forward compatible implementations.
func (UnimplementedTalkerServer) Addition ¶
func (UnimplementedTalkerServer) Addition(Talker_AdditionServer) error
func (UnimplementedTalkerServer) Bye ¶
func (UnimplementedTalkerServer) Bye(context.Context, *ByeRequest) (*ByeResponse, error)
func (UnimplementedTalkerServer) Fail ¶
func (UnimplementedTalkerServer) Fail(context.Context, *FailRequest) (*FailResponse, error)
func (UnimplementedTalkerServer) FailOnFour ¶
func (UnimplementedTalkerServer) FailOnFour(Talker_FailOnFourServer) error
func (UnimplementedTalkerServer) Fibonacci ¶
func (UnimplementedTalkerServer) Fibonacci(*FibonacciRequest, Talker_FibonacciServer) error
func (UnimplementedTalkerServer) Hello ¶
func (UnimplementedTalkerServer) Hello(context.Context, *HelloRequest) (*HelloResponse, error)
func (UnimplementedTalkerServer) Whisper ¶
func (UnimplementedTalkerServer) Whisper(context.Context, *WhisperRequest) (*WhisperResponse, error)
type UnsafeTalkerServer ¶
type UnsafeTalkerServer interface {
// contains filtered or unexported methods
}
UnsafeTalkerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TalkerServer will result in compilation errors.
type WhisperRequest ¶
type WhisperRequest struct { Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*WhisperRequest) Descriptor
deprecated
func (*WhisperRequest) Descriptor() ([]byte, []int)
Deprecated: Use WhisperRequest.ProtoReflect.Descriptor instead.
func (*WhisperRequest) GetMessage ¶
func (x *WhisperRequest) GetMessage() string
func (*WhisperRequest) GetTarget ¶
func (x *WhisperRequest) GetTarget() string
func (*WhisperRequest) ProtoMessage ¶
func (*WhisperRequest) ProtoMessage()
func (*WhisperRequest) ProtoReflect ¶
func (x *WhisperRequest) ProtoReflect() protoreflect.Message
func (*WhisperRequest) Reset ¶
func (x *WhisperRequest) Reset()
func (*WhisperRequest) String ¶
func (x *WhisperRequest) String() string
type WhisperResponse ¶
type WhisperResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*WhisperResponse) Descriptor
deprecated
func (*WhisperResponse) Descriptor() ([]byte, []int)
Deprecated: Use WhisperResponse.ProtoReflect.Descriptor instead.
func (*WhisperResponse) GetMessage ¶
func (x *WhisperResponse) GetMessage() string
func (*WhisperResponse) ProtoMessage ¶
func (*WhisperResponse) ProtoMessage()
func (*WhisperResponse) ProtoReflect ¶
func (x *WhisperResponse) ProtoReflect() protoreflect.Message
func (*WhisperResponse) Reset ¶
func (x *WhisperResponse) Reset()
func (*WhisperResponse) String ¶
func (x *WhisperResponse) String() string