clouddeploy

package
v1.134.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CanaryDeployment_FromProto 

func CanaryDeployment_FromProto(mapCtx *direct.MapContext, in *pb.CanaryDeployment) *krm.CanaryDeployment

func CanaryDeployment_ToProto 

func CanaryDeployment_ToProto(mapCtx *direct.MapContext, in *krm.CanaryDeployment) *pb.CanaryDeployment

func Canary_FromProto 

func Canary_FromProto(mapCtx *direct.MapContext, in *pb.Canary) *krm.Canary

func Canary_ToProto 

func Canary_ToProto(mapCtx *direct.MapContext, in *krm.Canary) *pb.Canary

func CloudRunConfig_FromProto 

func CloudRunConfig_FromProto(mapCtx *direct.MapContext, in *pb.CloudRunConfig) *krm.CloudRunConfig

func CloudRunConfig_ToProto 

func CloudRunConfig_ToProto(mapCtx *direct.MapContext, in *krm.CloudRunConfig) *pb.CloudRunConfig

func CustomCanaryDeployment_FromProto 

func CustomCanaryDeployment_FromProto(mapCtx *direct.MapContext, in *pb.CustomCanaryDeployment) *krm.CustomCanaryDeployment

func CustomCanaryDeployment_PhaseConfig_FromProto 

func CustomCanaryDeployment_PhaseConfig_FromProto(mapCtx *direct.MapContext, in *pb.CustomCanaryDeployment_PhaseConfig) *krm.CustomCanaryDeployment_PhaseConfig

func CustomCanaryDeployment_PhaseConfig_ToProto 

func CustomCanaryDeployment_PhaseConfig_ToProto(mapCtx *direct.MapContext, in *krm.CustomCanaryDeployment_PhaseConfig) *pb.CustomCanaryDeployment_PhaseConfig

func CustomCanaryDeployment_ToProto 

func CustomCanaryDeployment_ToProto(mapCtx *direct.MapContext, in *krm.CustomCanaryDeployment) *pb.CustomCanaryDeployment

func CustomTargetSkaffoldActions_FromProto 

func CustomTargetSkaffoldActions_FromProto(mapCtx *direct.MapContext, in *pb.CustomTargetSkaffoldActions) *krm.CustomTargetSkaffoldActions

func CustomTargetSkaffoldActions_ToProto 

func CustomTargetSkaffoldActions_ToProto(mapCtx *direct.MapContext, in *krm.CustomTargetSkaffoldActions) *pb.CustomTargetSkaffoldActions

func CustomTargetTypeObservedState_FromProto 

func CustomTargetTypeObservedState_FromProto(mapCtx *direct.MapContext, in *pb.CustomTargetType) *krm.CustomTargetTypeObservedState

func CustomTargetTypeObservedState_ToProto 

func CustomTargetTypeObservedState_ToProto(mapCtx *direct.MapContext, in *krm.CustomTargetTypeObservedState) *pb.CustomTargetType

func CustomTargetType_FromProto 

func CustomTargetType_FromProto(mapCtx *direct.MapContext, in *pb.CustomTargetType) *krm.CustomTargetTypeSpec

func CustomTargetType_ToProto 

func CustomTargetType_ToProto(mapCtx *direct.MapContext, in *krm.CustomTargetTypeSpec) *pb.CustomTargetType

func Date_FromProto 

func Date_FromProto(mapCtx *direct.MapContext, in *datepb.Date) *krm.Date

func Date_ToProto 

func Date_ToProto(mapCtx *direct.MapContext, in *krm.Date) *datepb.Date

func DeliveryPipelineAttribute_FromProto 

func DeliveryPipelineAttribute_FromProto(mapCtx *direct.MapContext, in *pb.DeliveryPipelineAttribute) *krm.DeliveryPipelineAttribute

func DeliveryPipelineAttribute_ToProto 

func DeliveryPipelineAttribute_ToProto(mapCtx *direct.MapContext, in *krm.DeliveryPipelineAttribute) *pb.DeliveryPipelineAttribute

func DeliveryPipelineObservedState_FromProto 

func DeliveryPipelineObservedState_FromProto(mapCtx *direct.MapContext, in *pb.DeliveryPipeline) *krm.DeliveryPipelineObservedState

func DeliveryPipelineObservedState_ToProto 

func DeliveryPipelineObservedState_ToProto(mapCtx *direct.MapContext, in *krm.DeliveryPipelineObservedState) *pb.DeliveryPipeline

func DeliveryPipelineSpec_FromProto 

func DeliveryPipelineSpec_FromProto(mapCtx *direct.MapContext, in *pb.DeliveryPipeline) *krm.DeliveryPipelineSpec

func DeliveryPipelineSpec_ToProto 

func DeliveryPipelineSpec_ToProto(mapCtx *direct.MapContext, in *krm.DeliveryPipelineSpec) *pb.DeliveryPipeline

func DeployParameters_FromProto 

func DeployParameters_FromProto(mapCtx *direct.MapContext, in *pb.DeployParameters) *krm.DeployParameters

func DeployParameters_ToProto 

func DeployParameters_ToProto(mapCtx *direct.MapContext, in *krm.DeployParameters) *pb.DeployParameters

func DeployPolicyObservedState_FromProto 

func DeployPolicyObservedState_FromProto(mapCtx *direct.MapContext, in *pb.DeployPolicy) *krm.DeployPolicyObservedState

func DeployPolicyObservedState_ToProto 

func DeployPolicyObservedState_ToProto(mapCtx *direct.MapContext, in *krm.DeployPolicyObservedState) *pb.DeployPolicy

func DeployPolicyResourceSelector_FromProto 

func DeployPolicyResourceSelector_FromProto(mapCtx *direct.MapContext, in *pb.DeployPolicyResourceSelector) *krm.DeployPolicyResourceSelector

func DeployPolicyResourceSelector_ToProto 

func DeployPolicyResourceSelector_ToProto(mapCtx *direct.MapContext, in *krm.DeployPolicyResourceSelector) *pb.DeployPolicyResourceSelector

func DeployPolicySpec_FromProto 

func DeployPolicySpec_FromProto(mapCtx *direct.MapContext, in *pb.DeployPolicy) *krm.DeployPolicySpec

func DeployPolicySpec_ToProto 

func DeployPolicySpec_ToProto(mapCtx *direct.MapContext, in *krm.DeployPolicySpec) *pb.DeployPolicy

func KubernetesConfig_FromProto 

func KubernetesConfig_FromProto(mapCtx *direct.MapContext, in *pb.KubernetesConfig) *krm.KubernetesConfig

func KubernetesConfig_GatewayServiceMesh_FromProto 

func KubernetesConfig_GatewayServiceMesh_FromProto(mapCtx *direct.MapContext, in *pb.KubernetesConfig_GatewayServiceMesh) *krm.KubernetesConfig_GatewayServiceMesh

func KubernetesConfig_GatewayServiceMesh_RouteDestinations_FromProto 

func KubernetesConfig_GatewayServiceMesh_RouteDestinations_FromProto(mapCtx *direct.MapContext, in *pb.KubernetesConfig_GatewayServiceMesh_RouteDestinations) *krm.KubernetesConfig_GatewayServiceMesh_RouteDestinations

func KubernetesConfig_GatewayServiceMesh_RouteDestinations_ToProto 

func KubernetesConfig_GatewayServiceMesh_RouteDestinations_ToProto(mapCtx *direct.MapContext, in *krm.KubernetesConfig_GatewayServiceMesh_RouteDestinations) *pb.KubernetesConfig_GatewayServiceMesh_RouteDestinations

func KubernetesConfig_GatewayServiceMesh_ToProto 

func KubernetesConfig_GatewayServiceMesh_ToProto(mapCtx *direct.MapContext, in *krm.KubernetesConfig_GatewayServiceMesh) *pb.KubernetesConfig_GatewayServiceMesh

func KubernetesConfig_ServiceNetworking_FromProto 

func KubernetesConfig_ServiceNetworking_FromProto(mapCtx *direct.MapContext, in *pb.KubernetesConfig_ServiceNetworking) *krm.KubernetesConfig_ServiceNetworking

func KubernetesConfig_ServiceNetworking_ToProto 

func KubernetesConfig_ServiceNetworking_ToProto(mapCtx *direct.MapContext, in *krm.KubernetesConfig_ServiceNetworking) *pb.KubernetesConfig_ServiceNetworking

func KubernetesConfig_ToProto 

func KubernetesConfig_ToProto(mapCtx *direct.MapContext, in *krm.KubernetesConfig) *pb.KubernetesConfig

func NewDeliveryPipelineModel 

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

func OneTimeWindow_FromProto 

func OneTimeWindow_FromProto(mapCtx *direct.MapContext, in *pb.OneTimeWindow) *krm.OneTimeWindow

func OneTimeWindow_ToProto 

func OneTimeWindow_ToProto(mapCtx *direct.MapContext, in *krm.OneTimeWindow) *pb.OneTimeWindow

func PipelineCondition_FromProto 

func PipelineCondition_FromProto(mapCtx *direct.MapContext, in *pb.PipelineCondition) *krm.PipelineCondition

func PipelineCondition_ToProto 

func PipelineCondition_ToProto(mapCtx *direct.MapContext, in *krm.PipelineCondition) *pb.PipelineCondition

func PipelineReadyCondition_FromProto 

func PipelineReadyCondition_FromProto(mapCtx *direct.MapContext, in *pb.PipelineReadyCondition) *krm.PipelineReadyCondition

func PipelineReadyCondition_ToProto 

func PipelineReadyCondition_ToProto(mapCtx *direct.MapContext, in *krm.PipelineReadyCondition) *pb.PipelineReadyCondition

func PolicyRule_FromProto 

func PolicyRule_FromProto(mapCtx *direct.MapContext, in *pb.PolicyRule) *krm.PolicyRule

func PolicyRule_ToProto 

func PolicyRule_ToProto(mapCtx *direct.MapContext, in *krm.PolicyRule) *pb.PolicyRule

func Postdeploy_FromProto 

func Postdeploy_FromProto(mapCtx *direct.MapContext, in *pb.Postdeploy) *krm.Postdeploy

func Postdeploy_ToProto 

func Postdeploy_ToProto(mapCtx *direct.MapContext, in *krm.Postdeploy) *pb.Postdeploy

func Predeploy_FromProto 

func Predeploy_FromProto(mapCtx *direct.MapContext, in *pb.Predeploy) *krm.Predeploy

func Predeploy_ToProto 

func Predeploy_ToProto(mapCtx *direct.MapContext, in *krm.Predeploy) *pb.Predeploy

func RolloutRestriction_FromProto 

func RolloutRestriction_FromProto(mapCtx *direct.MapContext, in *pb.RolloutRestriction) *krm.RolloutRestriction

func RolloutRestriction_ToProto 

func RolloutRestriction_ToProto(mapCtx *direct.MapContext, in *krm.RolloutRestriction) *pb.RolloutRestriction

func RuntimeConfig_FromProto 

func RuntimeConfig_FromProto(mapCtx *direct.MapContext, in *pb.RuntimeConfig) *krm.RuntimeConfig

func RuntimeConfig_ToProto 

func RuntimeConfig_ToProto(mapCtx *direct.MapContext, in *krm.RuntimeConfig) *pb.RuntimeConfig

func SerialPipeline_FromProto 

func SerialPipeline_FromProto(mapCtx *direct.MapContext, in *pb.SerialPipeline) *krm.SerialPipeline

func SerialPipeline_ToProto 

func SerialPipeline_ToProto(mapCtx *direct.MapContext, in *krm.SerialPipeline) *pb.SerialPipeline

func SkaffoldModules_FromProto 

func SkaffoldModules_FromProto(mapCtx *direct.MapContext, in *pb.SkaffoldModules) *krm.SkaffoldModules

func SkaffoldModules_SkaffoldGCSSource_FromProto 

func SkaffoldModules_SkaffoldGCSSource_FromProto(mapCtx *direct.MapContext, in *pb.SkaffoldModules_SkaffoldGCSSource) *krm.SkaffoldModules_SkaffoldGCSSource

func SkaffoldModules_SkaffoldGCSSource_ToProto 

func SkaffoldModules_SkaffoldGCSSource_ToProto(mapCtx *direct.MapContext, in *krm.SkaffoldModules_SkaffoldGCSSource) *pb.SkaffoldModules_SkaffoldGCSSource

func SkaffoldModules_SkaffoldGcbRepoSource_FromProto 

func SkaffoldModules_SkaffoldGcbRepoSource_FromProto(mapCtx *direct.MapContext, in *pb.SkaffoldModules_SkaffoldGCBRepoSource) *krm.SkaffoldModules_SkaffoldGcbRepoSource

func SkaffoldModules_SkaffoldGcbRepoSource_ToProto 

func SkaffoldModules_SkaffoldGcbRepoSource_ToProto(mapCtx *direct.MapContext, in *krm.SkaffoldModules_SkaffoldGcbRepoSource) *pb.SkaffoldModules_SkaffoldGCBRepoSource

func SkaffoldModules_SkaffoldGitSource_FromProto 

func SkaffoldModules_SkaffoldGitSource_FromProto(mapCtx *direct.MapContext, in *pb.SkaffoldModules_SkaffoldGitSource) *krm.SkaffoldModules_SkaffoldGitSource

func SkaffoldModules_SkaffoldGitSource_ToProto 

func SkaffoldModules_SkaffoldGitSource_ToProto(mapCtx *direct.MapContext, in *krm.SkaffoldModules_SkaffoldGitSource) *pb.SkaffoldModules_SkaffoldGitSource

func SkaffoldModules_ToProto 

func SkaffoldModules_ToProto(mapCtx *direct.MapContext, in *krm.SkaffoldModules) *pb.SkaffoldModules

func Stage_FromProto 

func Stage_FromProto(mapCtx *direct.MapContext, in *pb.Stage) *krm.Stage

func Stage_ToProto 

func Stage_ToProto(mapCtx *direct.MapContext, in *krm.Stage) *pb.Stage

func Standard_FromProto 

func Standard_FromProto(mapCtx *direct.MapContext, in *pb.Standard) *krm.Standard

func Standard_ToProto 

func Standard_ToProto(mapCtx *direct.MapContext, in *krm.Standard) *pb.Standard

func Strategy_FromProto 

func Strategy_FromProto(mapCtx *direct.MapContext, in *pb.Strategy) *krm.Strategy

func Strategy_ToProto 

func Strategy_ToProto(mapCtx *direct.MapContext, in *krm.Strategy) *pb.Strategy

func TargetAttribute_FromProto 

func TargetAttribute_FromProto(mapCtx *direct.MapContext, in *pb.TargetAttribute) *krm.TargetAttribute

func TargetAttribute_ToProto 

func TargetAttribute_ToProto(mapCtx *direct.MapContext, in *krm.TargetAttribute) *pb.TargetAttribute

func TargetsPresentCondition_FromProto 

func TargetsPresentCondition_FromProto(mapCtx *direct.MapContext, in *pb.TargetsPresentCondition) *krm.TargetsPresentCondition

func TargetsPresentCondition_ToProto 

func TargetsPresentCondition_ToProto(mapCtx *direct.MapContext, in *krm.TargetsPresentCondition) *pb.TargetsPresentCondition

func TargetsTypeCondition_FromProto 

func TargetsTypeCondition_FromProto(mapCtx *direct.MapContext, in *pb.TargetsTypeCondition) *krm.TargetsTypeCondition

func TargetsTypeCondition_ToProto 

func TargetsTypeCondition_ToProto(mapCtx *direct.MapContext, in *krm.TargetsTypeCondition) *pb.TargetsTypeCondition

func TimeOfDay_FromProto 

func TimeOfDay_FromProto(mapCtx *direct.MapContext, in *timeofdaypb.TimeOfDay) *krm.TimeOfDay

func TimeOfDay_ToProto 

func TimeOfDay_ToProto(mapCtx *direct.MapContext, in *krm.TimeOfDay) *timeofdaypb.TimeOfDay

func TimeWindows_FromProto 

func TimeWindows_FromProto(mapCtx *direct.MapContext, in *pb.TimeWindows) *krm.TimeWindows

func TimeWindows_ToProto 

func TimeWindows_ToProto(mapCtx *direct.MapContext, in *krm.TimeWindows) *pb.TimeWindows

func WeeklyWindow_FromProto 

func WeeklyWindow_FromProto(mapCtx *direct.MapContext, in *pb.WeeklyWindow) *krm.WeeklyWindow

func WeeklyWindow_ToProto 

func WeeklyWindow_ToProto(mapCtx *direct.MapContext, in *krm.WeeklyWindow) *pb.WeeklyWindow

Types

type DeliveryPipelineAdapter 

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

func (*DeliveryPipelineAdapter) Create 

func (a *DeliveryPipelineAdapter) 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 (*DeliveryPipelineAdapter) Delete 

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

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

func (*DeliveryPipelineAdapter) Export 

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

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

func (*DeliveryPipelineAdapter) Find 

func (a *DeliveryPipelineAdapter) 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 (*DeliveryPipelineAdapter) Update 

func (a *DeliveryPipelineAdapter) 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.