proto

package

Go to main page

Versions in this module

v1

v1.0.7

May 15, 2025

v1.0.6

May 15, 2025

v1.0.5

May 15, 2025

v1.0.4

May 15, 2025

v1.0.3

May 15, 2025

v1.0.2

May 15, 2025

Changes in this version

+ const SuhaibMessageQueue_BulkRetrieve_FullMethodName

+ const SuhaibMessageQueue_Connect_FullMethodName

+ const SuhaibMessageQueue_Consume_FullMethodName

+ const SuhaibMessageQueue_CreateTopic_FullMethodName

+ const SuhaibMessageQueue_DeleteUntilOffset_FullMethodName

+ const SuhaibMessageQueue_GetEarliestOffset_FullMethodName

+ const SuhaibMessageQueue_GetLatestOffset_FullMethodName

+ const SuhaibMessageQueue_Produce_FullMethodName

+ const SuhaibMessageQueue_StreamConsume_FullMethodName

+ const SuhaibMessageQueue_StreamProduce_FullMethodName

+ type BulkRetrieveRequest struct

+ Limit int32

+ StartOffset int64

+ Topic string

+ func (*BulkRetrieveRequest) Descriptor() ([]byte, []int)

+ func (*BulkRetrieveRequest) ProtoMessage()

+ func (x *BulkRetrieveRequest) GetLimit() int32

+ func (x *BulkRetrieveRequest) GetStartOffset() int64

+ func (x *BulkRetrieveRequest) GetTopic() string

+ func (x *BulkRetrieveRequest) ProtoReflect() protoreflect.Message

+ func (x *BulkRetrieveRequest) Reset()

+ func (x *BulkRetrieveRequest) String() string

+ type BulkRetrieveResponse struct

+ Count int32

+ Messages []*RetrievedMessage

+ NextOffset int64

+ func (*BulkRetrieveResponse) Descriptor() ([]byte, []int)

+ func (*BulkRetrieveResponse) ProtoMessage()

+ func (x *BulkRetrieveResponse) GetCount() int32

+ func (x *BulkRetrieveResponse) GetMessages() []*RetrievedMessage

+ func (x *BulkRetrieveResponse) GetNextOffset() int64

+ func (x *BulkRetrieveResponse) ProtoReflect() protoreflect.Message

+ func (x *BulkRetrieveResponse) Reset()

+ func (x *BulkRetrieveResponse) String() string

+ type RetrievedMessage struct

+ Message []byte

+ Offset int64

+ func (*RetrievedMessage) Descriptor() ([]byte, []int)

+ func (*RetrievedMessage) ProtoMessage()

+ func (x *RetrievedMessage) GetMessage() []byte

+ func (x *RetrievedMessage) GetOffset() int64

+ func (x *RetrievedMessage) ProtoReflect() protoreflect.Message

+ func (x *RetrievedMessage) Reset()

+ func (x *RetrievedMessage) String() string

type SuhaibMessageQueueClient

+ BulkRetrieve func(ctx context.Context, in *BulkRetrieveRequest, opts ...grpc.CallOption) (*BulkRetrieveResponse, error)

type SuhaibMessageQueueServer

+ BulkRetrieve func(context.Context, *BulkRetrieveRequest) (*BulkRetrieveResponse, error)

type UnimplementedSuhaibMessageQueueServer

+ func (UnimplementedSuhaibMessageQueueServer) BulkRetrieve(context.Context, *BulkRetrieveRequest) (*BulkRetrieveResponse, error)

v1.0.1

May 13, 2025

v1.0.0

May 13, 2025

Changes in this version

+ var File_smq_proto protoreflect.FileDescriptor

+ var SuhaibMessageQueue_ServiceDesc = grpc.ServiceDesc

+ func RegisterSuhaibMessageQueueServer(s grpc.ServiceRegistrar, srv SuhaibMessageQueueServer)

+ type ConnectRequest struct

+ func (*ConnectRequest) Descriptor() ([]byte, []int)

+ func (*ConnectRequest) ProtoMessage()

+ func (x *ConnectRequest) ProtoReflect() protoreflect.Message

+ func (x *ConnectRequest) Reset()

+ func (x *ConnectRequest) String() string

+ type ConnectResponse struct

+ func (*ConnectResponse) Descriptor() ([]byte, []int)

+ func (*ConnectResponse) ProtoMessage()

+ func (x *ConnectResponse) ProtoReflect() protoreflect.Message

