plugin

Sep 13, 2024

Changes in this version

type Manager

+ GetVersionForBuiltInPlugins func(ctx context.Context) (string, error)

type MockManager

+ func (_m *MockManager) GetVersionForBuiltInPlugins(ctx context.Context) (string, error)

Aug 15, 2024

Changes in this version

+ func AreProtocolsSupported(protocols []string) error

+ type Installer interface

+ EnsureLatestVersion func(ctx context.Context, source string, opts ...InstallerOption) (string, error)

+ InstallPlugin func(ctx context.Context, source, version string, opts ...InstallerOption) error

+ func NewInstaller(logger hclog.Logger, defaultRegistryURL string) (Installer, error)

+ type InstallerOption func(*installerOptions)

+ func WithConstraints(constraints *string) InstallerOption

+ func WithToken(token *string) InstallerOption

+ type LaunchOption func(*launchOptions)

+ func WithBinaryPath(path string) LaunchOption

+ func WithDir(dir string) LaunchOption

+ func WithVersion(version string) LaunchOption

+ type Manager interface

+ Close func()

+ GetPlugin func(name string) (*PipelinePlugin, error)

+ GetPlugins func() []*PipelinePlugin

+ LaunchPlugin func(ctx context.Context, source string, options ...LaunchOption) error

+ func New(logger hclog.Logger) Manager

+ type MockManager struct

+ func NewMockManager(t mockConstructorTestingTNewMockManager) *MockManager

+ func (_m *MockManager) Close()

+ func (_m *MockManager) GetPlugin(name string) (*PipelinePlugin, error)

+ func (_m *MockManager) GetPlugins() []*PipelinePlugin

+ func (_m *MockManager) LaunchPlugin(ctx context.Context, source string, options ...LaunchOption) error

+ type PipelinePlugin struct

+ func NewPipelinePlugin(instance component.PipelinePlugin, log hclog.Logger, close func()) *PipelinePlugin

+ func (p *PipelinePlugin) Close()

+ func (p *PipelinePlugin) Configure(ctx context.Context, body hcl.Body, evalCtx *hcl.EvalContext) hcl.Diagnostics

+ func (p *PipelinePlugin) ExecuteAction(ctx context.Context, actionName string, body hcl.Body, ...) (map[string]cty.Value, error)

+ func (p *PipelinePlugin) GetImpliedActionOutputs(ctx context.Context, actionName string) (map[string]cty.Value, error)

+ func (p *PipelinePlugin) GracefulShutdown(ctx context.Context) error

+ func (p *PipelinePlugin) ValidateActionInput(ctx context.Context, actionName string, body hcl.Body, ...) hcl.Diagnostics

+ func (p *PipelinePlugin) ValidateConfig(ctx context.Context, body hcl.Body, evalCtx *hcl.EvalContext) hcl.Diagnostics

+ type RegistryPluginDownloadResponse struct

+ Arch string

+ DownloadURL string

+ Filename string

+ OperatingSystem string

+ Protocols []string

+ SHASum string

+ SHASumsURL string

+ type RegistryPluginPlatform struct

+ Arch string

+ OperatingSystem string

+ type RegistryPluginVersion struct

+ Platforms []RegistryPluginPlatform

+ Protocols []string

+ Version string

+ type RegistryPluginVersionList struct

+ Versions []RegistryPluginVersion

+ type Source struct

+ Hostname svchost.Hostname

+ Name string

+ Organization string

+ func ParseSource(s string, defaultRegistryURL *string) (*Source, error)

+ func (s *Source) String() string