proto

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 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) (SuhaibMessageQueue_StreamProduceClient, error)
	StreamConsume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (SuhaibMessageQueue_StreamConsumeClient, error)
	DeleteUntilOffset(ctx context.Context, in *DeleteUntilOffsetRequest, opts ...grpc.CallOption) (*DeleteUntilOffsetResponse, 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(SuhaibMessageQueue_StreamProduceServer) error
	StreamConsume(*ConsumeRequest, SuhaibMessageQueue_StreamConsumeServer) error
	DeleteUntilOffset(context.Context, *DeleteUntilOffsetRequest) (*DeleteUntilOffsetResponse, error)
	// contains filtered or unexported methods
}

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

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

type SuhaibMessageQueue_StreamProduceClient interface {
	Send(*ProduceRequest) error
	CloseAndRecv() (*ProduceResponse, error)
	grpc.ClientStream
}

type SuhaibMessageQueue_StreamProduceServer interface {
	SendAndClose(*ProduceResponse) error
	Recv() (*ProduceRequest, error)
	grpc.ServerStream
}

type UnimplementedSuhaibMessageQueueServer struct {
}

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