bigquerydataset

Documentation

Overview

This file only contains the mapper for BigQueryDataset Resource. The mapper is created based on cloud.google.com/go/bigquery library. The old library google.golang.org/api/bigquery/v2 is depreacted and the recommended cloud.google.com/go/bigquery library has a different schema. Since this is a beta resource, and we want to be backward compatible, we have manually added this custom mapper to accommodate the schema difference.

Index

• func Access_FromAPI(mapCtx *direct.MapContext, in *api.DatasetAccess) *krm.Access
• func Access_ToAPI(mapCtx *direct.MapContext, in *krm.Access) *api.DatasetAccess
• func AsExternalRef(datasetRef *krm.BigQueryDatasetRef) *string
• func BigQueryDatasetSpec_FromAPI(mapCtx *direct.MapContext, in *api.Dataset) *krm.BigQueryDatasetSpec
• func BigQueryDatasetSpec_ToAPI(mapCtx *direct.MapContext, in *krm.BigQueryDatasetSpec, name string) *api.Dataset
• func BigQueryDatasetStatus_FromAPI(mapCtx *direct.MapContext, in *api.Dataset) *krm.BigQueryDatasetStatus
• func BigQueryDatasetStatus_ToAPI(mapCtx *direct.MapContext, in *krm.BigQueryDatasetStatus) *api.Dataset
• func DatasetAccessEntry_FromAPI(mapCtx *direct.MapContext, in *api.DatasetAccessEntry) *krm.DatasetAccessEntry
• func DatasetAccessEntry_ToAPI(mapCtx *direct.MapContext, in *krm.DatasetAccessEntry) *api.DatasetAccessEntry
• func DatasetReference_ToAPI(mapCtx *direct.MapContext, in *krm.BigQueryDatasetSpec, name string) *api.DatasetReference
• func EncryptionConfiguration_FromAPI(mapCtx *direct.MapContext, in *api.EncryptionConfiguration) *krm.EncryptionConfiguration
• func EncryptionConfiguration_ToAPI(mapCtx *direct.MapContext, in *krm.EncryptionConfiguration) *api.EncryptionConfiguration
• func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
• func RoutineReference_FromAPI(mapCtx *direct.MapContext, in *api.RoutineReference) *krm.RoutineReference
• func RoutineReference_ToAPI(mapCtx *direct.MapContext, in *krm.RoutineReference) *api.RoutineReference
• func TableReference_FromAPI(mapCtx *direct.MapContext, in *api.TableReference) *krm.TableReference
• func TableReference_ToAPI(mapCtx *direct.MapContext, in *krm.TableReference) *api.TableReference
• type Adapter
  • func (a *Adapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error
  • func (a *Adapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)
  • func (a *Adapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
  • func (a *Adapter) Find(ctx context.Context) (bool, error)
  • func (a *Adapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Functions

func Access_FromAPI

func Access_FromAPI(mapCtx *direct.MapContext, in *api.DatasetAccess) *krm.Access

func Access_ToAPI

func Access_ToAPI(mapCtx *direct.MapContext, in *krm.Access) *api.DatasetAccess

func AsExternalRef

func AsExternalRef(datasetRef *krm.BigQueryDatasetRef) *string

AsExternalRef builds a externalRef from a BigQueryDataTransferConfig

func BigQueryDatasetSpec_FromAPI

func BigQueryDatasetSpec_FromAPI(mapCtx *direct.MapContext, in *api.Dataset) *krm.BigQueryDatasetSpec

func BigQueryDatasetSpec_ToAPI

func BigQueryDatasetSpec_ToAPI(mapCtx *direct.MapContext, in *krm.BigQueryDatasetSpec, name string) *api.Dataset

func BigQueryDatasetStatus_FromAPI

func BigQueryDatasetStatus_FromAPI(mapCtx *direct.MapContext, in *api.Dataset) *krm.BigQueryDatasetStatus

func BigQueryDatasetStatus_ToAPI

func BigQueryDatasetStatus_ToAPI(mapCtx *direct.MapContext, in *krm.BigQueryDatasetStatus) *api.Dataset

func DatasetAccessEntry_FromAPI

func DatasetAccessEntry_FromAPI(mapCtx *direct.MapContext, in *api.DatasetAccessEntry) *krm.DatasetAccessEntry

func DatasetAccessEntry_ToAPI

func DatasetAccessEntry_ToAPI(mapCtx *direct.MapContext, in *krm.DatasetAccessEntry) *api.DatasetAccessEntry

func DatasetReference_ToAPI

func DatasetReference_ToAPI(mapCtx *direct.MapContext, in *krm.BigQueryDatasetSpec, name string) *api.DatasetReference

func EncryptionConfiguration_FromAPI

func EncryptionConfiguration_FromAPI(mapCtx *direct.MapContext, in *api.EncryptionConfiguration) *krm.EncryptionConfiguration

func EncryptionConfiguration_ToAPI

func EncryptionConfiguration_ToAPI(mapCtx *direct.MapContext, in *krm.EncryptionConfiguration) *api.EncryptionConfiguration

func NewModel

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

func RoutineReference_FromAPI

func RoutineReference_FromAPI(mapCtx *direct.MapContext, in *api.RoutineReference) *krm.RoutineReference

func RoutineReference_ToAPI

func RoutineReference_ToAPI(mapCtx *direct.MapContext, in *krm.RoutineReference) *api.RoutineReference

func TableReference_FromAPI

func TableReference_FromAPI(mapCtx *direct.MapContext, in *api.TableReference) *krm.TableReference

func TableReference_ToAPI

func TableReference_ToAPI(mapCtx *direct.MapContext, in *krm.TableReference) *api.TableReference

Types

type Adapter

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

func (*Adapter) Create

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

func (*Adapter) Delete

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

Delete implements the Adapter interface.

func (*Adapter) Export

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

func (*Adapter) Find

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

func (*Adapter) Update

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