bigquery

package
v1.134.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 21, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AvroOptions_FromProto 

func AvroOptions_FromProto(mapCtx *direct.MapContext, in *pb.AvroOptions) *krmv1beta1.AvroOptions

func AvroOptions_ToProto 

func AvroOptions_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.AvroOptions) *pb.AvroOptions

func BigQueryTableObservedState_FromProto 

func BigQueryTableObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krmv1beta1.BigQueryTableObservedState

func BigQueryTableObservedState_ToProto 

func BigQueryTableObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.BigQueryTableObservedState) *pb.Table

func BigQueryTableSpec_FromProto 

func BigQueryTableSpec_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krmv1beta1.BigQueryTableSpec

func BigQueryTableSpec_ToProto 

func BigQueryTableSpec_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.BigQueryTableSpec) *pb.Table

func BigQueryTableStatus_FromProto 

func BigQueryTableStatus_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krmv1beta1.BigQueryTableStatus

func BigQueryTableStatus_ToProto 

func BigQueryTableStatus_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.BigQueryTableStatus) *pb.Table

func ColumnReference_FromProto 

func ColumnReference_FromProto(mapCtx *direct.MapContext, in *pb.TableConstraintsForeignKeysColumnReferences) krmv1beta1.ColumnReference

func ColumnReference_ToProto 

func ColumnReference_ToProto(mapCtx *direct.MapContext, in krmv1beta1.ColumnReference) *pb.TableConstraintsForeignKeysColumnReferences

func CsvOptions_FromProto 

func CsvOptions_FromProto(mapCtx *direct.MapContext, in *pb.CsvOptions) *krmv1beta1.CsvOptions

func CsvOptions_ToProto 

func CsvOptions_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.CsvOptions) *pb.CsvOptions

func EncryptionConfiguration_FromProto 

func EncryptionConfiguration_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionConfiguration) *krmv1beta1.TableEncryptionConfiguration

func EncryptionConfiguration_ToProto 

func EncryptionConfiguration_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.TableEncryptionConfiguration) *pb.EncryptionConfiguration

func ExternalDataConfiguration_FromProto 

func ExternalDataConfiguration_FromProto(mapCtx *direct.MapContext, in *pb.ExternalDataConfiguration) *krmv1beta1.ExternalDataConfiguration

func ExternalDataConfiguration_ToProto 

func ExternalDataConfiguration_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.ExternalDataConfiguration) *pb.ExternalDataConfiguration

func ForeignKey_FromProto 

func ForeignKey_FromProto(mapCtx *direct.MapContext, in *pb.TableConstraintsForeignKeys) *krmv1beta1.ForeignKey

func ForeignKey_ToProto 

func ForeignKey_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.ForeignKey) *pb.TableConstraintsForeignKeys

func GoogleSheetsOptions_FromProto 

func GoogleSheetsOptions_FromProto(mapCtx *direct.MapContext, in *pb.GoogleSheetsOptions) *krmv1beta1.GoogleSheetsOptions

func GoogleSheetsOptions_ToProto 

func GoogleSheetsOptions_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.GoogleSheetsOptions) *pb.GoogleSheetsOptions

func HivePartitioningOptions_FromProto 

func HivePartitioningOptions_FromProto(mapCtx *direct.MapContext, in *pb.HivePartitioningOptions) *krmv1beta1.HivePartitioningOptions

func HivePartitioningOptions_ToProto 

func HivePartitioningOptions_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.HivePartitioningOptions) *pb.HivePartitioningOptions

func JsonOptions_FromProto 

func JsonOptions_FromProto(mapCtx *direct.MapContext, in *pb.JsonOptions) *krmv1beta1.JsonOptions

func JsonOptions_ToProto 

func JsonOptions_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.JsonOptions) *pb.JsonOptions

func MaterializedViewDefinition_FromProto 

func MaterializedViewDefinition_FromProto(mapCtx *direct.MapContext, in *pb.MaterializedViewDefinition) *krmv1beta1.MaterializedViewDefinition

func MaterializedViewDefinition_ToProto 

func MaterializedViewDefinition_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.MaterializedViewDefinition) *pb.MaterializedViewDefinition

func NewModel added in v1.133.0 

func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func ParquetOptions_FromProto 