+ func (x *ConnectResponse) Reset()

+ func (x *ConnectResponse) String() string

+ type ConsumeRequest struct

+ Offset int64

+ Topic string

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

+ func (*ConsumeRequest) ProtoMessage()

+ func (x *ConsumeRequest) GetOffset() int64

+ func (x *ConsumeRequest) GetTopic() string

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

+ func (x *ConsumeRequest) Reset()

+ func (x *ConsumeRequest) String() string

+ type ConsumeResponse struct

+ Message []byte

+ Offset int64

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

+ func (*ConsumeResponse) ProtoMessage()

+ func (x *ConsumeResponse) GetMessage() []byte

+ func (x *ConsumeResponse) GetOffset() int64

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

+ func (x *ConsumeResponse) Reset()

+ func (x *ConsumeResponse) String() string

+ type CreateTopicRequest struct

+ Topic string

+ func (*CreateTopicRequest) Descriptor() ([]byte, []int)

+ func (*CreateTopicRequest) ProtoMessage()

+ func (x *CreateTopicRequest) GetTopic() string

+ func (x *CreateTopicRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateTopicRequest) Reset()

+ func (x *CreateTopicRequest) String() string

+ type CreateTopicResponse struct

+ func (*CreateTopicResponse) Descriptor() ([]byte, []int)

+ func (*CreateTopicResponse) ProtoMessage()

+ func (x *CreateTopicResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateTopicResponse) Reset()

+ func (x *CreateTopicResponse) String() string

+ type DeleteUntilOffsetRequest struct

+ Offset int64

+ Topic string

+ func (*DeleteUntilOffsetRequest) Descriptor() ([]byte, []int)

+ func (*DeleteUntilOffsetRequest) ProtoMessage()

+ func (x *DeleteUntilOffsetRequest) GetOffset() int64

+ func (x *DeleteUntilOffsetRequest) GetTopic() string

+ func (x *DeleteUntilOffsetRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteUntilOffsetRequest) Reset()

+ func (x *DeleteUntilOffsetRequest) String() string

+ type DeleteUntilOffsetResponse struct

+ func (*DeleteUntilOffsetResponse) Descriptor() ([]byte, []int)

+ func (*DeleteUntilOffsetResponse) ProtoMessage()

+ func (x *DeleteUntilOffsetResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteUntilOffsetResponse) Reset()

+ func (x *DeleteUntilOffsetResponse) String() string

+ type GetEarliestOffsetRequest struct

+ Topic string

+ func (*GetEarliestOffsetRequest) Descriptor() ([]byte, []int)

+ func (*GetEarliestOffsetRequest) ProtoMessage()

+ func (x *GetEarliestOffsetRequest) GetTopic() string

+ func (x *GetEarliestOffsetRequest) ProtoReflect() protoreflect.Message

+ func (x *GetEarliestOffsetRequest) Reset()

+ func (x *GetEarliestOffsetRequest) String() string

+ type GetEarliestOffsetResponse struct

+ Offset int64

+ func (*GetEarliestOffsetResponse) Descriptor() ([]byte, []int)

+ func (*GetEarliestOffsetResponse) ProtoMessage()

+ func (x *GetEarliestOffsetResponse) GetOffset() int64

+ func (x *GetEarliestOffsetResponse) ProtoReflect() protoreflect.Message

+ func (x *GetEarliestOffsetResponse) Reset()

+ func (x *GetEarliestOffsetResponse) String() string

+ type GetLatestOffsetRequest struct

+ Topic string

+ func (*GetLatestOffsetRequest) Descriptor() ([]byte, []int)

+ func (*GetLatestOffsetRequest) ProtoMessage()

+ func (x *GetLatestOffsetRequest) GetTopic() string

+ func (x *GetLatestOffsetRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLatestOffsetRequest) Reset()

+ func (x *GetLatestOffsetRequest) String() string

+ type GetLatestOffsetResponse struct

+ Offset int64

+ func (*GetLatestOffsetResponse) Descriptor() ([]byte, []int)

+ func (*GetLatestOffsetResponse) ProtoMessage()

+ func (x *GetLatestOffsetResponse) GetOffset() int64

+ func (x *GetLatestOffsetResponse) ProtoReflect() protoreflect.Message

+ func (x *GetLatestOffsetResponse) Reset()

+ func (x *GetLatestOffsetResponse) String() string

