gcp

Documentation

Index

• type BQ
  • func (d *BQ) Cleanup() error
  • func (d *BQ) Init() error
  • func (d *BQ) LoadEnv(prefix string) error
  • func (d *BQ) LoadFlags() error
  • func (d *BQ) Push(r io.Reader) error
• type GCPFirestore
  • func (d *GCPFirestore) Cleanup() error
  • func (d *GCPFirestore) Init() error
  • func (d *GCPFirestore) LoadEnv(prefix string) error
  • func (d *GCPFirestore) LoadFlags() error
  • func (d *GCPFirestore) Push(r io.Reader) error
• type GCPPubSub
  • func (d *GCPPubSub) Cleanup() error
  • func (d *GCPPubSub) Init() error
  • func (d *GCPPubSub) LoadEnv(prefix string) error
  • func (d *GCPPubSub) LoadFlags() error
  • func (d *GCPPubSub) Push(r io.Reader) error
• type GCS
  • func (d *GCS) Cleanup() error
  • func (d *GCS) Init() error
  • func (d *GCS) LoadEnv(prefix string) error
  • func (d *GCS) LoadFlags() error
  • func (d *GCS) Push(r io.Reader) error

Types

type BQ

type BQ struct {
	Client    *bigquery.Client
	ProjectID string
	Query     *string
}

func (*BQ) Cleanup

func (d *BQ) Cleanup() error

func (*BQ) Init

func (d *BQ) Init() error

func (*BQ) LoadEnv

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

func (*BQ) LoadFlags

func (d *BQ) LoadFlags() error

func (*BQ) Push

func (d *BQ) Push(r io.Reader) error

type GCPFirestore

type GCPFirestore struct {
	Client         *firestore.Client
	Collection     *string
	ID             *string
	FailCollection *string
	ProjectID      string
}

func (*GCPFirestore) Cleanup

func (d *GCPFirestore) Cleanup() error

func (*GCPFirestore) Init

func (d *GCPFirestore) Init() error

func (*GCPFirestore) LoadEnv

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

func (*GCPFirestore) LoadFlags

func (d *GCPFirestore) LoadFlags() error

func (*GCPFirestore) Push

func (d *GCPFirestore) Push(r io.Reader) error

type GCPPubSub

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

func (*GCPPubSub) Cleanup

func (d *GCPPubSub) Cleanup() 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

func (*GCPPubSub) Push

func (d *GCPPubSub) Push(r io.Reader) error

type GCS

type GCS struct {
	Client *storage.Client
	Bucket string
	Key    string
}

func (*GCS) Cleanup

func (d *GCS) Cleanup() 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

func (*GCS) Push

func (d *GCS) Push(r io.Reader) error