gcp

Documentation

Index

• Variables
• 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
• type GCS
  • func (d *GCS) Cleanup() error
  • func (d *GCS) ClearWork() error
  • func (d *GCS) GetWork() (io.Reader, error)
  • func (d *GCS) HandleFailure() error
  • func (d *GCS) Init() error
  • func (d *GCS) LoadEnv(prefix string) error
  • func (d *GCS) LoadFlags() error
• type GCSOp
  • func (o *GCSOp) GetKey() string
• type GCSOperation

Variables

var (
	GCSOperationRM = GCSOperation("rm")
	GCSOperationMV = GCSOperation("mv")
)

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

type GCS

type GCS struct {
	Client    *storage.Client
	Bucket    string
	Key       string
	KeyRegex  string
	KeyPrefix string
	ClearOp   *GCSOp
	FailOp    *GCSOp
}

func (*GCS) Cleanup

func (d *GCS) Cleanup() error

func (*GCS) ClearWork

func (d *GCS) ClearWork() error

func (*GCS) GetWork

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

func (*GCS) HandleFailure

func (d *GCS) HandleFailure() error

func (*GCS) Init

func (d *GCS) Init() error

func (*GCS) LoadEnv

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

func (*GCS) LoadFlags

func (d *GCS) LoadFlags() error

type GCSOp

type GCSOp struct {
	Operation   GCSOperation
	Bucket      string
	Key         string
	KeyTemplate string
}

func (*GCSOp) GetKey

func (o *GCSOp) GetKey() string

type GCSOperation

type GCSOperation string