messagesvc

Documentation

Index

• Variables
• func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceServer)
• type ConsumeRequest
  • func (*ConsumeRequest) Descriptor() ([]byte, []int)
  • func (x *ConsumeRequest) GetConsumerId() string
  • func (x *ConsumeRequest) GetTopic() string
  • func (*ConsumeRequest) ProtoMessage()
  • func (x *ConsumeRequest) ProtoReflect() protoreflect.Message
  • func (x *ConsumeRequest) Reset()
  • func (x *ConsumeRequest) String() string
• type ConsumeResponse
  • func (*ConsumeResponse) Descriptor() ([]byte, []int)
  • func (x *ConsumeResponse) GetMessage() *v1.Message
  • func (*ConsumeResponse) ProtoMessage()
  • func (x *ConsumeResponse) ProtoReflect() protoreflect.Message
  • func (x *ConsumeResponse) Reset()
  • func (x *ConsumeResponse) String() string
• type MessageServiceClient
  • func NewMessageServiceClient(cc grpc.ClientConnInterface) MessageServiceClient
• type MessageServiceServer
• type MessageService_ConsumeClient
• type MessageService_ConsumeServer
• type ProduceRequest
  • func (*ProduceRequest) Descriptor() ([]byte, []int)
  • func (x *ProduceRequest) GetMessage() *v1.Message
  • func (*ProduceRequest) ProtoMessage()
  • func (x *ProduceRequest) ProtoReflect() protoreflect.Message
  • func (x *ProduceRequest) Reset()
  • func (x *ProduceRequest) String() string
• type ProduceResponse
  • func (*ProduceResponse) Descriptor() ([]byte, []int)
  • func (*ProduceResponse) ProtoMessage()
  • func (x *ProduceResponse) ProtoReflect() protoreflect.Message
  • func (x *ProduceResponse) Reset()
  • func (x *ProduceResponse) String() string
• type UnimplementedMessageServiceServer
  • func (UnimplementedMessageServiceServer) Consume(*ConsumeRequest, MessageService_ConsumeServer) error
  • func (UnimplementedMessageServiceServer) Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
• type UnsafeMessageServiceServer

Variables

var File_arrebato_message_service_v1_service_proto protoreflect.FileDescriptor

var MessageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arrebato.message.service.v1.MessageService",
	HandlerType: (*MessageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Produce",
			Handler:    _MessageService_Produce_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Consume",
			Handler:       _MessageService_Consume_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arrebato/message/service/v1/service.proto",
}

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

Functions

func RegisterMessageServiceServer

func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceServer)

Types

type ConsumeRequest

type ConsumeRequest struct {
	Topic      string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	ConsumerId string `protobuf:"bytes,2,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	// contains filtered or unexported fields
}

The ConsumeRequest message is the request DTO when calling MessageService.Consume. It describes the topic to consume from and the name of the consumer.

func (*ConsumeRequest) Descriptor

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

Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.

func (*ConsumeRequest) GetConsumerId

func (x *ConsumeRequest) GetConsumerId() string

func (*ConsumeRequest) GetTopic

func (x *ConsumeRequest) GetTopic() string

func (*ConsumeRequest) ProtoMessage

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) ProtoReflect

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

func (*ConsumeRequest) Reset

func (x *ConsumeRequest) Reset()

func (*ConsumeRequest) String

func (x *ConsumeRequest) String() string

type ConsumeResponse

type ConsumeResponse struct {
	Message *v1.Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The ConsumeResponse message is the response DTO when streaming from MessageService.Consume. It contains a single message consumed from the topic.

func (*ConsumeResponse) Descriptor

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

Deprecated: Use ConsumeResponse.ProtoReflect.Descriptor instead.

func (*ConsumeResponse) GetMessage

func (x *ConsumeResponse) GetMessage() *v1.Message

func (*ConsumeResponse) ProtoMessage

func (*ConsumeResponse) ProtoMessage()

func (*ConsumeResponse) ProtoReflect

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

func (*ConsumeResponse) Reset

func (x *ConsumeResponse) Reset()

func (*ConsumeResponse) String

func (x *ConsumeResponse) String() string

type MessageServiceClient

type MessageServiceClient interface {
	// Produce a new message on a topic. This RPC should return a NOT_FOUND error code if the topic does not exist.
	Produce(ctx context.Context, in *ProduceRequest, opts ...grpc.CallOption) (*ProduceResponse, error)
	// Consume messages from a topic. This RPC should return a NOT_FOUND error code if the topic does not exist.
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (MessageService_ConsumeClient, error)
}

MessageServiceClient is the client API for MessageService 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 NewMessageServiceClient

func NewMessageServiceClient(cc grpc.ClientConnInterface) MessageServiceClient

type MessageServiceServer

type MessageServiceServer interface {
	// Produce a new message on a topic. This RPC should return a NOT_FOUND error code if the topic does not exist.
	Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
	// Consume messages from a topic. This RPC should return a NOT_FOUND error code if the topic does not exist.
	Consume(*ConsumeRequest, MessageService_ConsumeServer) error
}

MessageServiceServer is the server API for MessageService service. All implementations should embed UnimplementedMessageServiceServer for forward compatibility

type MessageService_ConsumeClient

type MessageService_ConsumeClient interface {
	Recv() (*ConsumeResponse, error)
	grpc.ClientStream
}

type MessageService_ConsumeServer

type MessageService_ConsumeServer interface {
	Send(*ConsumeResponse) error
	grpc.ServerStream
}

type ProduceRequest

type ProduceRequest struct {

	// The message to produce.
	Message *v1.Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The ProduceRequest message is the request DTO when calling MessageService.Produce. It describes the message to produce.

func (*ProduceRequest) Descriptor

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

Deprecated: Use ProduceRequest.ProtoReflect.Descriptor instead.

func (*ProduceRequest) GetMessage

func (x *ProduceRequest) GetMessage() *v1.Message

func (*ProduceRequest) ProtoMessage

func (*ProduceRequest) ProtoMessage()

func (*ProduceRequest) ProtoReflect

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

func (*ProduceRequest) Reset

func (x *ProduceRequest) Reset()

func (*ProduceRequest) String

func (x *ProduceRequest) String() string

type ProduceResponse

type ProduceResponse struct {
	// contains filtered or unexported fields
}

The ProduceResponse message is the response DTO when calling MessageService.Produce.

func (*ProduceResponse) Descriptor

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

Deprecated: Use ProduceResponse.ProtoReflect.Descriptor instead.

func (*ProduceResponse) ProtoMessage

func (*ProduceResponse) ProtoMessage()

func (*ProduceResponse) ProtoReflect

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

func (*ProduceResponse) Reset

func (x *ProduceResponse) Reset()

func (*ProduceResponse) String

func (x *ProduceResponse) String() string

type UnimplementedMessageServiceServer

type UnimplementedMessageServiceServer struct {
}

UnimplementedMessageServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedMessageServiceServer) Consume

func (UnimplementedMessageServiceServer) Consume(*ConsumeRequest, MessageService_ConsumeServer) error

func (UnimplementedMessageServiceServer) Produce

func (UnimplementedMessageServiceServer) Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)

type UnsafeMessageServiceServer

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

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