plugin

Documentation

Index

• Variables
• func Initialize(l log.Logger) (*models.PluginRepository, error)
• func InstallPlugins(conf *config.ServerConfig) error
• type Assets
• type EvaluatorFactory
• type IPluginManager
• type PluginGetter
• type PluginManager
  • func NewPluginManager(logLevel config.LogLevel) *PluginManager
  • func (p *PluginManager) Archive(archiveName string) error
  • func (p *PluginManager) Install(dst string, sources ...string) error
  • func (p *PluginManager) UnArchive(src, dest string) error
• type PluginService
  • func NewPluginService(logger log.Logger, pluginGetter PluginGetter, ...) (*PluginService, error)
  • func (s PluginService) ConstructDestinationURN(_ context.Context, taskName string, compiledConfig map[string]string) (resource.URN, error)
  • func (s PluginService) IdentifyUpstreams(ctx context.Context, taskName string, compiledConfig, assets map[string]string) ([]resource.URN, error)
  • func (s PluginService) Info(_ context.Context, taskName string) (*plugin.Info, error)
• type UpstreamIdentifierFactory

Variables

var (
	// for plugin installation, discovery & sync on both client and server
	PluginsDir         = ".plugins"
	PluginsArchiveName = "yaml-plugins.zip"
)

Functions

func Initialize

func Initialize(l log.Logger) (*models.PluginRepository, error)

func InstallPlugins

func InstallPlugins(conf *config.ServerConfig) error

used during server start also exposed as cmd

Types

type Assets

type Assets map[string]string

type EvaluatorFactory

type EvaluatorFactory interface {
	GetFileEvaluator(filepath string) (evaluator.Evaluator, error)
	GetYamlPathEvaluator(filepath, selector string) (evaluator.Evaluator, error)
}

type IPluginManager

type IPluginManager interface {
	Install(dst string, sources ...string) error
	Archive(name string) error
	UnArchive(src, dest string) error
}

type PluginGetter

type PluginGetter interface {
	GetByName(name string) (*plugin.Plugin, error)
}

type PluginManager

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

func NewPluginManager

func NewPluginManager(logLevel config.LogLevel) *PluginManager

func (*PluginManager) Archive

func (p *PluginManager) Archive(archiveName string) error

func (*PluginManager) Install

func (p *PluginManager) Install(dst string, sources ...string) error

func (*PluginManager) UnArchive

func (p *PluginManager) UnArchive(src, dest string) error

type PluginService

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

func NewPluginService

func NewPluginService(logger log.Logger, pluginGetter PluginGetter, upstreamIdentifierFactory UpstreamIdentifierFactory, evaluatorFactory EvaluatorFactory) (*PluginService, error)

func (PluginService) ConstructDestinationURN

func (s PluginService) ConstructDestinationURN(_ context.Context, taskName string, compiledConfig map[string]string) (resource.URN, error)

func (PluginService) IdentifyUpstreams

func (s PluginService) IdentifyUpstreams(ctx context.Context, taskName string, compiledConfig, assets map[string]string) ([]resource.URN, error)

func (PluginService) Info

func (s PluginService) Info(_ context.Context, taskName string) (*plugin.Info, error)

type UpstreamIdentifierFactory

type UpstreamIdentifierFactory interface {
	GetBQUpstreamIdentifier(ctx context.Context, svcAcc string, evaluators ...evaluator.Evaluator) (upstreamidentifier.UpstreamIdentifier, error)
}