consumersvc

Documentation

Index

• Variables
• func RegisterConsumerServiceServer(s grpc.ServiceRegistrar, srv ConsumerServiceServer)
• type ConsumerServiceClient
  • func NewConsumerServiceClient(cc grpc.ClientConnInterface) ConsumerServiceClient
• type ConsumerServiceServer
• type SetTopicIndexRequest
  • func (*SetTopicIndexRequest) Descriptor() ([]byte, []int)
  • func (x *SetTopicIndexRequest) GetTopicIndex() *v1.TopicIndex
  • func (*SetTopicIndexRequest) ProtoMessage()
  • func (x *SetTopicIndexRequest) ProtoReflect() protoreflect.Message
  • func (x *SetTopicIndexRequest) Reset()
  • func (x *SetTopicIndexRequest) String() string
• type SetTopicIndexResponse
  • func (*SetTopicIndexResponse) Descriptor() ([]byte, []int)
  • func (*SetTopicIndexResponse) ProtoMessage()
  • func (x *SetTopicIndexResponse) ProtoReflect() protoreflect.Message
  • func (x *SetTopicIndexResponse) Reset()
  • func (x *SetTopicIndexResponse) String() string
• type UnimplementedConsumerServiceServer
  • func (UnimplementedConsumerServiceServer) SetTopicIndex(context.Context, *SetTopicIndexRequest) (*SetTopicIndexResponse, error)
• type UnsafeConsumerServiceServer

Variables

var ConsumerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arrebato.consumer.service.v1.ConsumerService",
	HandlerType: (*ConsumerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SetTopicIndex",
			Handler:    _ConsumerService_SetTopicIndex_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "arrebato/consumer/service/v1/service.proto",
}

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

var File_arrebato_consumer_service_v1_service_proto protoreflect.FileDescriptor

Functions

func RegisterConsumerServiceServer

func RegisterConsumerServiceServer(s grpc.ServiceRegistrar, srv ConsumerServiceServer)

Types

type ConsumerServiceClient

type ConsumerServiceClient interface {
	// SetTopicIndex sets the current index of a consumer on a topic. This RPC should return a NOT_FOUND error code if the
	// topic does not exist.
	SetTopicIndex(ctx context.Context, in *SetTopicIndexRequest, opts ...grpc.CallOption) (*SetTopicIndexResponse, error)
}

ConsumerServiceClient is the client API for ConsumerService 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 NewConsumerServiceClient

func NewConsumerServiceClient(cc grpc.ClientConnInterface) ConsumerServiceClient

type ConsumerServiceServer

type ConsumerServiceServer interface {
	// SetTopicIndex sets the current index of a consumer on a topic. This RPC should return a NOT_FOUND error code if the
	// topic does not exist.
	SetTopicIndex(context.Context, *SetTopicIndexRequest) (*SetTopicIndexResponse, error)
}

ConsumerServiceServer is the server API for ConsumerService service. All implementations should embed UnimplementedConsumerServiceServer for forward compatibility

type SetTopicIndexRequest

type SetTopicIndexRequest struct {
	TopicIndex *v1.TopicIndex `protobuf:"bytes,1,opt,name=topic_index,json=topicIndex,proto3" json:"topic_index,omitempty"`
	// contains filtered or unexported fields
}

The SetTopicIndexRequest message is the request DTO when calling ConsumerService.SetTopicIndex. It describes current index of a consumer within a topic.

func (*SetTopicIndexRequest) Descriptor

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

Deprecated: Use SetTopicIndexRequest.ProtoReflect.Descriptor instead.

func (*SetTopicIndexRequest) GetTopicIndex

func (x *SetTopicIndexRequest) GetTopicIndex() *v1.TopicIndex

func (*SetTopicIndexRequest) ProtoMessage

func (*SetTopicIndexRequest) ProtoMessage()

func (*SetTopicIndexRequest) ProtoReflect

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

func (*SetTopicIndexRequest) Reset

func (x *SetTopicIndexRequest) Reset()

func (*SetTopicIndexRequest) String

func (x *SetTopicIndexRequest) String() string

type SetTopicIndexResponse

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

The SetTopicIndexResponse message is the response DTO when calling ConsumerService.SetTopicIndex.

func (*SetTopicIndexResponse) Descriptor

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

Deprecated: Use SetTopicIndexResponse.ProtoReflect.Descriptor instead.

func (*SetTopicIndexResponse) ProtoMessage

func (*SetTopicIndexResponse) ProtoMessage()

func (*SetTopicIndexResponse) ProtoReflect

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

func (*SetTopicIndexResponse) Reset

func (x *SetTopicIndexResponse) Reset()

func (*SetTopicIndexResponse) String

func (x *SetTopicIndexResponse) String() string

type UnimplementedConsumerServiceServer

type UnimplementedConsumerServiceServer struct {
}

UnimplementedConsumerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedConsumerServiceServer) SetTopicIndex

func (UnimplementedConsumerServiceServer) SetTopicIndex(context.Context, *SetTopicIndexRequest) (*SetTopicIndexResponse, error)

type UnsafeConsumerServiceServer

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

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