messageman

Documentation

Index

• Variables
• func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)
• type ReceiveRequest
  • func (*ReceiveRequest) Descriptor() ([]byte, []int)
  • func (x *ReceiveRequest) GetMessage() []byte
  • func (x *ReceiveRequest) GetName() string
  • func (*ReceiveRequest) ProtoMessage()
  • func (x *ReceiveRequest) ProtoReflect() protoreflect.Message
  • func (x *ReceiveRequest) Reset()
  • func (x *ReceiveRequest) String() string
• type UnimplementedWorkerServiceServer
  • func (UnimplementedWorkerServiceServer) Receive(context.Context, *ReceiveRequest) (*emptypb.Empty, error)
• type UnsafeWorkerServiceServer
• type WorkerServiceClient
  • func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient
• type WorkerServiceServer

Variables

var File_pb_v1_worker_proto protoreflect.FileDescriptor

var WorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "messageman.v1.WorkerService",
	HandlerType: (*WorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Receive",
			Handler:    _WorkerService_Receive_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pb/v1/worker.proto",
}

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

Functions

func RegisterWorkerServiceServer

func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)

Types

type ReceiveRequest

type ReceiveRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiveRequest) Descriptor

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

Deprecated: Use ReceiveRequest.ProtoReflect.Descriptor instead.

func (*ReceiveRequest) GetMessage

func (x *ReceiveRequest) GetMessage() []byte

func (*ReceiveRequest) GetName

func (x *ReceiveRequest) GetName() string

func (*ReceiveRequest) ProtoMessage

func (*ReceiveRequest) ProtoMessage()

func (*ReceiveRequest) ProtoReflect

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

func (*ReceiveRequest) Reset

func (x *ReceiveRequest) Reset()

func (*ReceiveRequest) String

func (x *ReceiveRequest) String() string

type UnimplementedWorkerServiceServer

type UnimplementedWorkerServiceServer struct {
}

UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerServiceServer) Receive

func (UnimplementedWorkerServiceServer) Receive(context.Context, *ReceiveRequest) (*emptypb.Empty, error)

type UnsafeWorkerServiceServer

type UnsafeWorkerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServiceServer will result in compilation errors.

type WorkerServiceClient

type WorkerServiceClient interface {
	Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

WorkerServiceClient is the client API for WorkerService 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 NewWorkerServiceClient

func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient

type WorkerServiceServer

type WorkerServiceServer interface {
	Receive(context.Context, *ReceiveRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

WorkerServiceServer is the server API for WorkerService service. All implementations must embed UnimplementedWorkerServiceServer for forward compatibility