deployment

package
v0.51.0-rc0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	PredefinedStageK8sSync  = "K8sSync"
	PredefinedStageRollback = "K8sRollback"
)

Variables

View Source 
var AllStages = []Stage{
	StageK8sSync,
	StageK8sPrimaryRollout,
	StageK8sCanaryRollout,
	StageK8sCanaryClean,
	StageK8sBaselineRollout,
	StageK8sBaselineClean,
	StageK8sTrafficRouting,
	StageK8sRollback,
}

Functions

func BuildQuickSyncPipeline 

func BuildQuickSyncPipeline(autoRollback bool) []sdk.QuickSyncStage

func GetPredefinedStage 

func GetPredefinedStage(id string) (*model.PipelineStage, bool)

GetPredefinedStage finds and returns the predefined stage for the given id.

Types

type DeploymentService 

type DeploymentService struct {
	deployment.UnimplementedDeploymentServiceServer
	// contains filtered or unexported fields
}

func NewDeploymentService 

func NewDeploymentService(
	config *config.PipedPlugin,
	logger *zap.Logger,
	toolClient toolClient,
	logPersister logPersister,
) *DeploymentService

NewDeploymentService creates a new planService.

func (*DeploymentService) BuildPipelineSyncStages 

func (a *DeploymentService) BuildPipelineSyncStages(ctx context.Context, request *deployment.BuildPipelineSyncStagesRequest) (*deployment.BuildPipelineSyncStagesResponse, error)

BuildPipelineSyncStages implements deployment.DeploymentServiceServer.

func (*DeploymentService) BuildQuickSyncStages 

func (a *DeploymentService) BuildQuickSyncStages(ctx context.Context, request *deployment.BuildQuickSyncStagesRequest) (*deployment.BuildQuickSyncStagesResponse, error)

BuildQuickSyncStages implements deployment.DeploymentServiceServer.

func (*DeploymentService) DetermineStrategy 

func (a *DeploymentService) DetermineStrategy(ctx context.Context, request *deployment.DetermineStrategyRequest) (*deployment.DetermineStrategyResponse, error)

DetermineStrategy implements deployment.DeploymentServiceServer.

func (*DeploymentService) DetermineVersions 

func (a *DeploymentService) DetermineVersions(ctx context.Context, request *deployment.DetermineVersionsRequest) (*deployment.DetermineVersionsResponse, error)

DetermineVersions implements deployment.DeploymentServiceServer.

func (*DeploymentService) ExecuteStage 

func (a *DeploymentService) ExecuteStage(ctx context.Context, request *deployment.ExecuteStageRequest) (response *deployment.ExecuteStageResponse, _ error)

ExecuteStage performs stage-defined tasks. It returns stage status after execution without error. Error only be raised if the given stage is not supported.

func (*DeploymentService) FetchDefinedStages 

func (a *DeploymentService) FetchDefinedStages(context.Context, *deployment.FetchDefinedStagesRequest) (*deployment.FetchDefinedStagesResponse, error)

FetchDefinedStages implements deployment.DeploymentServiceServer.

func (*DeploymentService) Register 

func (a *DeploymentService) Register(server *grpc.Server)

Register registers all handling of this service into the specified gRPC server.

type Plugin added in v0.51.0 

type Plugin struct {
}

Plugin implements the sdk.DeploymentPlugin interface.

func (*Plugin) BuildPipelineSyncStages added in v0.51.0 

func (p *Plugin) BuildPipelineSyncStages(ctx context.Context, _ *sdk.ConfigNone, input *sdk.BuildPipelineSyncStagesInput) (*sdk.BuildPipelineSyncStagesResponse, error)

FIXME

func (*Plugin) BuildQuickSyncStages added in v0.51.0 

func (p *Plugin) BuildQuickSyncStages(ctx context.Context, _ *sdk.ConfigNone, input *sdk.BuildQuickSyncStagesInput) (*sdk.BuildQuickSyncStagesResponse, error)

func (*Plugin) DetermineStrategy added in v0.51.0 

func (p *Plugin) DetermineStrategy(context.Context, *sdk.ConfigNone, *sdk.Client, *sdk.DetermineStrategyInput) (*sdk.DetermineStrategyResponse, error)

FIXME

func (*Plugin) DetermineVersions added in v0.51.0 

func (p *Plugin) DetermineVersions(ctx context.Context, _ *sdk.ConfigNone, _ *sdk.Client, input *sdk.DetermineVersionsInput) (*sdk.DetermineVersionsResponse, error)

func (*Plugin) ExecuteStage added in v0.51.0 

func (p *Plugin) ExecuteStage(ctx context.Context, _ *sdk.ConfigNone, dts []*sdk.DeployTarget[kubeconfig.KubernetesDeployTargetConfig], input *sdk.ExecuteStageInput) (*sdk.ExecuteStageResponse, error)

FIXME

func (*Plugin) FetchDefinedStages added in v0.51.0 

func (p *Plugin) FetchDefinedStages() []string

func (*Plugin) Name added in v0.51.0 

func (p *Plugin) Name() string

func (*Plugin) Version added in v0.51.0 

func (p *Plugin) Version() string

type Stage 

type Stage string
const (
	// StageK8sSync represents the state where
	// all resources should be synced with the Git state.
	StageK8sSync Stage = "K8S_SYNC"
	// StageK8sPrimaryRollout represents the state where
	// the PRIMARY variant resources has been updated to the new version/configuration.
	StageK8sPrimaryRollout Stage = "K8S_PRIMARY_ROLLOUT"
	// StageK8sCanaryRollout represents the state where
	// the CANARY variant resources has been rolled out with the new version/configuration.
	StageK8sCanaryRollout Stage = "K8S_CANARY_ROLLOUT"
	// StageK8sCanaryClean represents the state where
	// the CANARY variant resources has been cleaned.
	StageK8sCanaryClean Stage = "K8S_CANARY_CLEAN"
	// StageK8sBaselineRollout represents the state where
	// the BASELINE variant resources has been rolled out.
	StageK8sBaselineRollout Stage = "K8S_BASELINE_ROLLOUT"
	// StageK8sBaselineClean represents the state where
	// the BASELINE variant resources has been cleaned.
	StageK8sBaselineClean Stage = "K8S_BASELINE_CLEAN"
	// StageK8sTrafficRouting represents the state where the traffic to application
	// should be splitted as the specified percentage to PRIMARY, CANARY, BASELINE variants.
	StageK8sTrafficRouting Stage = "K8S_TRAFFIC_ROUTING"
	// StageK8sRollback represents the state where all deployed resources should be rollbacked.
	StageK8sRollback Stage = "K8S_ROLLBACK"
)

func (Stage) String 

func (s Stage) String() string

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.