Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + func SetConfig(cfg *Config) error + type Config struct + GoogleTokenSource google.TokenSourceFactoryConfig + ResourceConstraints core.ResourceConstraintsSpec + WebAPI webapi.PluginConfig + func GetConfig() *Config + func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet + type Plugin struct + func NewPlugin(cfg *Config, metricScope promutils.Scope) (*Plugin, error) + func (p Plugin) Create(ctx context.Context, taskCtx webapi.TaskExecutionContextReader) (webapi.ResourceMeta, webapi.Resource, error) + func (p Plugin) Delete(ctx context.Context, taskCtx webapi.DeleteContext) error + func (p Plugin) Get(ctx context.Context, taskCtx webapi.GetContext) (latest webapi.Resource, err error) + func (p Plugin) GetConfig() webapi.PluginConfig + func (p Plugin) ResourceRequirements(_ context.Context, _ webapi.TaskExecutionContextReader) (namespace core.ResourceNamespace, constraints core.ResourceConstraintsSpec, ...) + func (p Plugin) Status(ctx context.Context, tCtx webapi.StatusContext) (phase core.PhaseInfo, err error) + type QueryJobConfig struct + AllowLargeResults bool + Clustering *bigquery.Clustering + CreateDisposition string + DefaultDataset *bigquery.DatasetReference + DestinationEncryptionConfiguration *bigquery.EncryptionConfiguration + DestinationTable *bigquery.TableReference + FlattenResults *bool + Location string + MaximumBillingTier *int64 + MaximumBytesBilled int64 + Priority string + ProjectID string + Query string + SchemaUpdateOptions []string + TableDefinitions map[string]bigquery.ExternalDataConfiguration + TimePartitioning *bigquery.TimePartitioning + UseLegacySQL *bool + UseQueryCache *bool + UserDefinedFunctionResources []*bigquery.UserDefinedFunctionResource + WriteDisposition string + type ResourceMetaWrapper struct + JobReference bigquery.JobReference + K8sServiceAccount string + Namespace string + type ResourceWrapper struct + CreateError *googleapi.Error + OutputLocation string + Status *bigquery.JobStatus