grpc

Documentation

Index

• func NewGRPCServer(node http.Node) (*grpc.Server, error)
• type QueueServer
  • func NewQueueServer(node http.Node) *QueueServer
  • func (s *QueueServer) Ack(ctx context.Context, req *pb.AckRequest) (*pb.AckResponse, error)
  • func (s *QueueServer) CreateQueue(ctx context.Context, req *pb.CreateQueueRequest) (*pb.CreateQueueResponse, error)
  • func (s *QueueServer) DeleteQueue(ctx context.Context, req *pb.DeleteQueueRequest) (*pb.DeleteQueueResponse, error)
  • func (s *QueueServer) Dequeue(ctx context.Context, req *pb.DequeueRequest) (*pb.DequeueResponse, error)
  • func (s *QueueServer) DequeueStream(req *pb.DequeueRequest, stream pb.DOQ_DequeueStreamServer) error
  • func (s *QueueServer) Enqueue(ctx context.Context, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)
  • func (s *QueueServer) EnqueueStream(stream pb.DOQ_EnqueueStreamServer) error
  • func (s *QueueServer) Nack(ctx context.Context, req *pb.NackRequest) (*pb.NackResponse, error)
  • func (s *QueueServer) UpdatePriority(ctx context.Context, req *pb.UpdatePriorityRequest) (*pb.UpdatePriorityResponse, error)

Functions

func NewGRPCServer

func NewGRPCServer(node http.Node) (*grpc.Server, error)

Types

type QueueServer

type QueueServer struct {
	pb.UnimplementedDOQServer
	// contains filtered or unexported fields
}

func NewQueueServer

func NewQueueServer(node http.Node) *QueueServer

func (*QueueServer) Ack

func (s *QueueServer) Ack(ctx context.Context, req *pb.AckRequest) (*pb.AckResponse, error)

Ack message handling (this could be used to confirm message processing, depending on your requirements)

func (*QueueServer) CreateQueue

func (s *QueueServer) CreateQueue(ctx context.Context, req *pb.CreateQueueRequest) (*pb.CreateQueueResponse, error)

CreateQueue creates a new queue

func (*QueueServer) DeleteQueue

func (s *QueueServer) DeleteQueue(ctx context.Context, req *pb.DeleteQueueRequest) (*pb.DeleteQueueResponse, error)

DeleteQueue deletes a queue

func (*QueueServer) Dequeue

func (s *QueueServer) Dequeue(ctx context.Context, req *pb.DequeueRequest) (*pb.DequeueResponse, error)

Dequeue implements server-side streaming for dequeuing messages

func (*QueueServer) DequeueStream

func (s *QueueServer) DequeueStream(req *pb.DequeueRequest, stream pb.DOQ_DequeueStreamServer) error

DequeueStream implements server-side streaming for dequeuing messages

func (*QueueServer) Enqueue

func (s *QueueServer) Enqueue(ctx context.Context, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)

Enqueue implements client-side streaming for enqueuing messages

func (*QueueServer) EnqueueStream

func (s *QueueServer) EnqueueStream(stream pb.DOQ_EnqueueStreamServer) error

EnqueueStream implements client-side streaming for enqueuing messages

func (*QueueServer) Nack

func (s *QueueServer) Nack(ctx context.Context, req *pb.NackRequest) (*pb.NackResponse, error)

Nack message handling (this could be used to confirm message processing, depending on your requirements)

func (*QueueServer) UpdatePriority

func (s *QueueServer) UpdatePriority(ctx context.Context, req *pb.UpdatePriorityRequest) (*pb.UpdatePriorityResponse, error)

Acknowledge message handling (this could be used to confirm message processing, depending on your requirements)