gcp

package

v0.0.41 Latest Latest Go to latest Published: Aug 10, 2022 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/robertlestak/procx

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type BQ
type GCPPubSub
type GCS
type GCSOp
- func (o *GCSOp) GetKey() string
type GCSOperation

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

Types ¶

type BQ ¶ added in v0.0.30

type BQ struct {
	Client        *bigquery.Client
	ProjectID     string
	Key           *string
	QueryKey      *bool
	RetrieveQuery *string
	ClearQuery    *string
	FailQuery     *string
}

func (*BQ) Cleanup ¶ added in v0.0.30

func (d *BQ) Cleanup() error

func (*BQ) ClearWork ¶ added in v0.0.30

func (d *BQ) ClearWork() error

func (*BQ) GetWork ¶ added in v0.0.30

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

func (*BQ) HandleFailure ¶ added in v0.0.30

func (d *BQ) HandleFailure() error

func (*BQ) Init ¶ added in v0.0.30

func (d *BQ) Init() error

func (*BQ) LoadEnv ¶ added in v0.0.30

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

func (*BQ) LoadFlags ¶ added in v0.0.30

func (d *BQ) LoadFlags() error

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 ¶ added in v0.0.28

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

func (*GCS) Cleanup ¶ added in v0.0.28

func (d *GCS) Cleanup() error

func (*GCS) ClearWork ¶ added in v0.0.28

func (d *GCS) ClearWork() error

func (*GCS) GetWork ¶ added in v0.0.28

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

func (*GCS) HandleFailure ¶ added in v0.0.28

func (d *GCS) HandleFailure() error

func (*GCS) Init ¶ added in v0.0.28

func (d *GCS) Init() error

func (*GCS) LoadEnv ¶ added in v0.0.28

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

func (*GCS) LoadFlags ¶ added in v0.0.28

func (d *GCS) LoadFlags() error

type GCSOp ¶ added in v0.0.28

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

func (*GCSOp) GetKey ¶ added in v0.0.28

func (o *GCSOp) GetKey() string

type GCSOperation ¶ added in v0.0.28

type GCSOperation string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL