plugin

Documentation

Index

• Constants
• type Manager
  • func NewManager(logger hclog.Logger, pluginDirectory string, registryURL string, ...) (*Manager, error)
  • func (m *Manager) ClosePlugin(p Plugin)
  • func (m *Manager) CreatePlugin(providerName, alias string, env []string) (Plugin, error)
  • func (m *Manager) DownloadProviders(ctx context.Context, providers []*config.RequiredProvider, noVerify bool) error
  • func (m *Manager) GetPluginDetails(providerName string) (registry.ProviderDetails, error)
  • func (m *Manager) LoadExisting(providers []*config.RequiredProvider)
  • func (m *Manager) Shutdown()
• type Plugin

Constants

const (
	Unmanaged = "unmanaged"
)

Types

type Manager

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

Manager handles lifecycle execution of CloudQuery providers

func NewManager

func NewManager(logger hclog.Logger, pluginDirectory string, registryURL string, updater ui.Progress) (*Manager, error)

func (*Manager) ClosePlugin

func (m *Manager) ClosePlugin(p Plugin)

func (*Manager) CreatePlugin

func (m *Manager) CreatePlugin(providerName, alias string, env []string) (Plugin, error)

func (*Manager) DownloadProviders

func (m *Manager) DownloadProviders(ctx context.Context, providers []*config.RequiredProvider, noVerify bool) error

func (*Manager) GetPluginDetails

func (m *Manager) GetPluginDetails(providerName string) (registry.ProviderDetails, error)

func (*Manager) LoadExisting

func (m *Manager) LoadExisting(providers []*config.RequiredProvider)

LoadExisting loads existing providers that are found by the hub in ProviderDirectory

func (*Manager) Shutdown

func (m *Manager) Shutdown()

Shutdown closes all clients and cleans the managed clients

type Plugin

type Plugin interface {
	Name() string
	Version() string
	ProtocolVersion() int
	Provider() cqproto.CQProvider
	Close()
}