dataplex

package
v1.133.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 22, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AssetStatus_FromProto 

func AssetStatus_FromProto(mapCtx *direct.MapContext, in *pb.AssetStatus) *krm.AssetStatus

func AssetStatus_ToProto 

func AssetStatus_ToProto(mapCtx *direct.MapContext, in *krm.AssetStatus) *pb.AssetStatus

func DataplexEntryGroupObservedState_FromProto added in v1.131.0 

func DataplexEntryGroupObservedState_FromProto(mapCtx *direct.MapContext, in *pb.EntryGroup) *krmv1alpha1.DataplexEntryGroupObservedState

func DataplexEntryGroupObservedState_ToProto added in v1.131.0 

func DataplexEntryGroupObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataplexEntryGroupObservedState) *pb.EntryGroup

func DataplexEntryGroupSpec_FromProto added in v1.131.0 

func DataplexEntryGroupSpec_FromProto(mapCtx *direct.MapContext, in *pb.EntryGroup) *krmv1alpha1.DataplexEntryGroupSpec

func DataplexEntryGroupSpec_ToProto added in v1.131.0 

func DataplexEntryGroupSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataplexEntryGroupSpec) *pb.EntryGroup

func DataplexEntryTypeObservedState_FromProto added in v1.131.0 

func DataplexEntryTypeObservedState_FromProto(mapCtx *direct.MapContext, in *pb.EntryType) *krmv1alpha1.DataplexEntryTypeObservedState

func DataplexEntryTypeObservedState_ToProto added in v1.131.0 

func DataplexEntryTypeObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataplexEntryTypeObservedState) *pb.EntryType

func DataplexEntryTypeSpec_FromProto added in v1.131.0 

func DataplexEntryTypeSpec_FromProto(mapCtx *direct.MapContext, in *pb.EntryType) *krmv1alpha1.DataplexEntryTypeSpec

func DataplexEntryTypeSpec_ToProto added in v1.131.0 

func DataplexEntryTypeSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataplexEntryTypeSpec) *pb.EntryType

func DataplexLakeObservedState_FromProto 

func DataplexLakeObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Lake) *krm.DataplexLakeObservedState

func DataplexLakeObservedState_ToProto 

func DataplexLakeObservedState_ToProto(mapCtx *direct.MapContext, in *krm.DataplexLakeObservedState) *pb.Lake

func DataplexLakeSpec_FromProto 

func DataplexLakeSpec_FromProto(mapCtx *direct.MapContext, in *pb.Lake) *krm.DataplexLakeSpec

func DataplexLakeSpec_ToProto 

func DataplexLakeSpec_ToProto(mapCtx *direct.MapContext, in *krm.DataplexLakeSpec) *pb.Lake

func DataplexTaskObservedState_FromProto added in v1.131.0 

func DataplexTaskObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Task) *krmv1alpha1.DataplexTaskObservedState

func DataplexTaskObservedState_ToProto added in v1.131.0 

func DataplexTaskObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataplexTaskObservedState) *pb.Task

func DataplexTaskSpec_FromProto added in v1.131.0 

func DataplexTaskSpec_FromProto(mapCtx *direct.MapContext, in *pb.Task) *krmv1alpha1.DataplexTaskSpec

func DataplexTaskSpec_ToProto added in v1.131.0 

func DataplexTaskSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataplexTaskSpec) *pb.Task

func DataplexZoneObservedState_FromProto added in v1.131.0 

func DataplexZoneObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Zone) *krmv1alpha1.DataplexZoneObservedState

func DataplexZoneObservedState_ToProto added in v1.131.0 

func DataplexZoneObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataplexZoneObservedState) *pb.Zone

func DataplexZoneSpec_FromProto added in v1.131.0 

func DataplexZoneSpec_FromProto(mapCtx *direct.MapContext, in *pb.Zone) *krmv1alpha1.DataplexZoneSpec

func DataplexZoneSpec_ToProto added in v1.131.0 

func DataplexZoneSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.DataplexZoneSpec) *pb.Zone

func EntryTypeObservedState_FromProto added in v1.131.0 

func EntryTypeObservedState_FromProto(mapCtx *direct.MapContext, in *pb.EntryType) *krm.EntryTypeObservedState

func EntryTypeObservedState_ToProto added in v1.131.0 

func EntryTypeObservedState_ToProto(mapCtx *direct.MapContext, in *krm.EntryTypeObservedState) *pb.EntryType

func EntryType_AspectInfo_FromProto added in v1.131.0 

func EntryType_AspectInfo_FromProto(mapCtx *direct.MapContext, in *pb.EntryType_AspectInfo) *krmv1alpha1.EntryType_AspectInfo

