dataplex

package
v1.152.0 Latest Latest
Warning

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

 Go to latest Published: May 28, 2026 License: Apache-2.0 Imports: 25 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) *krm.DataplexEntryGroupObservedState

func DataplexEntryGroupObservedState_ToProto added in v1.131.0 

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

func DataplexEntryGroupSpec_FromProto added in v1.131.0 

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

func DataplexEntryGroupSpec_ToProto added in v1.131.0 

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

func DataplexEntryTypeObservedState_FromProto added in v1.131.0 

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

func DataplexEntryTypeObservedState_ToProto added in v1.131.0 

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

func DataplexEntryTypeSpec_FromProto added in v1.131.0 

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

func DataplexEntryTypeSpec_ToProto added in v1.131.0 

func DataplexEntryTypeSpec_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.DataplexTaskSpec

func DataplexTaskSpec_ToProto added in v1.131.0 

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

func DataplexZoneObservedState_FromProto added in v1.131.0 

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

func DataplexZoneObservedState_ToProto added in v1.131.0 

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

func DataplexZoneSpec_FromProto added in v1.131.0 

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

func DataplexZoneSpec_ToProto added in v1.131.0 

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

func EntryType_AspectInfo_FromProto added in v1.131.0 

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

func EntryType_AspectInfo_ToProto added in v1.131.0 

func EntryType_AspectInfo_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.EntryType_Authorization

func EntryType_Authorization_ToProto added in v1.131.0 

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

func JobObservedState_FromProto added in v1.131.0 

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

func JobObservedState_ToProto added in v1.131.0 

func JobObservedState_ToProto(mapCtx *direct.MapContext, in *krm.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_ExecutionSpecObservedState_FromProto added in v1.141.0 

func Task_ExecutionSpecObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Task_ExecutionSpec) *krm.Task_ExecutionSpecObservedState

func Task_ExecutionSpecObservedState_ToProto added in v1.141.0 

func Task_ExecutionSpecObservedState_ToProto(mapCtx *direct.MapContext, in *krm.Task_ExecutionSpecObservedState) *pb.Task_ExecutionSpec

func Task_ExecutionSpec_FromProto added in v1.131.0 

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

func Task_ExecutionSpec_ToProto added in v1.131.0 

func Task_ExecutionSpec_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.Task_ExecutionStatusObservedState

func Task_ExecutionStatusObservedState_ToProto added in v1.131.0 

func Task_ExecutionStatusObservedState_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.Task_InfrastructureSpec_BatchComputeResources

func Task_InfrastructureSpec_BatchComputeResources_ToProto added in v1.131.0 

func Task_InfrastructureSpec_BatchComputeResources_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.Task_InfrastructureSpec_ContainerImageRuntime

func Task_InfrastructureSpec_ContainerImageRuntime_ToProto added in v1.131.0 

func Task_InfrastructureSpec_ContainerImageRuntime_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.Task_InfrastructureSpec

func Task_InfrastructureSpec_ToProto added in v1.131.0 

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

func Task_InfrastructureSpec_VPCNetwork_FromProto added in v1.141.0 

func Task_InfrastructureSpec_VPCNetwork_FromProto(mapCtx *direct.MapContext, in *pb.Task_InfrastructureSpec_VpcNetwork) *krm.Task_InfrastructureSpec_VPCNetwork

func Task_InfrastructureSpec_VPCNetwork_Network_ToProto added in v1.141.0 

func Task_InfrastructureSpec_VPCNetwork_Network_ToProto(mapCtx *direct.MapContext, in *string) *pb.Task_InfrastructureSpec_VpcNetwork_Network

func Task_InfrastructureSpec_VPCNetwork_SubNetwork_ToProto added in v1.141.0 

func Task_InfrastructureSpec_VPCNetwork_SubNetwork_ToProto(mapCtx *direct.MapContext, in *string) *pb.Task_InfrastructureSpec_VpcNetwork_SubNetwork

func Task_InfrastructureSpec_VPCNetwork_ToProto added in v1.141.0 

func Task_InfrastructureSpec_VPCNetwork_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.Task_NotebookTaskConfig

func Task_NotebookTaskConfig_ToProto added in v1.131.0 

func Task_NotebookTaskConfig_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.Task_SparkTaskConfig

func Task_SparkTaskConfig_MainClass_ToProto added in v1.141.0 

func Task_SparkTaskConfig_MainClass_ToProto(mapCtx *direct.MapContext, in *string) *pb.Task_SparkTaskConfig_MainClass

func Task_SparkTaskConfig_MainJarFileUri_ToProto added in v1.141.0 

func Task_SparkTaskConfig_MainJarFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.Task_SparkTaskConfig_MainJarFileUri

func Task_SparkTaskConfig_PythonScriptFile_ToProto added in v1.141.0 

func Task_SparkTaskConfig_PythonScriptFile_ToProto(mapCtx *direct.MapContext, in *string) *pb.Task_SparkTaskConfig_PythonScriptFile

func Task_SparkTaskConfig_SqlScriptFile_ToProto added in v1.141.0 

func Task_SparkTaskConfig_SqlScriptFile_ToProto(mapCtx *direct.MapContext, in *string) *pb.Task_SparkTaskConfig_SqlScriptFile

func Task_SparkTaskConfig_SqlScript_ToProto added in v1.141.0 

func Task_SparkTaskConfig_SqlScript_ToProto(mapCtx *direct.MapContext, in *string) *pb.Task_SparkTaskConfig_SqlScript

func Task_SparkTaskConfig_ToProto added in v1.131.0 

func Task_SparkTaskConfig_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.Task_TriggerSpec

func Task_TriggerSpec_Schedule_ToProto added in v1.141.0 

func Task_TriggerSpec_Schedule_ToProto(mapCtx *direct.MapContext, in *string) *pb.Task_TriggerSpec_Schedule

func Task_TriggerSpec_ToProto added in v1.131.0 

func Task_TriggerSpec_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.Zone_DiscoverySpec_CsvOptions

func Zone_DiscoverySpec_CsvOptions_ToProto added in v1.131.0 

func Zone_DiscoverySpec_CsvOptions_ToProto(mapCtx *direct.MapContext, in *krm.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) *krm.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) *krm.Zone_DiscoverySpec_JsonOptions

func Zone_DiscoverySpec_JsonOptions_ToProto added in v1.131.0 

func Zone_DiscoverySpec_JsonOptions_ToProto(mapCtx *direct.MapContext, in *krm.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 *krm.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) *krm.Zone_ResourceSpec

func Zone_ResourceSpec_ToProto added in v1.131.0 

func Zone_ResourceSpec_ToProto(mapCtx *direct.MapContext, in *krm.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.