proto

type AckRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type AckResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type CreateQueueRequest struct {
	Name     string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type     string         `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Settings *QueueSettings `protobuf:"bytes,3,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

type CreateQueueResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type DOQClient interface {
	CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*CreateQueueResponse, error)
	DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*DeleteQueueResponse, error)
	GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*GetQueueResponse, error)
	GetQueues(ctx context.Context, in *GetQueuesRequest, opts ...grpc.CallOption) (*GetQueuesResponse, error)
	Enqueue(ctx context.Context, in *EnqueueRequest, opts ...grpc.CallOption) (*EnqueueResponse, error)
	EnqueueStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[EnqueueRequest, EnqueueResponse], error)
	Dequeue(ctx context.Context, in *DequeueRequest, opts ...grpc.CallOption) (*DequeueResponse, error)
	DequeueStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[DequeueRequest, DequeueResponse], error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*AckResponse, error)
	Nack(ctx context.Context, in *NackRequest, opts ...grpc.CallOption) (*NackResponse, error)
	UpdatePriority(ctx context.Context, in *UpdatePriorityRequest, opts ...grpc.CallOption) (*UpdatePriorityResponse, error)
}

type DOQServer interface {
	CreateQueue(context.Context, *CreateQueueRequest) (*CreateQueueResponse, error)
	DeleteQueue(context.Context, *DeleteQueueRequest) (*DeleteQueueResponse, error)
	GetQueue(context.Context, *GetQueueRequest) (*GetQueueResponse, error)
	GetQueues(context.Context, *GetQueuesRequest) (*GetQueuesResponse, error)
	Enqueue(context.Context, *EnqueueRequest) (*EnqueueResponse, error)
	EnqueueStream(grpc.BidiStreamingServer[EnqueueRequest, EnqueueResponse]) error
	Dequeue(context.Context, *DequeueRequest) (*DequeueResponse, error)
	DequeueStream(grpc.BidiStreamingServer[DequeueRequest, DequeueResponse]) error
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Ack(context.Context, *AckRequest) (*AckResponse, error)
	Nack(context.Context, *NackRequest) (*NackResponse, error)
	UpdatePriority(context.Context, *UpdatePriorityRequest) (*UpdatePriorityResponse, error)
	// contains filtered or unexported methods
}

type DOQ_DequeueStreamClient = grpc.BidiStreamingClient[DequeueRequest, DequeueResponse]

type DOQ_DequeueStreamServer = grpc.BidiStreamingServer[DequeueRequest, DequeueResponse]

type DOQ_EnqueueStreamClient = grpc.BidiStreamingClient[EnqueueRequest, EnqueueResponse]

type DOQ_EnqueueStreamServer = grpc.BidiStreamingServer[EnqueueRequest, EnqueueResponse]

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

type DeleteQueueResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type DeleteRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type DequeueRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Ack       bool   `protobuf:"varint,2,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

type DequeueResponse struct {
	Success   bool              `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	QueueName string            `protobuf:"bytes,2,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64            `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	Group     string            `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	Priority  int64             `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	Content   string            `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
	Metadata  map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EnqueueRequest struct {
	QueueName string            `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64            `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Group     string            `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Priority  int64             `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	Content   string            `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	Metadata  map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EnqueueResponse struct {
	Success   bool              `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	QueueName string            `protobuf:"bytes,2,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64            `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	Group     string            `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	Priority  int64             `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	Content   string            `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
	Metadata  map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type GetQueueResponse struct {
	Name     string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type     string         `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Settings *QueueSettings `protobuf:"bytes,3,opt,name=settings,proto3" json:"settings,omitempty"`
	Stats    *Stats         `protobuf:"bytes,4,opt,name=stats,proto3" json:"stats,omitempty"`
	Ready    int64          `protobuf:"varint,5,opt,name=ready,proto3" json:"ready,omitempty"`     // Number of messages ready to be dequeued
	Unacked  int64          `protobuf:"varint,6,opt,name=unacked,proto3" json:"unacked,omitempty"` // Number of messages that have been dequeued but not acknowledged
	Total    int64          `protobuf:"varint,7,opt,name=total,proto3" json:"total,omitempty"`     // Total number of messages in the queue
	// contains filtered or unexported fields
}

type GetQueuesRequest struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // Optional filter by queue type
	// contains filtered or unexported fields
}

type GetQueuesResponse struct {
	Queues []*GetQueueResponse `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
	// contains filtered or unexported fields
}

type GetRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetResponse struct {
	Success   bool              `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	QueueName string            `protobuf:"bytes,2,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64            `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	Group     string            `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	Priority  int64             `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	Content   string            `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
	Metadata  map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Message struct {
	Group    string            `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Id       uint64            `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Priority int64             `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	Content  string            `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type NackRequest struct {
	QueueName string            `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64            `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Priority  int64             `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	Metadata  map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type NackResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type Queue struct {
	Name     string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type     string         `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Settings *QueueSettings `protobuf:"bytes,3,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

type QueueSettings struct {
	Strategy   QueueSettings_Strategy `protobuf:"varint,1,opt,name=strategy,proto3,enum=queue.QueueSettings_Strategy" json:"strategy,omitempty"`
	MaxUnacked uint32                 `protobuf:"varint,2,opt,name=max_unacked,json=maxUnacked,proto3" json:"max_unacked,omitempty"`
	// contains filtered or unexported fields
}

type QueueSettings_Strategy int32

type RaftCommand struct {

	// Types that are valid to be assigned to Cmd:
	//
	//	*RaftCommand_CreateQueue
	//	*RaftCommand_DeleteQueue
	//	*RaftCommand_GetQueue
	//	*RaftCommand_GetQueues
	//	*RaftCommand_Enqueue
	//	*RaftCommand_Dequeue
	//	*RaftCommand_Get
	//	*RaftCommand_Delete
	//	*RaftCommand_Ack
	//	*RaftCommand_Nack
	//	*RaftCommand_UpdatePriority
	Cmd isRaftCommand_Cmd `protobuf_oneof:"cmd"`
	// contains filtered or unexported fields
}

type RaftCommand_Ack struct {
	Ack *AckRequest `protobuf:"bytes,9,opt,name=ack,proto3,oneof"`
}

type RaftCommand_CreateQueue struct {
	CreateQueue *CreateQueueRequest `protobuf:"bytes,1,opt,name=createQueue,proto3,oneof"`
}

type RaftCommand_Delete struct {
	Delete *DeleteRequest `protobuf:"bytes,8,opt,name=delete,proto3,oneof"`
}

type RaftCommand_DeleteQueue struct {
	DeleteQueue *DeleteQueueRequest `protobuf:"bytes,2,opt,name=deleteQueue,proto3,oneof"`
}

type RaftCommand_Dequeue struct {
	Dequeue *DequeueRequest `protobuf:"bytes,6,opt,name=dequeue,proto3,oneof"`
}

type RaftCommand_Enqueue struct {
	Enqueue *EnqueueRequest `protobuf:"bytes,5,opt,name=enqueue,proto3,oneof"`
}

type RaftCommand_Get struct {
	Get *GetRequest `protobuf:"bytes,7,opt,name=get,proto3,oneof"`
}

type RaftCommand_GetQueue struct {
	GetQueue *GetQueueRequest `protobuf:"bytes,3,opt,name=getQueue,proto3,oneof"`
}

type RaftCommand_GetQueues struct {
	GetQueues *GetQueuesRequest `protobuf:"bytes,4,opt,name=getQueues,proto3,oneof"`
}

type RaftCommand_Nack struct {
	Nack *NackRequest `protobuf:"bytes,10,opt,name=nack,proto3,oneof"`
}

type RaftCommand_UpdatePriority struct {
	UpdatePriority *UpdatePriorityRequest `protobuf:"bytes,11,opt,name=updatePriority,proto3,oneof"`
}

type SnapshotItem struct {

	// Types that are valid to be assigned to Item:
	//
	//	*SnapshotItem_Queue
	//	*SnapshotItem_Message
	Item isSnapshotItem_Item `protobuf_oneof:"item"`
	// contains filtered or unexported fields
}

type SnapshotItem_Message struct {
	Message *Message `protobuf:"bytes,2,opt,name=message,proto3,oneof"`
}

type SnapshotItem_Queue struct {
	Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3,oneof"`
}

type Stats struct {
	EnqueueRPS float64 `protobuf:"fixed64,1,opt,name=enqueueRPS,proto3" json:"enqueueRPS,omitempty"`
	DequeueRPS float64 `protobuf:"fixed64,2,opt,name=dequeueRPS,proto3" json:"dequeueRPS,omitempty"`
	AckRPS     float64 `protobuf:"fixed64,3,opt,name=ackRPS,proto3" json:"ackRPS,omitempty"`
	NackRPS    float64 `protobuf:"fixed64,4,opt,name=nackRPS,proto3" json:"nackRPS,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedDOQServer struct{}

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

type UpdatePriorityRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Priority  int64  `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

type UpdatePriorityResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}