bigquerybiglake

package
v1.131.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BigLakeCatalogObservedState_FromProto added in v1.131.0 

func BigLakeCatalogObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Catalog) *krm.BigLakeCatalogObservedState

func BigLakeCatalogObservedState_ToProto added in v1.131.0 

func BigLakeCatalogObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BigLakeCatalogObservedState) *pb.Catalog

func BigLakeCatalogSpec_FromProto added in v1.131.0 

func BigLakeCatalogSpec_FromProto(mapCtx *direct.MapContext, in *pb.Catalog) *krm.BigLakeCatalogSpec

func BigLakeCatalogSpec_ToProto added in v1.131.0 

func BigLakeCatalogSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigLakeCatalogSpec) *pb.Catalog

func BigLakeTableObservedState_FromProto 

func BigLakeTableObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krm.BigLakeTableObservedState

func BigLakeTableObservedState_ToProto 

func BigLakeTableObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BigLakeTableObservedState) *pb.Table

func BigLakeTableSpec_FromProto 

func BigLakeTableSpec_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krm.BigLakeTableSpec

func BigLakeTableSpec_ToProto 

func BigLakeTableSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigLakeTableSpec) *pb.Table

func CatalogObservedState_FromProto added in v1.131.0 

func CatalogObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Catalog) *krm.CatalogObservedState

func CatalogObservedState_ToProto added in v1.131.0 

func CatalogObservedState_ToProto(mapCtx *direct.MapContext, in *krm.CatalogObservedState) *pb.Catalog

func Catalog_FromProto added in v1.131.0 

func Catalog_FromProto(mapCtx *direct.MapContext, in *pb.Catalog) *krm.Catalog

func Catalog_ToProto added in v1.131.0 

func Catalog_ToProto(mapCtx *direct.MapContext, in *krm.Catalog) *pb.Catalog

func DatabaseObservedState_FromProto added in v1.131.0 

func DatabaseObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Database) *krm.BigLakeDatabaseObservedState

func DatabaseObservedState_ToProto added in v1.131.0 

func DatabaseObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BigLakeDatabaseObservedState) *pb.Database

func DatabaseSpec_FromProto added in v1.131.0 

func DatabaseSpec_FromProto(mapCtx *direct.MapContext, in *pb.Database) *krm.BigLakeDatabaseSpec

func DatabaseSpec_ToProto added in v1.131.0 

func DatabaseSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigLakeDatabaseSpec) *pb.Database

func HiveDatabaseOptions_FromProto added in v1.131.0 

func HiveDatabaseOptions_FromProto(mapCtx *direct.MapContext, in *pb.HiveDatabaseOptions) *krm.HiveDatabaseOptions

func HiveDatabaseOptions_ToProto added in v1.131.0 

func HiveDatabaseOptions_ToProto(mapCtx *direct.MapContext, in *krm.HiveDatabaseOptions) *pb.HiveDatabaseOptions

func HiveTableOptions_FromProto 

func HiveTableOptions_FromProto(mapCtx *direct.MapContext, in *pb.HiveTableOptions) *krm.HiveTableOptions

func HiveTableOptions_SerDeInfo_FromProto 

func HiveTableOptions_SerDeInfo_FromProto(mapCtx *direct.MapContext, in *pb.HiveTableOptions_SerDeInfo) *krm.HiveTableOptions_SerDeInfo

func HiveTableOptions_SerDeInfo_ToProto 

func HiveTableOptions_SerDeInfo_ToProto(mapCtx *direct.MapContext, in *krm.HiveTableOptions_SerDeInfo) *pb.HiveTableOptions_SerDeInfo

func HiveTableOptions_StorageDescriptor_FromProto 

func HiveTableOptions_StorageDescriptor_FromProto(mapCtx *direct.MapContext, in *pb.HiveTableOptions_StorageDescriptor) *krm.HiveTableOptions_StorageDescriptor

func HiveTableOptions_StorageDescriptor_ToProto 

func HiveTableOptions_StorageDescriptor_ToProto(mapCtx *direct.MapContext, in *krm.HiveTableOptions_StorageDescriptor) *pb.HiveTableOptions_StorageDescriptor

func HiveTableOptions_ToProto 

func HiveTableOptions_ToProto(mapCtx *direct.MapContext, in *krm.HiveTableOptions) *pb.HiveTableOptions

func NewTableModel 

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

Types

type TableAdapter 

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

func (*TableAdapter) Create 

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

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*TableAdapter) Delete 

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

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*TableAdapter) Export 

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

Export maps the GCP object to a Config Connector resource `spec`.

func (*TableAdapter) Find 

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

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*TableAdapter) Update 

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

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

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.
OSZAR »