talkerpb

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_talker_proto protoreflect.FileDescriptor
View Source 
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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.