queue

Documentation

Index

• type PubsubQueueService
  • func New() (*PubsubQueueService, error)
  • func NewWithClient(client ifaces_pubsub.PubsubClient) *PubsubQueueService
  • func NewWithClients(client ifaces_pubsub.PubsubClient, ...) *PubsubQueueService
  • func (s *PubsubQueueService) Complete(ctx context.Context, req *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)
  • func (s *PubsubQueueService) Dequeue(ctx context.Context, req *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)
  • func (s *PubsubQueueService) Enqueue(ctx context.Context, req *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, error)

Types

type PubsubQueueService

type PubsubQueueService struct {
	queuespb.UnimplementedQueuesServer
	// contains filtered or unexported fields
}

func New

func New() (*PubsubQueueService, error)

New - Constructs a new GCP pubsub client with defaults

func NewWithClient

func NewWithClient(client ifaces_pubsub.PubsubClient) *PubsubQueueService

func NewWithClients

func NewWithClients(client ifaces_pubsub.PubsubClient, subscriberClientGenerator func(ctx context.Context, opts ...option.ClientOption) (ifaces_pubsub.SubscriberClient, error)) *PubsubQueueService

*pubsubbase.SubscriberClient

func (*PubsubQueueService) Complete

func (s *PubsubQueueService) Complete(ctx context.Context, req *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)

func (*PubsubQueueService) Dequeue

func (s *PubsubQueueService) Dequeue(ctx context.Context, req *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)

func (*PubsubQueueService) Enqueue

func (s *PubsubQueueService) Enqueue(ctx context.Context, req *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, error)