ds2bq

Documentation

Index

• type Config
• type SchedulerJob
  • func ParseYaml(ctx context.Context, data []byte) ([]*SchedulerJob, error)
  • func (job *SchedulerJob) CreateUpsertJobRequest() (*scheduler.UpsertJobRequest, error)

Types

type Config

type Config struct {
	ProjectID         string   `json:"projectId" yaml:"projectId"`
	AllKinds          bool     `json:"allKinds" yaml:"allKinds"`
	Kinds             []string `json:"kinds"`
	NamespaceIDs      []string `json:"namespaceIds" yaml:"namespaceIds"`
	IgnoreKinds       []string `json:"ignoreKinds" yaml:"ignoreKinds"`
	IgnoreBQLoadKinds []string `json:"ignoreBQLoadKinds" yaml:"ignoreBQLoadKinds"`
	OutputGCSFilePath string   `json:"outputGCSFilePath" yaml:"outputGCSFilePath"`
	BQLoadProjectID   string   `json:"bqLoadProjectId" yaml:"bqLoadProjectId"`
	BQLoadDatasetID   string   `json:"bqLoadDatasetId" yaml:"bqLoadDatasetId"`
}

type SchedulerJob

type SchedulerJob struct {
	Name                    string  `json:"name"`
	ProjectID               string  `json:"projectId" yaml:"projectId"`
	Location                string  `json:"location"`
	Description             string  `json:"description"`
	URI                     string  `json:"uri"`
	Schedule                string  `json:"schedule"`
	Timezone                string  `json:"timezone"`
	Body                    *Config `json:"messageBody"`
	OIDCServiceAccountEmail string  `json:"oidcServiceAccountEmail" yaml:"oidcServiceAccountEmail"`
}

func ParseYaml

func ParseYaml(ctx context.Context, data []byte) ([]*SchedulerJob, error)

func (*SchedulerJob) CreateUpsertJobRequest

func (job *SchedulerJob) CreateUpsertJobRequest() (*scheduler.UpsertJobRequest, error)