gcp

Documentation

Index

• Variables
• type BQ
  • func (d *BQ) Cleanup() error
  • func (d *BQ) ClearWork() error
  • func (d *BQ) GetWork() (io.Reader, error)
  • func (d *BQ) HandleFailure() error
  • func (d *BQ) Init() error
  • func (d *BQ) LoadEnv(prefix string) error
  • func (d *BQ) LoadFlags() error
• type FirestoreOp
• type GCPFirestore
  • func (d *GCPFirestore) Cleanup() error
  • func (d *GCPFirestore) ClearWork() error
  • func (d *GCPFirestore) Data(obj []map[string]interface{}) (io.Reader, error)
  • func (d *GCPFirestore) GetWork() (io.Reader, error)
  • func (d *GCPFirestore) HandleFailure() error
  • func (d *GCPFirestore) Init() error
  • func (d *GCPFirestore) LoadEnv(prefix string) error
  • func (d *GCPFirestore) LoadFlags() error
• type GCPFirestoreQuery
• 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 (
	FirestoreRMOp     = FirestoreOp("rm")
	FirestoreMVOp     = FirestoreOp("mv")
	FirestoreUpdateOp = FirestoreOp("update")
)

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

Types

type BQ

type BQ struct {
	Client        *bigquery.Client
	ProjectID     string
	Key           *string
	RetrieveField *string
	RetrieveQuery *string
	ClearQuery    *string
	FailQuery     *string
	// contains filtered or unexported fields
}

func (*BQ) Cleanup

func (d *BQ) Cleanup() error

func (*BQ) ClearWork

func (d *BQ) ClearWork() error

func (*BQ) GetWork

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

func (*BQ) HandleFailure

func (d *BQ) HandleFailure() 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

type FirestoreOp

type FirestoreOp string

type GCPFirestore

type GCPFirestore struct {
	Client                  *firestore.Client
	RetrieveCollection      *string
	RetrieveDocument        *string
	RetrieveQuery           *GCPFirestoreQuery
	RetrieveDocumentJSONKey *string
	Limit                   *int
	ClearOp                 *FirestoreOp
	ClearUpdate             *map[string]any
	ClearCollection         *string
	FailOp                  *FirestoreOp
	FailUpdate              *map[string]any
	FailCollection          *string
	ProjectID               string
	// contains filtered or unexported fields
}

func (*GCPFirestore) Cleanup

func (d *GCPFirestore) Cleanup() error

func (*GCPFirestore) ClearWork

func (d *GCPFirestore) ClearWork() error

func (*GCPFirestore) Data

func (d *GCPFirestore) Data(obj []map[string]interface{}) (io.Reader, error)

func (*GCPFirestore) GetWork

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

func (*GCPFirestore) HandleFailure

func (d *GCPFirestore) HandleFailure() 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

type GCPFirestoreQuery

type GCPFirestoreQuery struct {
	Path    *string
	Op      *string
	Value   any
	OrderBy *string
	Order   *firestore.Direction
}

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