gcsworker

Documentation

Overview

Package gcsworker implements an http worker with automatic Google Cloud authentication.

Index

• func New() blaster.Worker
• type Worker
  • func (w *Worker) Send(ctx context.Context, raw map[string]interface{}) (map[string]interface{}, error)
  • func (w *Worker) Start(ctx context.Context, payload map[string]interface{}) error

Functions

func New

func New() blaster.Worker

New returns a new gcs worker

Types

type Worker

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

Worker is the worker type

func (*Worker) Send

func (w *Worker) Send(ctx context.Context, raw map[string]interface{}) (map[string]interface{}, error)

Send satisfies the blaster.Worker interface

func (*Worker) Start

func (w *Worker) Start(ctx context.Context, payload map[string]interface{}) error

Start satisfies the blaster.Starter interface