composer

package
v1.154.0 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AirflowMetadataRetentionPolicyConfig_FromProto 

func AirflowMetadataRetentionPolicyConfig_FromProto(mapCtx *direct.MapContext, in *pb.AirflowMetadataRetentionPolicyConfig) *krm.AirflowMetadataRetentionPolicyConfig

func AirflowMetadataRetentionPolicyConfig_ToProto 

func AirflowMetadataRetentionPolicyConfig_ToProto(mapCtx *direct.MapContext, in *krm.AirflowMetadataRetentionPolicyConfig) *pb.AirflowMetadataRetentionPolicyConfig

func CloudDataLineageIntegration_FromProto 

func CloudDataLineageIntegration_FromProto(mapCtx *direct.MapContext, in *pb.CloudDataLineageIntegration) *krm.CloudDataLineageIntegration

func CloudDataLineageIntegration_ToProto 

func CloudDataLineageIntegration_ToProto(mapCtx *direct.MapContext, in *krm.CloudDataLineageIntegration) *pb.CloudDataLineageIntegration

func ComposerEnvironmentObservedState_FromProto 

func ComposerEnvironmentObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Environment) *krm.ComposerEnvironmentObservedState

func ComposerEnvironmentObservedState_ToProto 

func ComposerEnvironmentObservedState_ToProto(mapCtx *direct.MapContext, in *krm.ComposerEnvironmentObservedState) *pb.Environment

func ComposerEnvironmentSpec_FromProto 

func ComposerEnvironmentSpec_FromProto(mapCtx *direct.MapContext, in *pb.Environment) *krm.ComposerEnvironmentSpec

func ComposerEnvironmentSpec_ToProto 

func ComposerEnvironmentSpec_ToProto(mapCtx *direct.MapContext, in *krm.ComposerEnvironmentSpec) *pb.Environment

func DataRetentionConfig_FromProto 

func DataRetentionConfig_FromProto(mapCtx *direct.MapContext, in *pb.DataRetentionConfig) *krm.DataRetentionConfig

func DataRetentionConfig_ToProto 

func DataRetentionConfig_ToProto(mapCtx *direct.MapContext, in *krm.DataRetentionConfig) *pb.DataRetentionConfig

func DatabaseConfig_FromProto 

func DatabaseConfig_FromProto(mapCtx *direct.MapContext, in *pb.DatabaseConfig) *krm.DatabaseConfig

func DatabaseConfig_ToProto 

func DatabaseConfig_ToProto(mapCtx *direct.MapContext, in *krm.DatabaseConfig) *pb.DatabaseConfig

func EncryptionConfig_FromProto 

func EncryptionConfig_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionConfig) *krm.EncryptionConfig

func EncryptionConfig_ToProto 

func EncryptionConfig_ToProto(mapCtx *direct.MapContext, in *krm.EncryptionConfig) *pb.EncryptionConfig

func EnvironmentConfigObservedState_FromProto 

func EnvironmentConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.EnvironmentConfig) *krm.EnvironmentConfigObservedState

func EnvironmentConfigObservedState_ToProto 

func EnvironmentConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krm.EnvironmentConfigObservedState) *pb.EnvironmentConfig

func EnvironmentConfig_FromProto 

func EnvironmentConfig_FromProto(mapCtx *direct.MapContext, in *pb.EnvironmentConfig) *krm.EnvironmentConfig

func EnvironmentConfig_ToProto 

func EnvironmentConfig_ToProto(mapCtx *direct.MapContext, in *krm.EnvironmentConfig) *pb.EnvironmentConfig

func IPAllocationPolicy_ClusterIpv4CidrBlock_ToProto added in v1.136.0 

func IPAllocationPolicy_ClusterIpv4CidrBlock_ToProto(mapCtx *direct.MapContext, in *string) *pb.IPAllocationPolicy_ClusterIpv4CidrBlock

func IPAllocationPolicy_ClusterSecondaryRangeName_ToProto added in v1.136.0 

