pipeline

Documentation

Index

• func ExternalServiceRegistrationStep(cfg *config.PluginManagementCfg, ...) initialization.InitializeFunc
• func ProvideBootstrapStage(cfg *config.PluginManagementCfg, sc plugins.SignatureCalculator, ...) *bootstrap.Bootstrap
• func ProvideDiscoveryStage(cfg *config.PluginManagementCfg, pf finder.Finder, pr registry.Service) *discovery.Discovery
• func ProvideInitializationStage(cfg *config.PluginManagementCfg, pr registry.Service, ...) *initialization.Initialize
• func ProvideTerminationStage(cfg *config.PluginManagementCfg, pr registry.Service, pm process.Manager) (*termination.Terminate, error)
• func ProvideValidationStage(cfg *config.PluginManagementCfg, sv signature.Validator, ...) *validation.Validate
• func RegisterPluginRolesStep(roleRegistry plugins.RoleRegistry) initialization.InitializeFunc
• func ReportBuildMetrics(_ context.Context, p *plugins.Plugin) (*plugins.Plugin, error)
• func SignatureValidationStep(signatureValidator signature.Validator) validation.ValidateFunc
• type AsExternal
  • func NewAsExternalStep(cfg *config.PluginManagementCfg) *AsExternal
  • func (c *AsExternal) Filter(cl plugins.Class, bundles []*plugins.FoundBundle) ([]*plugins.FoundBundle, error)
• type DisablePlugins
  • func NewDisablePluginsStep(cfg *config.PluginManagementCfg) *DisablePlugins
  • func (c *DisablePlugins) Filter(bundles []*plugins.FoundBundle) ([]*plugins.FoundBundle, error)
• type DuplicatePluginIDValidation
  • func NewDuplicatePluginIDFilterStep(registry registry.Service) *DuplicatePluginIDValidation
  • func (d *DuplicatePluginIDValidation) Filter(ctx context.Context, bundles []*plugins.FoundBundle) ([]*plugins.FoundBundle, error)
• type ExternalServiceRegistration
  • func (r *ExternalServiceRegistration) Register(ctx context.Context, p *plugins.Plugin) (*plugins.Plugin, error)
• type RegisterPluginRoles
  • func (r *RegisterPluginRoles) Register(ctx context.Context, p *plugins.Plugin) (*plugins.Plugin, error)
• type SignatureValidation
  • func (v *SignatureValidation) Validate(ctx context.Context, p *plugins.Plugin) error

Functions

func ExternalServiceRegistrationStep

func ExternalServiceRegistrationStep(cfg *config.PluginManagementCfg, externalServiceRegistry auth.ExternalServiceRegistry, tracer tracing.Tracer) initialization.InitializeFunc

ExternalServiceRegistrationStep returns an InitializeFunc for registering external services.

func ProvideBootstrapStage

func ProvideBootstrapStage(cfg *config.PluginManagementCfg, sc plugins.SignatureCalculator, a *assetpath.Service) *bootstrap.Bootstrap

func ProvideDiscoveryStage

func ProvideDiscoveryStage(cfg *config.PluginManagementCfg, pf finder.Finder, pr registry.Service) *discovery.Discovery

func ProvideInitializationStage

func ProvideInitializationStage(cfg *config.PluginManagementCfg, pr registry.Service, bp plugins.BackendFactoryProvider,
	pm process.Manager, externalServiceRegistry auth.ExternalServiceRegistry,
	roleRegistry plugins.RoleRegistry, pluginEnvProvider envvars.Provider, tracer tracing.Tracer) *initialization.Initialize

func ProvideTerminationStage

func ProvideTerminationStage(cfg *config.PluginManagementCfg, pr registry.Service, pm process.Manager) (*termination.Terminate, error)

func ProvideValidationStage

func ProvideValidationStage(cfg *config.PluginManagementCfg, sv signature.Validator, ai angularinspector.Inspector) *validation.Validate

func RegisterPluginRolesStep

func RegisterPluginRolesStep(roleRegistry plugins.RoleRegistry) initialization.InitializeFunc

RegisterPluginRolesStep returns a new InitializeFunc for registering plugin roles.

func ReportBuildMetrics

func ReportBuildMetrics(_ context.Context, p *plugins.Plugin) (*plugins.Plugin, error)

ReportBuildMetrics reports build information for all plugins, except core and bundled plugins.

func SignatureValidationStep

func SignatureValidationStep(signatureValidator signature.Validator) validation.ValidateFunc

SignatureValidationStep returns a new ValidateFunc for validating plugin signatures.

Types

type AsExternal

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

AsExternal is a filter step that will skip loading a core plugin to use an external one.

func NewAsExternalStep

func NewAsExternalStep(cfg *config.PluginManagementCfg) *AsExternal

NewAsExternalStep returns a new DisablePlugins.

func (*AsExternal) Filter

func (c *AsExternal) Filter(cl plugins.Class, bundles []*plugins.FoundBundle) ([]*plugins.FoundBundle, error)

Filter will filter out any plugins that are marked to be disabled.

type DisablePlugins

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

DisablePlugins is a filter step that will filter out any configured plugins

func NewDisablePluginsStep

func NewDisablePluginsStep(cfg *config.PluginManagementCfg) *DisablePlugins

NewDisablePluginsStep returns a new DisablePlugins.

func (*DisablePlugins) Filter

func (c *DisablePlugins) Filter(bundles []*plugins.FoundBundle) ([]*plugins.FoundBundle, error)

Filter will filter out any plugins that are marked to be disabled.

type DuplicatePluginIDValidation

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

DuplicatePluginIDValidation is a filter step that will filter out any plugins that are already registered with the same plugin ID. This includes both the primary plugin and child plugins, which are matched using the plugin.json plugin ID field.

func NewDuplicatePluginIDFilterStep

func NewDuplicatePluginIDFilterStep(registry registry.Service) *DuplicatePluginIDValidation

NewDuplicatePluginIDFilterStep returns a new DuplicatePluginIDValidation.

func (*DuplicatePluginIDValidation) Filter

func (d *DuplicatePluginIDValidation) Filter(ctx context.Context, bundles []*plugins.FoundBundle) ([]*plugins.FoundBundle, error)

Filter will filter out any plugins that have already been registered under the same plugin ID.

type ExternalServiceRegistration

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

ExternalServiceRegistration implements an InitializeFunc for registering external services.

func (*ExternalServiceRegistration) Register

func (r *ExternalServiceRegistration) Register(ctx context.Context, p *plugins.Plugin) (*plugins.Plugin, error)

Register registers the external service with the external service registry, if the feature is enabled.

type RegisterPluginRoles

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

RegisterPluginRoles implements an InitializeFunc for registering plugin roles.

func (*RegisterPluginRoles) Register

func (r *RegisterPluginRoles) Register(ctx context.Context, p *plugins.Plugin) (*plugins.Plugin, error)

Register registers the plugin roles with the role registry.

type SignatureValidation

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

SignatureValidation implements a ValidateFunc for validating plugin signatures.

func (*SignatureValidation) Validate

func (v *SignatureValidation) Validate(ctx context.Context, p *plugins.Plugin) error

Validate validates the plugin signature. If a signature error is encountered, the error is recorded with the pluginerrs.ErrorTracker.