func ParquetOptions_FromProto(mapCtx *direct.MapContext, in *pb.ParquetOptions) *krmv1beta1.ParquetOptions

func ParquetOptions_ToProto 

func ParquetOptions_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.ParquetOptions) *pb.ParquetOptions

func PrimaryKey_FromProto 

func PrimaryKey_FromProto(mapCtx *direct.MapContext, in *pb.TableConstraintsPrimaryKey) *krmv1beta1.PrimaryKey

func PrimaryKey_ToProto 

func PrimaryKey_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PrimaryKey) *pb.TableConstraintsPrimaryKey

func RangePartitioning_FromProto 

func RangePartitioning_FromProto(mapCtx *direct.MapContext, in *pb.RangePartitioning) *krmv1beta1.RangePartitioning

func RangePartitioning_Range_FromProto 

func RangePartitioning_Range_FromProto(mapCtx *direct.MapContext, in *pb.RangePartitioningRange) krmv1beta1.RangePartitioning_Range

func RangePartitioning_Range_ToProto 

func RangePartitioning_Range_ToProto(mapCtx *direct.MapContext, in krmv1beta1.RangePartitioning_Range) *pb.RangePartitioningRange

func RangePartitioning_ToProto 

func RangePartitioning_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.RangePartitioning) *pb.RangePartitioning

func TableConstraints_FromProto 

func TableConstraints_FromProto(mapCtx *direct.MapContext, in *pb.TableConstraints) *krmv1beta1.TableConstraints

func TableConstraints_ToProto 

func TableConstraints_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.TableConstraints) *pb.TableConstraints

func TableEq added in v1.133.0 

func TableEq(a, b *bigquery.Table) (bool, error)

func TableReference_FromProto 

func TableReference_FromProto(mapCtx *direct.MapContext, in *pb.TableConstraintsForeignKeysReferencedTable) krmv1beta1.TableReference

func TableReference_ToProto 

func TableReference_ToProto(mapCtx *direct.MapContext, in krmv1beta1.TableReference) *pb.TableConstraintsForeignKeysReferencedTable

func Table_Schema_FromProto 

func Table_Schema_FromProto(mapCtx *direct.MapContext, in *pb.TableSchema) *string

func Table_Schema_ToProto 

func Table_Schema_ToProto(mapCtx *direct.MapContext, in *string, managePolicyTags bool) *pb.TableSchema

func TimePartitioning_FromProto 

func TimePartitioning_FromProto(mapCtx *direct.MapContext, in *pb.TimePartitioning) *krmv1beta1.TimePartitioning

func TimePartitioning_ToProto 

func TimePartitioning_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.TimePartitioning) *pb.TimePartitioning

func ViewDefinition_FromProto 

func ViewDefinition_FromProto(mapCtx *direct.MapContext, in *pb.ViewDefinition) *krmv1beta1.ViewDefinition

func ViewDefinition_ToProto 

func ViewDefinition_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.ViewDefinition) *pb.ViewDefinition

Types

type Adapter added in v1.133.0 

type Adapter struct {
	// contains filtered or unexported fields
}

func (*Adapter) Create added in v1.133.0 

func (a *Adapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

func (*Adapter) Delete added in v1.133.0 

func (a *Adapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete implements the Adapter interface.

func (*Adapter) Export added in v1.133.0 

func (a *Adapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

func (*Adapter) Find added in v1.133.0 

func (a *Adapter) Find(ctx context.Context) (bool, error)

func (*Adapter) Update added in v1.133.0 

func (a *Adapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

func (*Adapter) UpdateStatusForCreate added in v1.133.0 

func (a *Adapter) UpdateStatusForCreate(ctx context.Context, createOp *directbase.CreateOperation, created *bigquery.Table) error

func (*Adapter) UpdateStatusForUpdate added in v1.133.0 

func (a *Adapter) UpdateStatusForUpdate(ctx context.Context, updateOp *directbase.UpdateOperation, updated *bigquery.Table) error

type TableReconcileGate added in v1.133.0 

type TableReconcileGate struct {
	// contains filtered or unexported fields
}

func (*TableReconcileGate) ShouldReconcile added in v1.133.0 

func (r *TableReconcileGate) ShouldReconcile(o *unstructured.Unstructured) bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.