func IPAllocationPolicy_ClusterSecondaryRangeName_ToProto(mapCtx *direct.MapContext, in *string) *pb.IPAllocationPolicy_ClusterSecondaryRangeName

func IPAllocationPolicy_FromProto 

func IPAllocationPolicy_FromProto(mapCtx *direct.MapContext, in *pb.IPAllocationPolicy) *krm.IPAllocationPolicy

func IPAllocationPolicy_ServicesIpv4CidrBlock_ToProto added in v1.136.0 

func IPAllocationPolicy_ServicesIpv4CidrBlock_ToProto(mapCtx *direct.MapContext, in *string) *pb.IPAllocationPolicy_ServicesIpv4CidrBlock

func IPAllocationPolicy_ServicesSecondaryRangeName_ToProto added in v1.136.0 

func IPAllocationPolicy_ServicesSecondaryRangeName_ToProto(mapCtx *direct.MapContext, in *string) *pb.IPAllocationPolicy_ServicesSecondaryRangeName

func IPAllocationPolicy_ToProto 

func IPAllocationPolicy_ToProto(mapCtx *direct.MapContext, in *krm.IPAllocationPolicy) *pb.IPAllocationPolicy

func MaintenanceWindow_FromProto 

func MaintenanceWindow_FromProto(mapCtx *direct.MapContext, in *pb.MaintenanceWindow) *krm.MaintenanceWindow

func MaintenanceWindow_ToProto 

func MaintenanceWindow_ToProto(mapCtx *direct.MapContext, in *krm.MaintenanceWindow) *pb.MaintenanceWindow

func MasterAuthorizedNetworksConfig_CIDRBlock_FromProto 

func MasterAuthorizedNetworksConfig_CIDRBlock_FromProto(mapCtx *direct.MapContext, in *pb.MasterAuthorizedNetworksConfig_CidrBlock) *krm.MasterAuthorizedNetworksConfig_CIDRBlock

func MasterAuthorizedNetworksConfig_CIDRBlock_ToProto 

func MasterAuthorizedNetworksConfig_CIDRBlock_ToProto(mapCtx *direct.MapContext, in *krm.MasterAuthorizedNetworksConfig_CIDRBlock) *pb.MasterAuthorizedNetworksConfig_CidrBlock

func MasterAuthorizedNetworksConfig_FromProto 

func MasterAuthorizedNetworksConfig_FromProto(mapCtx *direct.MapContext, in *pb.MasterAuthorizedNetworksConfig) *krm.MasterAuthorizedNetworksConfig

func MasterAuthorizedNetworksConfig_ToProto 

func MasterAuthorizedNetworksConfig_ToProto(mapCtx *direct.MapContext, in *krm.MasterAuthorizedNetworksConfig) *pb.MasterAuthorizedNetworksConfig

func NetworkingConfig_FromProto 

func NetworkingConfig_FromProto(mapCtx *direct.MapContext, in *pb.NetworkingConfig) *krm.NetworkingConfig

func NetworkingConfig_ToProto 

func NetworkingConfig_ToProto(mapCtx *direct.MapContext, in *krm.NetworkingConfig) *pb.NetworkingConfig

func NewEnvironmentModel 

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

func NodeConfig_FromProto 

func NodeConfig_FromProto(mapCtx *direct.MapContext, in *pb.NodeConfig) *krm.NodeConfig

func NodeConfig_ToProto 

func NodeConfig_ToProto(mapCtx *direct.MapContext, in *krm.NodeConfig) *pb.NodeConfig

func PrivateClusterConfigObservedState_FromProto 

func PrivateClusterConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PrivateClusterConfig) *krm.PrivateClusterConfigObservedState

func PrivateClusterConfigObservedState_ToProto 

func PrivateClusterConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krm.PrivateClusterConfigObservedState) *pb.PrivateClusterConfig

func PrivateClusterConfig_FromProto 

func PrivateClusterConfig_FromProto(mapCtx *direct.MapContext, in *pb.PrivateClusterConfig) *krm.PrivateClusterConfig

func PrivateClusterConfig_ToProto 

func PrivateClusterConfig_ToProto(mapCtx *direct.MapContext, in *krm.PrivateClusterConfig) *pb.PrivateClusterConfig

func PrivateEnvironmentConfigObservedState_FromProto 

func PrivateEnvironmentConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PrivateEnvironmentConfig) *krm.PrivateEnvironmentConfigObservedState

func PrivateEnvironmentConfigObservedState_ToProto 

func PrivateEnvironmentConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krm.PrivateEnvironmentConfigObservedState) *pb.PrivateEnvironmentConfig

func PrivateEnvironmentConfig_FromProto 

func PrivateEnvironmentConfig_FromProto(mapCtx *direct.MapContext, in *pb.PrivateEnvironmentConfig) *krm.PrivateEnvironmentConfig

func PrivateEnvironmentConfig_ToProto 

func PrivateEnvironmentConfig_ToProto(mapCtx *direct.MapContext, in *krm.PrivateEnvironmentConfig) *pb.PrivateEnvironmentConfig

func RecoveryConfig_FromProto 

func RecoveryConfig_FromProto(mapCtx *direct.MapContext, in *pb.RecoveryConfig) *krm.RecoveryConfig

func RecoveryConfig_ToProto 

func RecoveryConfig_ToProto(mapCtx *direct.MapContext, in *krm.RecoveryConfig) *pb.RecoveryConfig

func ResolveEnvironmentRefs added in v1.153.0 

func ResolveEnvironmentRefs(ctx context.Context, kube client.Reader, obj *krm.ComposerEnvironment) error

func ScheduledSnapshotsConfig_FromProto 

func ScheduledSnapshotsConfig_FromProto(mapCtx *direct.MapContext, in *pb.ScheduledSnapshotsConfig) *krm.ScheduledSnapshotsConfig

func ScheduledSnapshotsConfig_ToProto 

func ScheduledSnapshotsConfig_ToProto(mapCtx *direct.MapContext, in *krm.ScheduledSnapshotsConfig) *pb.ScheduledSnapshotsConfig

func SoftwareConfig_FromProto 

func SoftwareConfig_FromProto(mapCtx *direct.MapContext, in *pb.SoftwareConfig) *krm.SoftwareConfig

func SoftwareConfig_ToProto 

func SoftwareConfig_ToProto(mapCtx *direct.MapContext, in *krm.SoftwareConfig) *pb.SoftwareConfig

func StorageConfig_FromProto 

func StorageConfig_FromProto(mapCtx *direct.MapContext, in *pb.StorageConfig) *krm.StorageConfig

func StorageConfig_ToProto 

func StorageConfig_ToProto(mapCtx *direct.MapContext, in *krm.StorageConfig) *pb.StorageConfig

func TaskLogsRetentionConfig_FromProto 

func TaskLogsRetentionConfig_FromProto(mapCtx *direct.MapContext, in *pb.TaskLogsRetentionConfig) *krm.TaskLogsRetentionConfig

func TaskLogsRetentionConfig_ToProto 

func TaskLogsRetentionConfig_ToProto(mapCtx *direct.MapContext, in *krm.TaskLogsRetentionConfig) *pb.TaskLogsRetentionConfig

func WebServerConfig_FromProto 

func WebServerConfig_FromProto(mapCtx *direct.MapContext, in *pb.WebServerConfig) *krm.WebServerConfig

func WebServerConfig_ToProto 

func WebServerConfig_ToProto(mapCtx *direct.MapContext, in *krm.WebServerConfig) *pb.WebServerConfig

func WebServerNetworkAccessControl_AllowedIPRange_FromProto 

func WebServerNetworkAccessControl_AllowedIPRange_FromProto(mapCtx *direct.MapContext, in *pb.WebServerNetworkAccessControl_AllowedIpRange) *krm.WebServerNetworkAccessControl_AllowedIPRange

func WebServerNetworkAccessControl_AllowedIPRange_ToProto 

func WebServerNetworkAccessControl_AllowedIPRange_ToProto(mapCtx *direct.MapContext, in *krm.WebServerNetworkAccessControl_AllowedIPRange) *pb.WebServerNetworkAccessControl_AllowedIpRange

