pipeline

Documentation

Index

• func CreateDefaultPipeline(ctx context.Context, scheme *runtime.Scheme, cfg *v1alpha1.OperatorConfig, ...) (*pipeline.CapsulePipeline, error)
• func GetDefaultPipelineSteps(_ context.Context, cfg *v1alpha1.OperatorConfig, pluginManager *plugin.Manager, ...) ([]pipeline.Step[pipeline.CapsuleRequest], error)
• func NewCapsulePluginStep(pluginName, pluginConfig string, pluginManager *plugin.Manager, ...) (pipeline.Step[pipeline.CapsuleRequest], error)
• type PluginUsed
• type Service
  • func NewService(cfg *v1alpha1.OperatorConfig, client client.Client, ...) Service

Functions

func CreateDefaultPipeline

func CreateDefaultPipeline(
	ctx context.Context,
	scheme *runtime.Scheme,
	cfg *v1alpha1.OperatorConfig,
	pluginManager *plugin.Manager,
	logger logr.Logger,
) (*pipeline.CapsulePipeline, error)

func GetDefaultPipelineSteps

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

func NewCapsulePluginStep

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

Types

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

func NewService

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