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 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 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 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 CloudSpannerPropertiesSpec_FromProto(mapCtx *direct.MapContext, in *pb.CloudSpannerProperties) *krm.CloudSpannerPropertiesSpec
- func CloudSpannerPropertiesSpec_ToProto(mapCtx *direct.MapContext, in *krm.CloudSpannerPropertiesSpec) *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 MetastoreServiceConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.MetastoreServiceConfig) *krm.MetastoreServiceConfigSpec
- func MetastoreServiceConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.MetastoreServiceConfigSpec) *pb.MetastoreServiceConfig
- func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
- func SparkHistoryServerConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.SparkHistoryServerConfig) *krm.SparkHistoryServerConfigSpec
- func SparkHistoryServerConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.SparkHistoryServerConfigSpec) *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
- 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 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 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 BigQueryConnectionConnectionObservedState_FromProto ¶
func BigQueryConnectionConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Connection) *krm.BigQueryConnectionConnectionObservedState
found existing non-generated mapping function "AzurePropertiesStatus_ToProto", skipping
func AzurePropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.AzurePropertiesStatus) *pb.AzureProperties {
if in == nil {
return nil
}
out := &pb.AzureProperties{}
out.Application = direct.ValueOf(in.Application)
out.ClientId = direct.ValueOf(in.ClientID)
out.ObjectId = direct.ValueOf(in.ObjectID)
// MISSING: CustomerTenantID
// MISSING: RedirectURI
// (near miss): "RedirectURI" vs "RedirectUri"
// MISSING: FederatedApplicationClientID
out.Identity = direct.ValueOf(in.Identity)
return out
}
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
found existing non-generated mapping function "BigQueryConnectionConnectionSpec_ToProto", skipping
func BigQueryConnectionConnectionSpec_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConnectionConnectionSpec) *pb.Connection {
if in == nil {
return nil
}
out := &pb.Connection{}
// MISSING: Name
out.FriendlyName = direct.ValueOf(in.FriendlyName)
out.Description = direct.ValueOf(in.Description)
// MISSING: CloudSpanner
// MISSING: SalesforceDataCloud
// MISSING: CreationTime
// MISSING: LastModifiedTime
return out
}
func CloudResourcePropertiesStatus_ToProto ¶
func CloudResourcePropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.CloudResourcePropertiesStatus) *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 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
found existing non-generated mapping function "CloudSqlCredential_ToProto", skipping
func CloudSqlCredential_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlCredential) *pb.CloudSqlCredential {
if in == nil {
return nil
}
out := &pb.CloudSqlCredential{}
// MISSING: Username
// MISSING: Password
return out
}
func CloudSqlPropertiesStatus_ToProto ¶ added in v1.124.0
func CloudSqlPropertiesStatus_ToProto(mapCtx *direct.MapContext, in *krm.CloudSqlPropertiesStatus) *pb.CloudSqlProperties
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 NewModel ¶
func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
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 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
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.