grpc

package
v0.2.16 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 14, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewGRPCServer 

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

Types

type GRPCProxy added in v0.2.16 

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

func NewGRPCProxy added in v0.2.16 

func NewGRPCProxy(client pb.DOQClient, port int) *GRPCProxy

func (*GRPCProxy) Ack added in v0.2.16 

func (p *GRPCProxy) Ack(ctx context.Context, host string, req *pb.AckRequest) (*pb.AckResponse, error)

func (*GRPCProxy) CreateQueue added in v0.2.16 

func (p *GRPCProxy) CreateQueue(ctx context.Context, host string, req *pb.CreateQueueRequest) (*pb.CreateQueueResponse, error)

func (*GRPCProxy) DeleteQueue added in v0.2.16 

func (p *GRPCProxy) DeleteQueue(ctx context.Context, host string, req *pb.DeleteQueueRequest) (*pb.DeleteQueueResponse, error)

func (*GRPCProxy) Dequeue added in v0.2.16 

func (p *GRPCProxy) Dequeue(ctx context.Context, host string, req *pb.DequeueRequest) (*pb.DequeueResponse, error)

func (*GRPCProxy) DequeueStream added in v0.2.16 

func (p *GRPCProxy) DequeueStream(req *pb.DequeueRequest, outStream pb.DOQ_DequeueStreamServer, host string) error

func (*GRPCProxy) Enqueue added in v0.2.16 

func (p *GRPCProxy) Enqueue(ctx context.Context, host string, req *pb.EnqueueRequest) (*pb.EnqueueResponse, error)

func (*GRPCProxy) EnqueueStream added in v0.2.16 

func (p *GRPCProxy) EnqueueStream(inStream pb.DOQ_EnqueueStreamServer, host string) error

func (*GRPCProxy) Nack added in v0.2.16 

func (p *GRPCProxy) Nack(ctx context.Context, host string, req *pb.NackRequest) (*pb.NackResponse, error)

func (*GRPCProxy) UpdatePriority added in v0.2.16 

func (p *GRPCProxy) UpdatePriority(ctx context.Context, host string, req *pb.UpdatePriorityRequest) (*pb.UpdatePriorityResponse, error)

type QueueServer 

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

func NewQueueServer 

func NewQueueServer(node http.Node, port int) *QueueServer

func (*QueueServer) Ack added in v0.2.4 

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 added in v0.2.4 

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.