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 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 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 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
}