gcp

Documentation

Index

• type GCPPubSub
  • func (d *GCPPubSub) Cleanup() error
  • func (d *GCPPubSub) ClearWork() error
  • func (d *GCPPubSub) GetWork() (io.Reader, error)
  • func (d *GCPPubSub) HandleFailure() error
  • func (d *GCPPubSub) Init() error
  • func (d *GCPPubSub) LoadEnv(prefix string) error
  • func (d *GCPPubSub) LoadFlags() error

Types

type GCPPubSub

type GCPPubSub struct {
	Client           *pubsub.Client
	ProjectID        string
	SubscriptionName string
}

func (*GCPPubSub) Cleanup

func (d *GCPPubSub) Cleanup() error

func (*GCPPubSub) ClearWork

func (d *GCPPubSub) ClearWork() error

func (*GCPPubSub) GetWork

func (d *GCPPubSub) GetWork() (io.Reader, error)

func (*GCPPubSub) HandleFailure

func (d *GCPPubSub) HandleFailure() error

func (*GCPPubSub) Init

func (d *GCPPubSub) Init() error

func (*GCPPubSub) LoadEnv

func (d *GCPPubSub) LoadEnv(prefix string) error

func (*GCPPubSub) LoadFlags

func (d *GCPPubSub) LoadFlags() error