pipeline

package

v1.11.2 Latest Latest Go to latest Published: Aug 12, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rigdev/rig

Links

Open Source Insights

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, ...) (pipeline.Step[pipeline.CapsuleRequest], error)
type PluginUsed
type Service
- func NewService(cfg *v1alpha1.OperatorConfig, client client.Client, ...) Service

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateDefaultPipeline ¶ added in v1.9.0

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 ¶ added in v1.9.0

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

func NewCapsulePluginStep ¶ added in v1.9.0

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

func NewRigPlatformCapsulePluginStep ¶ added in v1.11.2

func NewRigPlatformCapsulePluginStep(
	execCtx plugin.ExecutionContext,
	pluginName 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,
	sh fx.Shutdowner,
) Service

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL