bigqueryanalyticshub

Documentation

Index

• func BigQueryAnalyticsHubDataExchangeObservedState_FromProto(mapCtx *direct.MapContext, in *pb.DataExchange) *krm.BigQueryAnalyticsHubDataExchangeObservedState
• func BigQueryAnalyticsHubDataExchangeSpec_FromProto(mapCtx *direct.MapContext, in *pb.DataExchange) *krm.BigQueryAnalyticsHubDataExchangeSpec
• func BigQueryAnalyticsHubDataExchangeSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryAnalyticsHubDataExchangeSpec) *pb.DataExchange
• func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
• 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
• type DataExchangeIdentity
  • func BuildID(project, location, resourceID string) *DataExchangeIdentity
  • func (c *DataExchangeIdentity) AsExternalRef() *string
  • func (c *DataExchangeIdentity) FullyQualifiedName() string

Functions

func BigQueryAnalyticsHubDataExchangeObservedState_FromProto

func BigQueryAnalyticsHubDataExchangeObservedState_FromProto(mapCtx *direct.MapContext, in *pb.DataExchange) *krm.BigQueryAnalyticsHubDataExchangeObservedState

func BigQueryAnalyticsHubDataExchangeSpec_FromProto

func BigQueryAnalyticsHubDataExchangeSpec_FromProto(mapCtx *direct.MapContext, in *pb.DataExchange) *krm.BigQueryAnalyticsHubDataExchangeSpec

func BigQueryAnalyticsHubDataExchangeSpec_ToProto

func BigQueryAnalyticsHubDataExchangeSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryAnalyticsHubDataExchangeSpec) *pb.DataExchange

func NewModel

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

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

type DataExchangeIdentity

type DataExchangeIdentity struct {
	Parent       parent
	DataExchange string
}

The Identifier for ConfigConnector to track the DataExchange resource from the GCP service.

func BuildID

func BuildID(project, location, resourceID string) *DataExchangeIdentity

BuildID builds the ID for ConfigConnector to track the DataExchange resource from the GCP service.

func (*DataExchangeIdentity) AsExternalRef

func (c *DataExchangeIdentity) AsExternalRef() *string

AsExternalRef builds a externalRef from a DataExchange

func (*DataExchangeIdentity) FullyQualifiedName

func (c *DataExchangeIdentity) FullyQualifiedName() string

FullyQualifiedName returns both parent and resource ID in the full url format.