pipeline

Documentation

Index

• func CreateDefaultPipeline(execCtx plugin.ExecutionContext, scheme *runtime.Scheme, ...) (*pipeline.CapsulePipeline, error)
• func GetDefaultPipelineSteps(execCtx plugin.ExecutionContext, cfg *v1alpha1.OperatorConfig, ...) ([]pipeline.Step[pipeline.CapsuleRequest], error)
• func NewCapsulePluginStep(execCtx plugin.ExecutionContext, pluginName, pluginConfig string, ...) (pipeline.Step[pipeline.CapsuleRequest], error)
• func NewRigPlatformCapsulePluginStep(execCtx plugin.ExecutionContext, pluginName string, pluginConfig string, ...) (pipeline.Step[pipeline.CapsuleRequest], error)
• type CapsuleExtensionStep
  • func NewCapsuleExtensionStep(name string, step pipeline.Step[pipeline.CapsuleRequest]) *CapsuleExtensionStep
  • func (s *CapsuleExtensionStep) Apply(ctx context.Context, req pipeline.CapsuleRequest, opts pipeline.Options) error
  • func (s *CapsuleExtensionStep) ComputeConfig(ctx context.Context, req pipeline.CapsuleRequest) pipeline.StepConfigResult
  • func (s *CapsuleExtensionStep) Name() string
  • func (s *CapsuleExtensionStep) PluginIDs() []uuid.UUID
  • func (s *CapsuleExtensionStep) WatchObjectStatus(ctx context.Context, capsule *v1alpha2.Capsule, ...) error
• type CapsuleExtensionValidationStep
  • func NewCapsuleExtensionValidationStep(cfg *v1alpha1.OperatorConfig) *CapsuleExtensionValidationStep
  • func (s *CapsuleExtensionValidationStep) Apply(_ context.Context, req pipeline.CapsuleRequest, _ pipeline.Options) error
  • func (s *CapsuleExtensionValidationStep) ComputeConfig(_ context.Context, _ pipeline.CapsuleRequest) pipeline.StepConfigResult
  • func (s *CapsuleExtensionValidationStep) Name() string
  • func (s *CapsuleExtensionValidationStep) PluginIDs() []uuid.UUID
  • func (s *CapsuleExtensionValidationStep) WatchObjectStatus(_ context.Context, _ *v1alpha2.Capsule, _ pipeline.ObjectStatusCallback) error
• type PluginUsed
• type Service
  • func NewService(cfg *v1alpha1.OperatorConfig, client client.Client, ...) Service

Functions

func CreateDefaultPipeline

func CreateDefaultPipeline(
	execCtx plugin.ExecutionContext,
	scheme *runtime.Scheme,
	vm scheme.VersionMapper,
	cfg *v1alpha1.OperatorConfig,
	pluginManager *plugin.Manager,
	logger logr.Logger,
) (*pipeline.CapsulePipeline, error)

func GetDefaultPipelineSteps

func GetDefaultPipelineSteps(
	execCtx plugin.ExecutionContext,
	cfg *v1alpha1.OperatorConfig,
	pluginManager *plugin.Manager,
	logger logr.Logger,
) ([]pipeline.Step[pipeline.CapsuleRequest], error)

func NewCapsulePluginStep

func NewCapsulePluginStep(
	execCtx plugin.ExecutionContext,
	pluginName, pluginConfig string,
	pluginManager *plugin.Manager,
	logger logr.Logger,
	enableForPlatform bool,
) (pipeline.Step[pipeline.CapsuleRequest], error)

func NewRigPlatformCapsulePluginStep

func NewRigPlatformCapsulePluginStep(
	execCtx plugin.ExecutionContext,
	pluginName string,
	pluginConfig string,
	pluginManager *plugin.Manager,
	logger logr.Logger,
) (pipeline.Step[pipeline.CapsuleRequest], error)

Types

type CapsuleExtensionStep

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

func NewCapsuleExtensionStep

func NewCapsuleExtensionStep(name string, step pipeline.Step[pipeline.CapsuleRequest]) *CapsuleExtensionStep

func (*CapsuleExtensionStep) Apply

func (s *CapsuleExtensionStep) Apply(ctx context.Context, req pipeline.CapsuleRequest, opts pipeline.Options) error

func (*CapsuleExtensionStep) ComputeConfig

func (s *CapsuleExtensionStep) ComputeConfig(
	ctx context.Context, req pipeline.CapsuleRequest,
) pipeline.StepConfigResult

func (*CapsuleExtensionStep) Name

func (s *CapsuleExtensionStep) Name() string

func (*CapsuleExtensionStep) PluginIDs

func (s *CapsuleExtensionStep) PluginIDs() []uuid.UUID

func (*CapsuleExtensionStep) WatchObjectStatus

func (s *CapsuleExtensionStep) WatchObjectStatus(
	ctx context.Context, capsule *v1alpha2.Capsule, callback pipeline.ObjectStatusCallback,
) error

type CapsuleExtensionValidationStep

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

func NewCapsuleExtensionValidationStep

func NewCapsuleExtensionValidationStep(cfg *v1alpha1.OperatorConfig) *CapsuleExtensionValidationStep

func (*CapsuleExtensionValidationStep) Apply

func (s *CapsuleExtensionValidationStep) Apply(
	_ context.Context, req pipeline.CapsuleRequest, _ pipeline.Options,
) error

func (*CapsuleExtensionValidationStep) ComputeConfig

func (s *CapsuleExtensionValidationStep) ComputeConfig(
	_ context.Context, _ pipeline.CapsuleRequest,
) pipeline.StepConfigResult

func (*CapsuleExtensionValidationStep) Name

func (s *CapsuleExtensionValidationStep) Name() string

func (*CapsuleExtensionValidationStep) PluginIDs

func (s *CapsuleExtensionValidationStep) PluginIDs() []uuid.UUID

func (*CapsuleExtensionValidationStep) WatchObjectStatus

func (s *CapsuleExtensionValidationStep) WatchObjectStatus(
	_ context.Context, _ *v1alpha2.Capsule, _ pipeline.ObjectStatusCallback,
) error

type PluginUsed

type PluginUsed struct {
	Namespace string
	Capsule   string
	Plugin    string
}

type Service

type Service interface {
	GetDefaultPipeline() *pipeline.CapsulePipeline
	DryRun(ctx context.Context,
		cfg *v1alpha1.OperatorConfig,
		namespace, capsuleName string,
		spec *v1alpha2.Capsule,
		opts ...pipeline.CapsuleRequestOption) (*pipeline.Result, error)
	DryRunPluginConfig(ctx context.Context,
		cfg *v1alpha1.OperatorConfig,
		namespace, capsuleName string,
		capsuleSpec *v1alpha2.Capsule,
	) (pipeline.PluginConfigResult, error)
}

func NewService

func NewService(
	cfg *v1alpha1.OperatorConfig,
	client client.Client,
	capSvc capabilities.Service,
	logger logr.Logger,
	pluginManager *plugin.Manager,
	lc fx.Lifecycle,
	sh fx.Shutdowner,
) Service