queuespb

type DequeuedMessage struct {
	LeaseId string        `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	Message *QueueMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type FailedEnqueueMessage struct {

	// The message that failed to be pushed
	Message *QueueMessage `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// A description of the failure
	Details string `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

type QueueCompleteRequest struct {

	// The nitric name for the queue
	//
	//	this will automatically be resolved to the provider specific queue identifier.
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// Lease id of the message to be completed
	LeaseId string `protobuf:"bytes,2,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	// contains filtered or unexported fields
}

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

type QueueDequeueRequest struct {

	// The nitric name for the queue
	// this will automatically be resolved to the provider specific queue identifier.
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// The max number of messages to pop off the queue, may be capped by provider specific limitations
	Depth int32 `protobuf:"varint,2,opt,name=depth,proto3" json:"depth,omitempty"`
	// contains filtered or unexported fields
}

type QueueDequeueResponse struct {

	// Array of messages popped off the queue
	Messages []*DequeuedMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type QueueEnqueueRequest struct {

	// The Nitric name for the queue
	// this will automatically be resolved to the provider specific queue identifier.
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// Array of messages to push to the queue
	Messages []*QueueMessage `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type QueueEnqueueResponse struct {

	// A list of messages that failed to be queued
	FailedMessages []*FailedEnqueueMessage `protobuf:"bytes,1,rep,name=failed_messages,json=failedMessages,proto3" json:"failed_messages,omitempty"`
	// contains filtered or unexported fields
}

type QueueMessage struct {

	// The queue message contents
	//
	// Types that are assignable to Content:
	//
	//	*QueueMessage_StructPayload
	Content isQueueMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type QueueMessage_StructPayload struct {
	StructPayload *structpb.Struct `protobuf:"bytes,1,opt,name=struct_payload,json=structPayload,proto3,oneof"`
}

type QueuesClient interface {
	// Send message(s) to a queue
	Enqueue(ctx context.Context, in *QueueEnqueueRequest, opts ...grpc.CallOption) (*QueueEnqueueResponse, error)
	// Receive message(s) from a queue
	Dequeue(ctx context.Context, in *QueueDequeueRequest, opts ...grpc.CallOption) (*QueueDequeueResponse, error)
	// Complete an message previously popped from a queue
	Complete(ctx context.Context, in *QueueCompleteRequest, opts ...grpc.CallOption) (*QueueCompleteResponse, error)
}

type QueuesServer interface {
	// Send message(s) to a queue
	Enqueue(context.Context, *QueueEnqueueRequest) (*QueueEnqueueResponse, error)
	// Receive message(s) from a queue
	Dequeue(context.Context, *QueueDequeueRequest) (*QueueDequeueResponse, error)
	// Complete an message previously popped from a queue
	Complete(context.Context, *QueueCompleteRequest) (*QueueCompleteResponse, error)
}

type UnimplementedQueuesServer struct {
}

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