deployment

Documentation

Index

• Constants
• Variables
• func GetPredefinedStage(id string) (*model.PipelineStage, bool)
• type DeploymentService
  • func NewDeploymentService(logger *zap.Logger) *DeploymentService
  • func (a *DeploymentService) BuildPipelineSyncStages(ctx context.Context, request *deployment.BuildPipelineSyncStagesRequest) (*deployment.BuildPipelineSyncStagesResponse, error)
  • func (a *DeploymentService) BuildQuickSyncStages(ctx context.Context, request *deployment.BuildQuickSyncStagesRequest) (*deployment.BuildQuickSyncStagesResponse, error)
  • func (a *DeploymentService) DetermineStrategy(ctx context.Context, request *deployment.DetermineStrategyRequest) (*deployment.DetermineStrategyResponse, error)
  • func (a *DeploymentService) DetermineVersions(ctx context.Context, request *deployment.DetermineVersionsRequest) (*deployment.DetermineVersionsResponse, error)
  • func (a *DeploymentService) ExecuteStage(ctx context.Context, request *deployment.ExecuteStageRequest) (*deployment.ExecuteStageResponse, error)
  • func (a *DeploymentService) FetchDefinedStages(context.Context, *deployment.FetchDefinedStagesRequest) (*deployment.FetchDefinedStagesResponse, error)
  • func (a *DeploymentService) Register(server *grpc.Server)
• type Stage
  • func (s Stage) String() string

Constants

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

Variables

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

Functions

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

	RegexPool    *regexpool.Pool
	Logger       *zap.Logger
	ToolRegistry toolRegistry
	Loader       loader
	LogPersister logPersister
}

func NewDeploymentService

func NewDeploymentService(
	logger *zap.Logger,
) *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) (*deployment.ExecuteStageResponse, error)

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 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