func WebServerNetworkAccessControl_FromProto 

func WebServerNetworkAccessControl_FromProto(mapCtx *direct.MapContext, in *pb.WebServerNetworkAccessControl) *krm.WebServerNetworkAccessControl

func WebServerNetworkAccessControl_ToProto 

func WebServerNetworkAccessControl_ToProto(mapCtx *direct.MapContext, in *krm.WebServerNetworkAccessControl) *pb.WebServerNetworkAccessControl

func WorkloadsConfig_DagProcessorResource_FromProto 

func WorkloadsConfig_DagProcessorResource_FromProto(mapCtx *direct.MapContext, in *pb.WorkloadsConfig_DagProcessorResource) *krm.WorkloadsConfig_DagProcessorResource

func WorkloadsConfig_DagProcessorResource_ToProto 

func WorkloadsConfig_DagProcessorResource_ToProto(mapCtx *direct.MapContext, in *krm.WorkloadsConfig_DagProcessorResource) *pb.WorkloadsConfig_DagProcessorResource

func WorkloadsConfig_FromProto 

func WorkloadsConfig_FromProto(mapCtx *direct.MapContext, in *pb.WorkloadsConfig) *krm.WorkloadsConfig

func WorkloadsConfig_SchedulerResource_FromProto 

func WorkloadsConfig_SchedulerResource_FromProto(mapCtx *direct.MapContext, in *pb.WorkloadsConfig_SchedulerResource) *krm.WorkloadsConfig_SchedulerResource

func WorkloadsConfig_SchedulerResource_ToProto 

func WorkloadsConfig_SchedulerResource_ToProto(mapCtx *direct.MapContext, in *krm.WorkloadsConfig_SchedulerResource) *pb.WorkloadsConfig_SchedulerResource

func WorkloadsConfig_ToProto 

func WorkloadsConfig_ToProto(mapCtx *direct.MapContext, in *krm.WorkloadsConfig) *pb.WorkloadsConfig

func WorkloadsConfig_TriggererResource_FromProto 

func WorkloadsConfig_TriggererResource_FromProto(mapCtx *direct.MapContext, in *pb.WorkloadsConfig_TriggererResource) *krm.WorkloadsConfig_TriggererResource

func WorkloadsConfig_TriggererResource_ToProto 

func WorkloadsConfig_TriggererResource_ToProto(mapCtx *direct.MapContext, in *krm.WorkloadsConfig_TriggererResource) *pb.WorkloadsConfig_TriggererResource

func WorkloadsConfig_WebServerResource_FromProto 

func WorkloadsConfig_WebServerResource_FromProto(mapCtx *direct.MapContext, in *pb.WorkloadsConfig_WebServerResource) *krm.WorkloadsConfig_WebServerResource

func WorkloadsConfig_WebServerResource_ToProto 

func WorkloadsConfig_WebServerResource_ToProto(mapCtx *direct.MapContext, in *krm.WorkloadsConfig_WebServerResource) *pb.WorkloadsConfig_WebServerResource

func WorkloadsConfig_WorkerResource_FromProto 

func WorkloadsConfig_WorkerResource_FromProto(mapCtx *direct.MapContext, in *pb.WorkloadsConfig_WorkerResource) *krm.WorkloadsConfig_WorkerResource

func WorkloadsConfig_WorkerResource_ToProto 

func WorkloadsConfig_WorkerResource_ToProto(mapCtx *direct.MapContext, in *krm.WorkloadsConfig_WorkerResource) *pb.WorkloadsConfig_WorkerResource

Types

type EnvironmentAdapter 

type EnvironmentAdapter struct {
	// contains filtered or unexported fields
}

func (*EnvironmentAdapter) Create 

func (a *EnvironmentAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*EnvironmentAdapter) Delete 

func (a *EnvironmentAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*EnvironmentAdapter) Export 

func (a *EnvironmentAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*EnvironmentAdapter) Find 

func (a *EnvironmentAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*EnvironmentAdapter) Update 

func (a *EnvironmentAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

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.