proto

type BulkRetrieveRequest struct {
	Topic       string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	StartOffset int64  `protobuf:"varint,2,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	Limit       int32  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type BulkRetrieveResponse struct {
	Messages   []*RetrievedMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	Count      int32               `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	NextOffset int64               `protobuf:"varint,3,opt,name=next_offset,json=nextOffset,proto3" json:"next_offset,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type ConsumeResponse struct {
	Message []byte `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Offset  int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

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

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

type DeleteUntilOffsetRequest struct {
	Topic  string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

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

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

type GetEarliestOffsetResponse struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

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

type GetLatestOffsetResponse struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

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

type ProduceResponse struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type RetrievedMessage struct {
	Message []byte `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Offset  int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type SuhaibMessageQueueClient interface {
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
	GetLatestOffset(ctx context.Context, in *GetLatestOffsetRequest, opts ...grpc.CallOption) (*GetLatestOffsetResponse, error)
	GetEarliestOffset(ctx context.Context, in *GetEarliestOffsetRequest, opts ...grpc.CallOption) (*GetEarliestOffsetResponse, error)
	CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*CreateTopicResponse, error)
	// Single message versions
	Produce(ctx context.Context, in *ProduceRequest, opts ...grpc.CallOption) (*ProduceResponse, error)
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponse, error)
	// Stream versions
	StreamProduce(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ProduceRequest, ProduceResponse], error)
	StreamConsume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ConsumeResponse], error)
	DeleteUntilOffset(ctx context.Context, in *DeleteUntilOffsetRequest, opts ...grpc.CallOption) (*DeleteUntilOffsetResponse, error)
	BulkRetrieve(ctx context.Context, in *BulkRetrieveRequest, opts ...grpc.CallOption) (*BulkRetrieveResponse, error)
}

type SuhaibMessageQueueServer interface {
	Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
	GetLatestOffset(context.Context, *GetLatestOffsetRequest) (*GetLatestOffsetResponse, error)
	GetEarliestOffset(context.Context, *GetEarliestOffsetRequest) (*GetEarliestOffsetResponse, error)
	CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)
	// Single message versions
	Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
	Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
	// Stream versions
	StreamProduce(grpc.ClientStreamingServer[ProduceRequest, ProduceResponse]) error
	StreamConsume(*ConsumeRequest, grpc.ServerStreamingServer[ConsumeResponse]) error
	DeleteUntilOffset(context.Context, *DeleteUntilOffsetRequest) (*DeleteUntilOffsetResponse, error)
	BulkRetrieve(context.Context, *BulkRetrieveRequest) (*BulkRetrieveResponse, error)
	// contains filtered or unexported methods
}

type SuhaibMessageQueue_StreamConsumeClient = grpc.ServerStreamingClient[ConsumeResponse]

type SuhaibMessageQueue_StreamConsumeServer = grpc.ServerStreamingServer[ConsumeResponse]

type SuhaibMessageQueue_StreamProduceClient = grpc.ClientStreamingClient[ProduceRequest, ProduceResponse]

type SuhaibMessageQueue_StreamProduceServer = grpc.ClientStreamingServer[ProduceRequest, ProduceResponse]

type UnimplementedSuhaibMessageQueueServer struct{}

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