Documentation ¶
Index ¶
- func AwsAccessRoleSpec_FromProto(mapCtx *direct.MapContext, in *pb.AwsAccessRole) *krm.AwsAccessRoleSpec
- func AwsAccessRoleSpec_ToProto(mapCtx *direct.MapContext, in *krm.AwsAccessRoleSpec) *pb.AwsAccessRole
- func AwsAccessRoleStatus_FromProto(mapCtx *direct.MapContext, in *pb.AwsAccessRole) *krm.AwsAccessRoleStatus
- func AwsAccessRoleStatus_ToProto(mapCtx *direct.MapContext, in *krm.AwsAccessRoleStatus) *pb.AwsAccessRole
- func AwsAccessRole_FromProto(mapCtx *direct.MapContext, in *pb.AwsAccessRole) *krm.AwsAccessRole
- func AwsAccessRole_ToProto(mapCtx *direct.MapContext, in *krm.AwsAccessRole) *pb.AwsAccessRole
- func AwsCrossAccountRole_FromProto(mapCtx *direct.MapContext, in *pb.AwsCrossAccountRole) *krm.AwsCrossAccountRole
- func AwsCrossAccountRole_ToProto(mapCtx *direct.MapContext, in *krm.AwsCrossAccountRole) *pb.AwsCrossAccountRole
- func AwsPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.AwsProperties) *krm.AwsPropertiesSpec
- func AwsPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.AwsPropertiesSpec) *pb.AwsProperties
- func AwsPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.AwsProperties) *krm.AwsPropertiesStatus
- func AwsPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.AwsPropertiesStatus) *pb.AwsProperties
- func AwsProperties_FromProto(mapCtx *direct.MapContext, in *pb.AwsProperties) *krm.AwsProperties
- func AwsProperties_ToProto(mapCtx *direct.MapContext, in *krm.AwsProperties) *pb.AwsProperties
- func AzurePropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.AzureProperties) *krm.AzurePropertiesSpec
- func AzurePropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.AzurePropertiesSpec) *pb.AzureProperties
- func AzurePropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.AzureProperties) *krm.AzurePropertiesStatus
- func AzurePropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.AzurePropertiesStatus) *pb.AzureProperties
- func AzureProperties_FromProto(mapCtx *direct.MapContext, in *pb.AzureProperties) *krm.AzureProperties
- func AzureProperties_ToProto(mapCtx *direct.MapContext, in *krm.AzureProperties) *pb.AzureProperties
- func BigQueryConnectionConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionObservedState
- func BigQueryConnectionConnectionObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConnectionConnectionObservedState) *pb.Connection
- func BigQueryConnectionConnectionSpec_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionSpec
- func BigQueryConnectionConnectionSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConnectionConnectionSpec) *pb.Connection
- func BigQueryConnectionConnectionStatusObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionObservedState
- func CloudResourcePropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudResourceProperties) *krm.CloudResourcePropertiesSpec
- func CloudResourcePropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudResourcePropertiesSpec) *pb.CloudResourceProperties
- func CloudResourcePropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.CloudResourceProperties) *krm.CloudResourcePropertiesStatus
- func CloudResourcePropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.CloudResourcePropertiesStatus) *pb.CloudResourceProperties
- func CloudResourceProperties_FromProto(mapCtx *direct.MapContext, in *pb.CloudResourceProperties) *krm.CloudResourceProperties
- func CloudResourceProperties_ToProto(mapCtx *direct.MapContext, in *krm.CloudResourceProperties) *pb.CloudResourceProperties
- func CloudSpannerPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudSpannerProperties) *krm.CloudSpannerPropertiesSpec
- func CloudSpannerPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudSpannerPropertiesSpec) *pb.CloudSpannerProperties
- func CloudSpannerProperties_FromProto(mapCtx *direct.MapContext, in *pb.CloudSpannerProperties) *krm.CloudSpannerProperties
- func CloudSpannerProperties_ToProto(mapCtx *direct.MapContext, in *krm.CloudSpannerProperties) *pb.CloudSpannerProperties
- func CloudSqlCredential_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlCredential) *krm.CloudSqlCredential
- func CloudSqlCredential_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlCredential) *pb.CloudSqlCredential
- func CloudSqlPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlProperties) *krm.CloudSqlPropertiesSpec
- func CloudSqlPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlPropertiesSpec) *pb.CloudSqlProperties
- func CloudSqlPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlProperties) *krm.CloudSqlPropertiesStatus
- func CloudSqlPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlPropertiesStatus) *pb.CloudSqlProperties
- func CloudSqlProperties_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlProperties) *krm.CloudSqlProperties
- func CloudSqlProperties_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlProperties) *pb.CloudSqlProperties
- func Connection_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.Connection
- func Connection_ToProto(mapCtx *direct.MapContext, in *krm.Connection) *pb.Connection
- func MetastoreServiceConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.MetastoreServiceConfig) *krm.MetastoreServiceConfigSpec
- func MetastoreServiceConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreServiceConfigSpec) *pb.MetastoreServiceConfig
- func MetastoreServiceConfig_FromProto(mapCtx *direct.MapContext, in *pb.MetastoreServiceConfig) *krm.MetastoreServiceConfig
- func MetastoreServiceConfig_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreServiceConfig) *pb.MetastoreServiceConfig
- func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
- func SalesforceDataCloudProperties_FromProto(mapCtx *direct.MapContext, in *pb.SalesforceDataCloudProperties) *krm.SalesforceDataCloudProperties
- func SalesforceDataCloudProperties_ToProto(mapCtx *direct.MapContext, in *krm.SalesforceDataCloudProperties) *pb.SalesforceDataCloudProperties
- func SparkHistoryServerConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.SparkHistoryServerConfig) *krm.SparkHistoryServerConfigSpec
- func SparkHistoryServerConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.SparkHistoryServerConfigSpec) *pb.SparkHistoryServerConfig
- func SparkHistoryServerConfig_FromProto(mapCtx *direct.MapContext, in *pb.SparkHistoryServerConfig) *krm.SparkHistoryServerConfig
- func SparkHistoryServerConfig_ToProto(mapCtx *direct.MapContext, in *krm.SparkHistoryServerConfig) *pb.SparkHistoryServerConfig
- func SparkPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.SparkProperties) *krm.SparkPropertiesSpec
- func SparkPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.SparkPropertiesSpec) *pb.SparkProperties
- func SparkPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.SparkProperties) *krm.SparkPropertiesStatus
- func SparkPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.SparkPropertiesStatus) *pb.SparkProperties
- func SparkProperties_FromProto(mapCtx *direct.MapContext, in *pb.SparkProperties) *krm.SparkProperties
- func SparkProperties_ToProto(mapCtx *direct.MapContext, in *krm.SparkProperties) *pb.SparkProperties
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AwsAccessRoleSpec_FromProto ¶ added in v1.124.0
func AwsAccessRoleSpec_FromProto(mapCtx *direct.MapContext, in *pb.AwsAccessRole) *krm.AwsAccessRoleSpec
func AwsAccessRoleSpec_ToProto ¶ added in v1.124.0
func AwsAccessRoleSpec_ToProto(mapCtx *direct.MapContext, in *krm.AwsAccessRoleSpec) *pb.AwsAccessRole
func AwsAccessRoleStatus_FromProto ¶ added in v1.124.0
func AwsAccessRoleStatus_FromProto(mapCtx *direct.MapContext, in *pb.AwsAccessRole) *krm.AwsAccessRoleStatus
func AwsAccessRoleStatus_ToProto ¶ added in v1.124.0
func AwsAccessRoleStatus_ToProto(mapCtx *direct.MapContext, in *krm.AwsAccessRoleStatus) *pb.AwsAccessRole
func AwsAccessRole_FromProto ¶
func AwsAccessRole_FromProto(mapCtx *direct.MapContext, in *pb.AwsAccessRole) *krm.AwsAccessRole
func AwsAccessRole_ToProto ¶
func AwsAccessRole_ToProto(mapCtx *direct.MapContext, in *krm.AwsAccessRole) *pb.AwsAccessRole
func AwsCrossAccountRole_FromProto ¶
func AwsCrossAccountRole_FromProto(mapCtx *direct.MapContext, in *pb.AwsCrossAccountRole) *krm.AwsCrossAccountRole
func AwsCrossAccountRole_ToProto ¶
func AwsCrossAccountRole_ToProto(mapCtx *direct.MapContext, in *krm.AwsCrossAccountRole) *pb.AwsCrossAccountRole
func AwsPropertiesSpec_FromProto ¶ added in v1.124.0
func AwsPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.AwsProperties) *krm.AwsPropertiesSpec
func AwsPropertiesSpec_ToProto ¶ added in v1.124.0
func AwsPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.AwsPropertiesSpec) *pb.AwsProperties
func AwsPropertiesStatus_FromProto ¶ added in v1.124.0
func AwsPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.AwsProperties) *krm.AwsPropertiesStatus
func AwsPropertiesStatus_ToProto ¶ added in v1.124.0
func AwsPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.AwsPropertiesStatus) *pb.AwsProperties
func AwsProperties_FromProto ¶
func AwsProperties_FromProto(mapCtx *direct.MapContext, in *pb.AwsProperties) *krm.AwsProperties
func AwsProperties_ToProto ¶
func AwsProperties_ToProto(mapCtx *direct.MapContext, in *krm.AwsProperties) *pb.AwsProperties
func AzurePropertiesSpec_FromProto ¶ added in v1.124.0
func AzurePropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.AzureProperties) *krm.AzurePropertiesSpec
func AzurePropertiesSpec_ToProto ¶ added in v1.124.0
func AzurePropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.AzurePropertiesSpec) *pb.AzureProperties
func AzurePropertiesStatus_FromProto ¶ added in v1.124.0
func AzurePropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.AzureProperties) *krm.AzurePropertiesStatus
func AzurePropertiesStatus_ToProto ¶ added in v1.124.0
func AzurePropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.AzurePropertiesStatus) *pb.AzureProperties
func AzureProperties_FromProto ¶
func AzureProperties_FromProto(mapCtx *direct.MapContext, in *pb.AzureProperties) *krm.AzureProperties
func AzureProperties_ToProto ¶
func AzureProperties_ToProto(mapCtx *direct.MapContext, in *krm.AzureProperties) *pb.AzureProperties
func BigQueryConnectionConnectionObservedState_FromProto ¶
func BigQueryConnectionConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionObservedState
func BigQueryConnectionConnectionObservedState_ToProto ¶
func BigQueryConnectionConnectionObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConnectionConnectionObservedState) *pb.Connection
func BigQueryConnectionConnectionSpec_FromProto ¶
func BigQueryConnectionConnectionSpec_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionSpec
func BigQueryConnectionConnectionSpec_ToProto ¶
func BigQueryConnectionConnectionSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConnectionConnectionSpec) *pb.Connection
func BigQueryConnectionConnectionStatusObservedState_FromProto ¶
func BigQueryConnectionConnectionStatusObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionObservedState
func CloudResourcePropertiesSpec_FromProto ¶
func CloudResourcePropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudResourceProperties) *krm.CloudResourcePropertiesSpec
func CloudResourcePropertiesSpec_ToProto ¶
func CloudResourcePropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudResourcePropertiesSpec) *pb.CloudResourceProperties
func CloudResourcePropertiesStatus_FromProto ¶
func CloudResourcePropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.CloudResourceProperties) *krm.CloudResourcePropertiesStatus
func CloudResourcePropertiesStatus_ToProto ¶
func CloudResourcePropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.CloudResourcePropertiesStatus) *pb.CloudResourceProperties
func CloudResourceProperties_FromProto ¶
func CloudResourceProperties_FromProto(mapCtx *direct.MapContext, in *pb.CloudResourceProperties) *krm.CloudResourceProperties
func CloudResourceProperties_ToProto ¶
func CloudResourceProperties_ToProto(mapCtx *direct.MapContext, in *krm.CloudResourceProperties) *pb.CloudResourceProperties
func CloudSpannerPropertiesSpec_FromProto ¶ added in v1.124.0
func CloudSpannerPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudSpannerProperties) *krm.CloudSpannerPropertiesSpec
func CloudSpannerPropertiesSpec_ToProto ¶ added in v1.124.0
func CloudSpannerPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudSpannerPropertiesSpec) *pb.CloudSpannerProperties
func CloudSpannerProperties_FromProto ¶
func CloudSpannerProperties_FromProto(mapCtx *direct.MapContext, in *pb.CloudSpannerProperties) *krm.CloudSpannerProperties
func CloudSpannerProperties_ToProto ¶
func CloudSpannerProperties_ToProto(mapCtx *direct.MapContext, in *krm.CloudSpannerProperties) *pb.CloudSpannerProperties
func CloudSqlCredential_FromProto ¶
func CloudSqlCredential_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlCredential) *krm.CloudSqlCredential
func CloudSqlCredential_ToProto ¶
func CloudSqlCredential_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlCredential) *pb.CloudSqlCredential
func CloudSqlPropertiesSpec_FromProto ¶ added in v1.124.0
func CloudSqlPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlProperties) *krm.CloudSqlPropertiesSpec
func CloudSqlPropertiesSpec_ToProto ¶ added in v1.124.0
func CloudSqlPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlPropertiesSpec) *pb.CloudSqlProperties
func CloudSqlPropertiesStatus_FromProto ¶ added in v1.124.0
func CloudSqlPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlProperties) *krm.CloudSqlPropertiesStatus
func CloudSqlPropertiesStatus_ToProto ¶ added in v1.124.0
func CloudSqlPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlPropertiesStatus) *pb.CloudSqlProperties
func CloudSqlProperties_FromProto ¶
func CloudSqlProperties_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlProperties) *krm.CloudSqlProperties
func CloudSqlProperties_ToProto ¶
func CloudSqlProperties_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlProperties) *pb.CloudSqlProperties
func Connection_FromProto ¶
func Connection_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.Connection
func Connection_ToProto ¶
func Connection_ToProto(mapCtx *direct.MapContext, in *krm.Connection) *pb.Connection
func MetastoreServiceConfigSpec_FromProto ¶ added in v1.124.0
func MetastoreServiceConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.MetastoreServiceConfig) *krm.MetastoreServiceConfigSpec
func MetastoreServiceConfigSpec_ToProto ¶ added in v1.124.0
func MetastoreServiceConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreServiceConfigSpec) *pb.MetastoreServiceConfig
func MetastoreServiceConfig_FromProto ¶
func MetastoreServiceConfig_FromProto(mapCtx *direct.MapContext, in *pb.MetastoreServiceConfig) *krm.MetastoreServiceConfig
func MetastoreServiceConfig_ToProto ¶
func MetastoreServiceConfig_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreServiceConfig) *pb.MetastoreServiceConfig
func NewModel ¶
func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
func SalesforceDataCloudProperties_FromProto ¶
func SalesforceDataCloudProperties_FromProto(mapCtx *direct.MapContext, in *pb.SalesforceDataCloudProperties) *krm.SalesforceDataCloudProperties
func SalesforceDataCloudProperties_ToProto ¶
func SalesforceDataCloudProperties_ToProto(mapCtx *direct.MapContext, in *krm.SalesforceDataCloudProperties) *pb.SalesforceDataCloudProperties
func SparkHistoryServerConfigSpec_FromProto ¶ added in v1.124.0
func SparkHistoryServerConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.SparkHistoryServerConfig) *krm.SparkHistoryServerConfigSpec
func SparkHistoryServerConfigSpec_ToProto ¶ added in v1.124.0
func SparkHistoryServerConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.SparkHistoryServerConfigSpec) *pb.SparkHistoryServerConfig
func SparkHistoryServerConfig_FromProto ¶
func SparkHistoryServerConfig_FromProto(mapCtx *direct.MapContext, in *pb.SparkHistoryServerConfig) *krm.SparkHistoryServerConfig
func SparkHistoryServerConfig_ToProto ¶
func SparkHistoryServerConfig_ToProto(mapCtx *direct.MapContext, in *krm.SparkHistoryServerConfig) *pb.SparkHistoryServerConfig
func SparkPropertiesSpec_FromProto ¶ added in v1.124.0
func SparkPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.SparkProperties) *krm.SparkPropertiesSpec
func SparkPropertiesSpec_ToProto ¶ added in v1.124.0
func SparkPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.SparkPropertiesSpec) *pb.SparkProperties
func SparkPropertiesStatus_FromProto ¶ added in v1.124.0
func SparkPropertiesStatus_FromProto(mapCtx *direct.MapContext, in *pb.SparkProperties) *krm.SparkPropertiesStatus
func SparkPropertiesStatus_ToProto ¶ added in v1.124.0
func SparkPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.SparkPropertiesStatus) *pb.SparkProperties
func SparkProperties_FromProto ¶
func SparkProperties_FromProto(mapCtx *direct.MapContext, in *pb.SparkProperties) *krm.SparkProperties
func SparkProperties_ToProto ¶
func SparkProperties_ToProto(mapCtx *direct.MapContext, in *krm.SparkProperties) *pb.SparkProperties
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
Click to show internal directories.
Click to hide internal directories.