Documentation ¶
Index ¶
- func BigQueryAnalyticsHubDataExchangeObservedState_FromProto(mapCtx *direct.MapContext, in *pb.DataExchange) *krmv1beta1.BigQueryAnalyticsHubDataExchangeObservedState
- func BigQueryAnalyticsHubDataExchangeSpec_FromProto(mapCtx *direct.MapContext, in *pb.DataExchange) *krmv1beta1.BigQueryAnalyticsHubDataExchangeSpec
- func BigQueryAnalyticsHubDataExchangeSpec_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.BigQueryAnalyticsHubDataExchangeSpec) *pb.DataExchange
- func BigQueryAnalyticsHubListingObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Listing) *krmv1alpha1.BigQueryAnalyticsHubListingObservedState
- func BigQueryAnalyticsHubListingObservedState_ToProto(mapCtx *direct.MapContext, ...) *pb.Listing
- func BigQueryAnalyticsHubListingSpec_FromProto(mapCtx *direct.MapContext, in *pb.Listing) *krmv1alpha1.BigQueryAnalyticsHubListingSpec
- func BigQueryAnalyticsHubListingSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.BigQueryAnalyticsHubListingSpec) *pb.Listing
- func Categories_FromProto(mapCtx *direct.MapContext, in []pb.Listing_Category) []string
- func Categories_ToProto(mapCtx *direct.MapContext, in []string) []pb.Listing_Category
- func DataProvider_FromProto(mapCtx *direct.MapContext, in *pb.DataProvider) *krmv1alpha1.DataProvider
- func DataProvider_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataProvider) *pb.DataProvider
- func Listing_BigQueryDatasetSource_FromProto(mapCtx *direct.MapContext, in *pb.Listing_BigQueryDatasetSource) *krmv1alpha1.BigQueryDatasetSource
- func Listing_BigQueryDatasetSource_RestrictedExportPolicy_FromProto(mapCtx *direct.MapContext, ...) *krmv1alpha1.RestrictedExportPolicy
- func Listing_BigQueryDatasetSource_RestrictedExportPolicy_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.RestrictedExportPolicy) *pb.Listing_BigQueryDatasetSource_RestrictedExportPolicy
- func Listing_BigQueryDatasetSource_SelectedResource_FromProto(mapCtx *direct.MapContext, ...) *krmv1alpha1.SelectedResource
- func Listing_BigQueryDatasetSource_SelectedResource_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.SelectedResource) *pb.Listing_BigQueryDatasetSource_SelectedResource
- func Listing_BigQueryDatasetSource_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.BigQueryDatasetSource) *pb.Listing_BigqueryDataset
- func NewListingModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
- func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
- func Publisher_FromProto(mapCtx *direct.MapContext, in *pb.Publisher) *krmv1alpha1.Publisher
- func Publisher_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Publisher) *pb.Publisher
- 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
- type ListingAdapter
- func (a *ListingAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error
- func (a *ListingAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)
- func (a *ListingAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
- func (a *ListingAdapter) Find(ctx context.Context) (bool, error)
- func (a *ListingAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BigQueryAnalyticsHubDataExchangeObservedState_FromProto ¶
func BigQueryAnalyticsHubDataExchangeObservedState_FromProto(mapCtx *direct.MapContext, in *pb.DataExchange) *krmv1beta1.BigQueryAnalyticsHubDataExchangeObservedState
func BigQueryAnalyticsHubDataExchangeSpec_FromProto ¶
func BigQueryAnalyticsHubDataExchangeSpec_FromProto(mapCtx *direct.MapContext, in *pb.DataExchange) *krmv1beta1.BigQueryAnalyticsHubDataExchangeSpec
func BigQueryAnalyticsHubDataExchangeSpec_ToProto ¶
func BigQueryAnalyticsHubDataExchangeSpec_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.BigQueryAnalyticsHubDataExchangeSpec) *pb.DataExchange
func BigQueryAnalyticsHubListingObservedState_FromProto ¶ added in v1.126.0
func BigQueryAnalyticsHubListingObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Listing) *krmv1alpha1.BigQueryAnalyticsHubListingObservedState
func BigQueryAnalyticsHubListingObservedState_ToProto ¶ added in v1.126.0
func BigQueryAnalyticsHubListingObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.BigQueryAnalyticsHubListingObservedState) *pb.Listing
func BigQueryAnalyticsHubListingSpec_FromProto ¶ added in v1.126.0
func BigQueryAnalyticsHubListingSpec_FromProto(mapCtx *direct.MapContext, in *pb.Listing) *krmv1alpha1.BigQueryAnalyticsHubListingSpec
func BigQueryAnalyticsHubListingSpec_ToProto ¶ added in v1.126.0
func BigQueryAnalyticsHubListingSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.BigQueryAnalyticsHubListingSpec) *pb.Listing
func Categories_FromProto ¶ added in v1.126.0
func Categories_FromProto(mapCtx *direct.MapContext, in []pb.Listing_Category) []string
func Categories_ToProto ¶ added in v1.126.0
func Categories_ToProto(mapCtx *direct.MapContext, in []string) []pb.Listing_Category
func DataProvider_FromProto ¶ added in v1.126.0
func DataProvider_FromProto(mapCtx *direct.MapContext, in *pb.DataProvider) *krmv1alpha1.DataProvider
func DataProvider_ToProto ¶ added in v1.126.0
func DataProvider_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataProvider) *pb.DataProvider
func Listing_BigQueryDatasetSource_FromProto ¶ added in v1.126.0
func Listing_BigQueryDatasetSource_FromProto(mapCtx *direct.MapContext, in *pb.Listing_BigQueryDatasetSource) *krmv1alpha1.BigQueryDatasetSource
func Listing_BigQueryDatasetSource_RestrictedExportPolicy_FromProto ¶ added in v1.126.0
func Listing_BigQueryDatasetSource_RestrictedExportPolicy_FromProto(mapCtx *direct.MapContext, in *pb.Listing_BigQueryDatasetSource_RestrictedExportPolicy) *krmv1alpha1.RestrictedExportPolicy
func Listing_BigQueryDatasetSource_RestrictedExportPolicy_ToProto ¶ added in v1.126.0
func Listing_BigQueryDatasetSource_RestrictedExportPolicy_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.RestrictedExportPolicy) *pb.Listing_BigQueryDatasetSource_RestrictedExportPolicy
func Listing_BigQueryDatasetSource_SelectedResource_FromProto ¶ added in v1.126.0
func Listing_BigQueryDatasetSource_SelectedResource_FromProto(mapCtx *direct.MapContext, in *pb.Listing_BigQueryDatasetSource_SelectedResource) *krmv1alpha1.SelectedResource
func Listing_BigQueryDatasetSource_SelectedResource_ToProto ¶ added in v1.126.0
func Listing_BigQueryDatasetSource_SelectedResource_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.SelectedResource) *pb.Listing_BigQueryDatasetSource_SelectedResource
func Listing_BigQueryDatasetSource_ToProto ¶ added in v1.126.0
func Listing_BigQueryDatasetSource_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.BigQueryDatasetSource) *pb.Listing_BigqueryDataset
func NewListingModel ¶ added in v1.126.0
func NewListingModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
func NewModel ¶
func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
func Publisher_FromProto ¶ added in v1.126.0
func Publisher_FromProto(mapCtx *direct.MapContext, in *pb.Publisher) *krmv1alpha1.Publisher
func Publisher_ToProto ¶ added in v1.126.0
func Publisher_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Publisher) *pb.Publisher
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) 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.
type ListingAdapter ¶ added in v1.126.0
type ListingAdapter struct {
// contains filtered or unexported fields
}
func (*ListingAdapter) Create ¶ added in v1.126.0
func (a *ListingAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error
func (*ListingAdapter) Delete ¶ added in v1.126.0
func (a *ListingAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)
Delete implements the Adapter interface.
func (*ListingAdapter) Export ¶ added in v1.126.0
func (a *ListingAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
func (*ListingAdapter) Find ¶ added in v1.126.0
func (a *ListingAdapter) Find(ctx context.Context) (bool, error)
func (*ListingAdapter) Update ¶ added in v1.126.0
func (a *ListingAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error
Click to show internal directories.
Click to hide internal directories.