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 AccessEntry_FromProto(mapCtx *direct.MapContext, in *pb.AccessEntry) *krm.Access
• func AccessEntry_ToProto(mapCtx *direct.MapContext, in *krm.Access) *pb.AccessEntry
• func BigQueryDatasetSpec_FromProto(mapCtx *direct.MapContext, in *pb.DatasetMetadata) *krm.BigQueryDatasetSpec
• func BigQueryDatasetSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryDatasetSpec) *pb.DatasetMetadata
• func BigQueryDatasetStatus_FromProto(mapCtx *direct.MapContext, in *pb.DatasetMetadata) *krm.BigQueryDatasetStatus
• func BigQueryDatasetStatus_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryDatasetStatus) *pb.DatasetMetadata
• func BigQueryDataset_ToMetadataToUpdate(mapCtx *direct.MapContext, in *pb.DatasetMetadata, updatePaths []string) *pb.DatasetMetadataToUpdate
• func DatasetAccessEntry_FromProto(mapCtx *direct.MapContext, in *pb.DatasetAccessEntry) *krm.DatasetAccessEntry
• func DatasetAccessEntry_ToProto(mapCtx *direct.MapContext, in *krm.DatasetAccessEntry) *pb.DatasetAccessEntry
• func DatasetReference_FromProto(mapCtx *direct.MapContext, in *pb.Dataset) *krm.DatasetReference
• func DatasetReference_ToProto(mapCtx *direct.MapContext, in *krm.DatasetReference) *pb.Dataset
• func DatasetSpec_ToExternalDatasetReference(mapCtx *direct.MapContext, in *krm.BigQueryDatasetSpec) *pb.ExternalDatasetReference
• func EncryptionConfiguration_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionConfig) *krm.EncryptionConfiguration
• func EncryptionConfiguration_ToProto(mapCtx *direct.MapContext, in *krm.EncryptionConfiguration) *pb.EncryptionConfig
• func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
• func RoutineReference_FromProto(mapCtx *direct.MapContext, in *pb.Routine) *krm.RoutineReference
• func RoutineReference_ToProto(mapCtx *direct.MapContext, in *krm.RoutineReference) *pb.Routine
• func TableReference_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krm.TableReference
• func TableReference_ToProto(mapCtx *direct.MapContext, in *krm.TableReference) *pb.Table
• 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 AccessEntry_FromProto

func AccessEntry_FromProto(mapCtx *direct.MapContext, in *pb.AccessEntry) *krm.Access

func AccessEntry_ToProto

func AccessEntry_ToProto(mapCtx *direct.MapContext, in *krm.Access) *pb.AccessEntry

func BigQueryDatasetSpec_FromProto

func BigQueryDatasetSpec_FromProto(mapCtx *direct.MapContext, in *pb.DatasetMetadata) *krm.BigQueryDatasetSpec

func BigQueryDatasetSpec_ToProto

func BigQueryDatasetSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryDatasetSpec) *pb.DatasetMetadata

func BigQueryDatasetStatus_FromProto

func BigQueryDatasetStatus_FromProto(mapCtx *direct.MapContext, in *pb.DatasetMetadata) *krm.BigQueryDatasetStatus

func BigQueryDatasetStatus_ToProto

func BigQueryDatasetStatus_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryDatasetStatus) *pb.DatasetMetadata

func BigQueryDataset_ToMetadataToUpdate

func BigQueryDataset_ToMetadataToUpdate(mapCtx *direct.MapContext, in *pb.DatasetMetadata, updatePaths []string) *pb.DatasetMetadataToUpdate

func DatasetAccessEntry_FromProto

func DatasetAccessEntry_FromProto(mapCtx *direct.MapContext, in *pb.DatasetAccessEntry) *krm.DatasetAccessEntry

func DatasetAccessEntry_ToProto

func DatasetAccessEntry_ToProto(mapCtx *direct.MapContext, in *krm.DatasetAccessEntry) *pb.DatasetAccessEntry

func DatasetReference_FromProto

func DatasetReference_FromProto(mapCtx *direct.MapContext, in *pb.Dataset) *krm.DatasetReference

func DatasetReference_ToProto

func DatasetReference_ToProto(mapCtx *direct.MapContext, in *krm.DatasetReference) *pb.Dataset

func DatasetSpec_ToExternalDatasetReference

func DatasetSpec_ToExternalDatasetReference(mapCtx *direct.MapContext, in *krm.BigQueryDatasetSpec) *pb.ExternalDatasetReference

func EncryptionConfiguration_FromProto

func EncryptionConfiguration_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionConfig) *krm.EncryptionConfiguration

func EncryptionConfiguration_ToProto

func EncryptionConfiguration_ToProto(mapCtx *direct.MapContext, in *krm.EncryptionConfiguration) *pb.EncryptionConfig

func NewModel

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

func RoutineReference_FromProto

func RoutineReference_FromProto(mapCtx *direct.MapContext, in *pb.Routine) *krm.RoutineReference

func RoutineReference_ToProto

func RoutineReference_ToProto(mapCtx *direct.MapContext, in *krm.RoutineReference) *pb.Routine

func TableReference_FromProto

func TableReference_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krm.TableReference

func TableReference_ToProto

func TableReference_ToProto(mapCtx *direct.MapContext, in *krm.TableReference) *pb.Table

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