+ type ProduceRequest struct

+ Message []byte

+ Topic string

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

+ func (*ProduceRequest) ProtoMessage()

+ func (x *ProduceRequest) GetMessage() []byte

+ func (x *ProduceRequest) GetTopic() string

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

+ func (x *ProduceRequest) Reset()

+ func (x *ProduceRequest) String() string

+ type ProduceResponse struct

+ Offset int64

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

+ func (*ProduceResponse) ProtoMessage()

+ func (x *ProduceResponse) GetOffset() int64

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

+ func (x *ProduceResponse) Reset()

+ func (x *ProduceResponse) String() string

+ type SuhaibMessageQueueClient interface

+ Connect func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)

+ Consume func(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponse, error)

+ CreateTopic func(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*CreateTopicResponse, error)

+ DeleteUntilOffset func(ctx context.Context, in *DeleteUntilOffsetRequest, opts ...grpc.CallOption) (*DeleteUntilOffsetResponse, error)

+ GetEarliestOffset func(ctx context.Context, in *GetEarliestOffsetRequest, opts ...grpc.CallOption) (*GetEarliestOffsetResponse, error)

+ GetLatestOffset func(ctx context.Context, in *GetLatestOffsetRequest, opts ...grpc.CallOption) (*GetLatestOffsetResponse, error)

+ Produce func(ctx context.Context, in *ProduceRequest, opts ...grpc.CallOption) (*ProduceResponse, error)

+ StreamConsume func(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (SuhaibMessageQueue_StreamConsumeClient, error)

+ StreamProduce func(ctx context.Context, opts ...grpc.CallOption) (SuhaibMessageQueue_StreamProduceClient, error)

+ func NewSuhaibMessageQueueClient(cc grpc.ClientConnInterface) SuhaibMessageQueueClient

+ type SuhaibMessageQueueServer interface

+ Connect func(context.Context, *ConnectRequest) (*ConnectResponse, error)

+ Consume func(context.Context, *ConsumeRequest) (*ConsumeResponse, error)

+ CreateTopic func(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)

+ DeleteUntilOffset func(context.Context, *DeleteUntilOffsetRequest) (*DeleteUntilOffsetResponse, error)

+ GetEarliestOffset func(context.Context, *GetEarliestOffsetRequest) (*GetEarliestOffsetResponse, error)

+ GetLatestOffset func(context.Context, *GetLatestOffsetRequest) (*GetLatestOffsetResponse, error)

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

+ StreamConsume func(*ConsumeRequest, SuhaibMessageQueue_StreamConsumeServer) error

+ StreamProduce func(SuhaibMessageQueue_StreamProduceServer) error

+ type SuhaibMessageQueue_StreamConsumeClient interface

+ Recv func() (*ConsumeResponse, error)

+ type SuhaibMessageQueue_StreamConsumeServer interface

+ Send func(*ConsumeResponse) error

+ type SuhaibMessageQueue_StreamProduceClient interface

+ CloseAndRecv func() (*ProduceResponse, error)

+ Send func(*ProduceRequest) error

+ type SuhaibMessageQueue_StreamProduceServer interface

+ Recv func() (*ProduceRequest, error)

+ SendAndClose func(*ProduceResponse) error

+ type UnimplementedSuhaibMessageQueueServer struct

+ func (UnimplementedSuhaibMessageQueueServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)

+ func (UnimplementedSuhaibMessageQueueServer) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)

+ func (UnimplementedSuhaibMessageQueueServer) CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)

+ func (UnimplementedSuhaibMessageQueueServer) DeleteUntilOffset(context.Context, *DeleteUntilOffsetRequest) (*DeleteUntilOffsetResponse, error)

+ func (UnimplementedSuhaibMessageQueueServer) GetEarliestOffset(context.Context, *GetEarliestOffsetRequest) (*GetEarliestOffsetResponse, error)

+ func (UnimplementedSuhaibMessageQueueServer) GetLatestOffset(context.Context, *GetLatestOffsetRequest) (*GetLatestOffsetResponse, error)

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

+ func (UnimplementedSuhaibMessageQueueServer) StreamConsume(*ConsumeRequest, SuhaibMessageQueue_StreamConsumeServer) error

+ func (UnimplementedSuhaibMessageQueueServer) StreamProduce(SuhaibMessageQueue_StreamProduceServer) error

+ type UnsafeSuhaibMessageQueueServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL