planner

Documentation

Index

• Constants
• func GetPredefinedStage(id string) (config.PipelineStage, bool)
• func MakeInitialStageMetadata(cfg config.PipelineStage) map[string]string
• type PlannerService
  • func NewPlannerService(decrypter secretDecrypter, logger *zap.Logger) *PlannerService
  • func (ps *PlannerService) DetermineStrategy(ctx context.Context, in *deployment.DetermineStrategyRequest) (*deployment.DetermineStrategyResponse, error)
  • func (ps *PlannerService) DetermineVersions(ctx context.Context, in *deployment.DetermineVersionsRequest) (*deployment.DetermineVersionsResponse, error)
  • func (a *PlannerService) Register(server *grpc.Server)

Constants

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

Functions

func GetPredefinedStage

func GetPredefinedStage(id string) (config.PipelineStage, bool)

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

func MakeInitialStageMetadata

func MakeInitialStageMetadata(cfg config.PipelineStage) map[string]string

MakeInitialStageMetadata makes the initial metadata for the given state configuration.

Types

type PlannerService

type PlannerService struct {
	deployment.UnimplementedDeploymentServiceServer

	Decrypter secretDecrypter
	RegexPool *regexpool.Pool
	Logger    *zap.Logger
}

func NewPlannerService

func NewPlannerService(
	decrypter secretDecrypter,
	logger *zap.Logger,
) *PlannerService

NewPlannerService creates a new planService.

func (*PlannerService) DetermineStrategy

func (ps *PlannerService) DetermineStrategy(ctx context.Context, in *deployment.DetermineStrategyRequest) (*deployment.DetermineStrategyResponse, error)

func (*PlannerService) DetermineVersions

func (ps *PlannerService) DetermineVersions(ctx context.Context, in *deployment.DetermineVersionsRequest) (*deployment.DetermineVersionsResponse, error)

func (*PlannerService) Register

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

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