reader

type ReadCommandAck struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type ReadCommandStart struct {
	SubId     string `protobuf:"bytes,1,opt,name=subId,proto3" json:"subId,omitempty"`
	BatchSize uint32 `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	// contains filtered or unexported fields
}

type ReadRequest struct {

	// Types that are assignable to Command:
	//
	//	*ReadRequest_Start
	//	*ReadRequest_Ack
	Command isReadRequest_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

type ReadRequest_Ack struct {
	Ack *ReadCommandAck `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type ReadRequest_Start struct {
	Start *ReadCommandStart `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}

type ReadResponse struct {
	Msgs []*pb.CloudEvent `protobuf:"bytes,1,rep,name=msgs,proto3" json:"msgs,omitempty"`
	// contains filtered or unexported fields
}

type Service interface {
	OpenReader(ctx context.Context, userId, subId string, batchSize uint32) (rs model.Reader[[]*pb.CloudEvent], err error)
	OpenAckReader(ctx context.Context, userId, subId string, batchSize uint32) (r model.AckReader[[]*pb.CloudEvent], err error)
}

type ServiceClient interface {
	// Start reading messages for a certain subscription id.
	// For every response, a client should sent the acknowledged messages count.
	Read(ctx context.Context, opts ...grpc.CallOption) (Service_ReadClient, error)
}

type ServiceServer interface {
	// Start reading messages for a certain subscription id.
	// For every response, a client should sent the acknowledged messages count.
	Read(Service_ReadServer) error
}

type Service_ReadClient interface {
	Send(*ReadRequest) error
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type Service_ReadServer interface {
	Send(*ReadResponse) error
	Recv() (*ReadRequest, error)
	grpc.ServerStream
}

type UnimplementedServiceServer struct {
}