googlecloudtasks

Documentation

Index

• type CloudTasks
  • func (this *CloudTasks) Disconnect() error
  • func (this CloudTasks) Healthy(ctx context.Context) error
  • func (this *CloudTasks) Init(queues []string) error
  • func (this CloudTasks) MaxConcurrentDrainWorkers() int
  • func (this CloudTasks) Pop(ctx context.Context, queueName string, handler types.Handler) error
  • func (this CloudTasks) Publish(ctx context.Context, queueName string, payload *types.Task) error
  • func (this CloudTasks) Purge(ctx context.Context, queueName string) error
  • func (this CloudTasks) PurgeMatching(ctx context.Context, queueName, taskName string) error
  • func (this CloudTasks) Subscribe(ctx context.Context, queueName string, handler types.Handler) error
  • func (this CloudTasks) Suck(ctx context.Context, queueName string, handler types.Handler) error

Types

type CloudTasks

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

func (*CloudTasks) Disconnect

func (this *CloudTasks) Disconnect() error

func (CloudTasks) Healthy

func (this CloudTasks) Healthy(ctx context.Context) error

func (*CloudTasks) Init

func (this *CloudTasks) Init(queues []string) error

func (CloudTasks) MaxConcurrentDrainWorkers

func (this CloudTasks) MaxConcurrentDrainWorkers() int

func (CloudTasks) Pop

func (this CloudTasks) Pop(ctx context.Context, queueName string, handler types.Handler) error

func (CloudTasks) Publish

func (this CloudTasks) Publish(ctx context.Context, queueName string, payload *types.Task) error

func (CloudTasks) Purge

func (this CloudTasks) Purge(ctx context.Context, queueName string) error

func (CloudTasks) PurgeMatching

func (this CloudTasks) PurgeMatching(ctx context.Context, queueName, taskName string) error

func (CloudTasks) Subscribe

func (this CloudTasks) Subscribe(ctx context.Context, queueName string, handler types.Handler) error

func (CloudTasks) Suck

func (this CloudTasks) Suck(ctx context.Context, queueName string, handler types.Handler) error