queuerpc

type Content struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

type ContentAndQueueName struct {
	Content *Content   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Name    *QueueName `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type ExpiryTime struct {
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

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

type Message struct {
	Content *Content    `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` // The message content
	Id      *ID         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`           // The message ID
	Expiry  *ExpiryTime `protobuf:"bytes,3,opt,name=expiry,proto3" json:"expiry,omitempty"`   // The expiry time
	// contains filtered or unexported fields
}

type QueueLength struct {
	Len int64 `protobuf:"varint,1,opt,name=len,proto3" json:"len,omitempty"`
	// contains filtered or unexported fields
}

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

type QueuedClient interface {
	// Delete deletes the queue with the given name.
	Delete(ctx context.Context, in *QueueName, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Len returns the number of messages in the queue with the given name that are not awaiting acknowledgement.
	Len(ctx context.Context, in *QueueName, opts ...grpc.CallOption) (*QueueLength, error)
	// Get returns the next message from the queue with the given name. The message will, eventually, be automatically requeued if it is not acknowledged.
	Get(ctx context.Context, in *QueueName, opts ...grpc.CallOption) (*Message, error)
	// Put places a message with the given content on the queue with the given name.
	Put(ctx context.Context, in *ContentAndQueueName, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Refresh gets a new expiry time for the message with the given ID.
	Refresh(ctx context.Context, in *ID, opts ...grpc.CallOption) (*ExpiryTime, error)
	// Acknowledge removes the message with the given ID from its queue.
	Acknowledge(ctx context.Context, in *ID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Requeue requeues the message with the given ID.
	Requeue(ctx context.Context, in *ID, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type QueuedServer interface {
	// Delete deletes the queue with the given name.
	Delete(context.Context, *QueueName) (*emptypb.Empty, error)
	// Len returns the number of messages in the queue with the given name that are not awaiting acknowledgement.
	Len(context.Context, *QueueName) (*QueueLength, error)
	// Get returns the next message from the queue with the given name. The message will, eventually, be automatically requeued if it is not acknowledged.
	Get(context.Context, *QueueName) (*Message, error)
	// Put places a message with the given content on the queue with the given name.
	Put(context.Context, *ContentAndQueueName) (*emptypb.Empty, error)
	// Refresh gets a new expiry time for the message with the given ID.
	Refresh(context.Context, *ID) (*ExpiryTime, error)
	// Acknowledge removes the message with the given ID from its queue.
	Acknowledge(context.Context, *ID) (*emptypb.Empty, error)
	// Requeue requeues the message with the given ID.
	Requeue(context.Context, *ID) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type UnimplementedQueuedServer struct {
}

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