discovery

type Discoverer ¶

type Discoverer interface {
	Discover(ctx context.Context, src plugins.PluginSource) ([]*plugins.FoundBundle, error)
}

Discoverer is responsible for the Discovery stage of the plugin loader pipeline.

type Discovery ¶

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

Discovery implements the Discoverer interface.

The Discovery stage is made up of the following steps (in order): - Find: Find plugins (from disk, remote, etc.) - Filter: Filter the results based on some criteria.

The Find step is implemented by the FindFunc type.

The Filter step is implemented by the FindFilterFunc type.

func New(cfg *config.Cfg, opts Opts) *Discovery

func (d *Discovery) Discover(ctx context.Context, src plugins.PluginSource) ([]*plugins.FoundBundle, error)

type DuplicatePluginValidation ¶

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

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

func NewDuplicatePluginFilterStep(registry registry.Service) *DuplicatePluginValidation

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

type FindFilterFunc ¶

type FindFilterFunc func(ctx context.Context, class plugins.Class, bundles []*plugins.FoundBundle) ([]*plugins.FoundBundle, error)

FindFilterFunc is the function used for the Filter step of the Discovery stage.

func NewPermittedPluginTypesFilterStep(permittedTypes []plugins.Type) FindFilterFunc

type FindFunc ¶

type FindFunc func(ctx context.Context, src plugins.PluginSource) ([]*plugins.FoundBundle, error)

FindFunc is the function used for the Find step of the Discovery stage.

func DefaultFindFunc(cfg *config.Cfg) FindFunc

type Opts ¶

type Opts struct {
	FindFunc        FindFunc
	FindFilterFuncs []FindFilterFunc
}

type PermittedPluginTypesFilter ¶

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

PermittedPluginTypesFilter is a filter step that will filter out any plugins that are not of a permitted type.

func (n *PermittedPluginTypesFilter) Filter(_ context.Context, _ plugins.Class, bundles []*plugins.FoundBundle) ([]*plugins.FoundBundle, error)