func EntryType_AspectInfo_ToProto added in v1.131.0 

func EntryType_AspectInfo_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.EntryType_AspectInfo) *pb.EntryType_AspectInfo

func EntryType_Authorization_FromProto added in v1.131.0 

func EntryType_Authorization_FromProto(mapCtx *direct.MapContext, in *pb.EntryType_Authorization) *krmv1alpha1.EntryType_Authorization

func EntryType_Authorization_ToProto added in v1.131.0 

func EntryType_Authorization_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.EntryType_Authorization) *pb.EntryType_Authorization

func EntryType_FromProto added in v1.131.0 

func EntryType_FromProto(mapCtx *direct.MapContext, in *pb.EntryType) *krm.EntryType

func EntryType_ToProto added in v1.131.0 

func EntryType_ToProto(mapCtx *direct.MapContext, in *krm.EntryType) *pb.EntryType

func JobObservedState_FromProto added in v1.131.0 

func JobObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Job) *krmv1alpha1.JobObservedState

func JobObservedState_ToProto added in v1.131.0 

func JobObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.JobObservedState) *pb.Job

func Lake_MetastoreStatus_FromProto 

func Lake_MetastoreStatus_FromProto(mapCtx *direct.MapContext, in *pb.Lake_MetastoreStatus) *krm.Lake_MetastoreStatus

func Lake_MetastoreStatus_ToProto 

func Lake_MetastoreStatus_ToProto(mapCtx *direct.MapContext, in *krm.Lake_MetastoreStatus) *pb.Lake_MetastoreStatus

func Lake_Metastore_FromProto 

func Lake_Metastore_FromProto(mapCtx *direct.MapContext, in *pb.Lake_Metastore) *krm.Lake_Metastore

func Lake_Metastore_ToProto 

func Lake_Metastore_ToProto(mapCtx *direct.MapContext, in *krm.Lake_Metastore) *pb.Lake_Metastore

func NewEntryGroupModel added in v1.131.0 

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

func NewEntryTypeModel added in v1.131.0 

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

func NewLakeModel 

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

func NewTaskModel added in v1.131.0 

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

func NewZoneModel added in v1.131.0 

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

func Task_ExecutionSpecObservedStatus_FromProto added in v1.131.0 

func Task_ExecutionSpecObservedStatus_FromProto(mapCtx *direct.MapContext, in *pb.Task_ExecutionSpec) *krmv1alpha1.Task_ExecutionSpecObservedState

Duplicate of Task_ExecutionSpec_FromProto, removing reference fields in observed status

func Task_ExecutionSpecObservedStatus_ToProto added in v1.131.0 

func Task_ExecutionSpecObservedStatus_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_ExecutionSpecObservedState) *pb.Task_ExecutionSpec

Duplicate of Task_ExecutionSpec_ToProto, removing reference fields in observed status

func Task_ExecutionSpec_FromProto added in v1.131.0 

func Task_ExecutionSpec_FromProto(mapCtx *direct.MapContext, in *pb.Task_ExecutionSpec) *krmv1alpha1.Task_ExecutionSpec

func Task_ExecutionSpec_ToProto added in v1.131.0 

func Task_ExecutionSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_ExecutionSpec) *pb.Task_ExecutionSpec

func Task_ExecutionStatusObservedState_FromProto added in v1.131.0 

func Task_ExecutionStatusObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Task_ExecutionStatus) *krmv1alpha1.Task_ExecutionStatusObservedState

func Task_ExecutionStatusObservedState_ToProto added in v1.131.0 

func Task_ExecutionStatusObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_ExecutionStatusObservedState) *pb.Task_ExecutionStatus

func Task_InfrastructureSpec_BatchComputeResources_FromProto added in v1.131.0 

func Task_InfrastructureSpec_BatchComputeResources_FromProto(mapCtx *direct.MapContext, in *pb.Task_InfrastructureSpec_BatchComputeResources) *krmv1alpha1.Task_InfrastructureSpec_BatchComputeResources

func Task_InfrastructureSpec_BatchComputeResources_ToProto added in v1.131.0 

func Task_InfrastructureSpec_BatchComputeResources_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_InfrastructureSpec_BatchComputeResources) *pb.Task_InfrastructureSpec_BatchComputeResources

func Task_InfrastructureSpec_ContainerImageRuntime_FromProto added in v1.131.0 

func Task_InfrastructureSpec_ContainerImageRuntime_FromProto(mapCtx *direct.MapContext, in *pb.Task_InfrastructureSpec_ContainerImageRuntime) *krmv1alpha1.Task_InfrastructureSpec_ContainerImageRuntime

func Task_InfrastructureSpec_ContainerImageRuntime_ToProto added in v1.131.0 

func Task_InfrastructureSpec_ContainerImageRuntime_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_InfrastructureSpec_ContainerImageRuntime) *pb.Task_InfrastructureSpec_ContainerImageRuntime

func Task_InfrastructureSpec_FromProto added in v1.131.0 

func Task_InfrastructureSpec_FromProto(mapCtx *direct.MapContext, in *pb.Task_InfrastructureSpec) *krmv1alpha1.Task_InfrastructureSpec

func Task_InfrastructureSpec_ToProto added in v1.131.0 

func Task_InfrastructureSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_InfrastructureSpec) *pb.Task_InfrastructureSpec

func Task_InfrastructureSpec_VpcNetwork_FromProto added in v1.131.0 

func Task_InfrastructureSpec_VpcNetwork_FromProto(mapCtx *direct.MapContext, in *pb.Task_InfrastructureSpec_VpcNetwork) *krmv1alpha1.Task_InfrastructureSpec_VpcNetwork

func Task_InfrastructureSpec_VpcNetwork_ToProto added in v1.131.0 

func Task_InfrastructureSpec_VpcNetwork_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_InfrastructureSpec_VpcNetwork) *pb.Task_InfrastructureSpec_VpcNetwork

func Task_NotebookTaskConfig_FromProto added in v1.131.0 

func Task_NotebookTaskConfig_FromProto(mapCtx *direct.MapContext, in *pb.Task_NotebookTaskConfig) *krmv1alpha1.Task_NotebookTaskConfig

func Task_NotebookTaskConfig_ToProto added in v1.131.0 

func Task_NotebookTaskConfig_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_NotebookTaskConfig) *pb.Task_NotebookTaskConfig

func Task_SparkTaskConfig_FromProto added in v1.131.0 

func Task_SparkTaskConfig_FromProto(mapCtx *direct.MapContext, in *pb.Task_SparkTaskConfig) *krmv1alpha1.Task_SparkTaskConfig

func Task_SparkTaskConfig_ToProto added in v1.131.0 

func Task_SparkTaskConfig_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_SparkTaskConfig) *pb.Task_SparkTaskConfig

func Task_TriggerSpec_FromProto added in v1.131.0 

func Task_TriggerSpec_FromProto(mapCtx *direct.MapContext, in *pb.Task_TriggerSpec) *krmv1alpha1.Task_TriggerSpec

func Task_TriggerSpec_ToProto added in v1.131.0 

func Task_TriggerSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Task_TriggerSpec) *pb.Task_TriggerSpec

func Zone_DiscoverySpec_CsvOptions_FromProto added in v1.131.0 

func Zone_DiscoverySpec_CsvOptions_FromProto(mapCtx *direct.MapContext, in *pb.Zone_DiscoverySpec_CsvOptions) *krmv1alpha1.Zone_DiscoverySpec_CsvOptions

func Zone_DiscoverySpec_CsvOptions_ToProto added in v1.131.0 

func Zone_DiscoverySpec_CsvOptions_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Zone_DiscoverySpec_CsvOptions) *pb.Zone_DiscoverySpec_CsvOptions

func Zone_DiscoverySpec_FromProto added in v1.131.0 

func Zone_DiscoverySpec_FromProto(mapCtx *direct.MapContext, in *pb.Zone_DiscoverySpec) *krmv1alpha1.Zone_DiscoverySpec

func Zone_DiscoverySpec_JsonOptions_FromProto added in v1.131.0 

func Zone_DiscoverySpec_JsonOptions_FromProto(mapCtx *direct.MapContext, in *pb.Zone_DiscoverySpec_JsonOptions) *krmv1alpha1.Zone_DiscoverySpec_JsonOptions

func Zone_DiscoverySpec_JsonOptions_ToProto added in v1.131.0 

func Zone_DiscoverySpec_JsonOptions_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Zone_DiscoverySpec_JsonOptions) *pb.Zone_DiscoverySpec_JsonOptions

func Zone_DiscoverySpec_Schedule_ToProto added in v1.131.0 

func Zone_DiscoverySpec_Schedule_ToProto(mapCtx *direct.MapContext, in *string) *pb.Zone_DiscoverySpec_Schedule

func Zone_DiscoverySpec_ToProto added in v1.131.0 

func Zone_DiscoverySpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Zone_DiscoverySpec) *pb.Zone_DiscoverySpec

func Zone_ResourceSpec_FromProto added in v1.131.0 

func Zone_ResourceSpec_FromProto(mapCtx *direct.MapContext, in *pb.Zone_ResourceSpec) *krmv1alpha1.Zone_ResourceSpec

func Zone_ResourceSpec_ToProto added in v1.131.0 

func Zone_ResourceSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.Zone_ResourceSpec) *pb.Zone_ResourceSpec

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.