plugin

Documentation

Index

• Constants
• func GetProviderPath(details *registry.ProviderDetails) (string, error)
• type Manager
  • func NewManager() (*Manager, error)
  • func (p *Manager) GetOrCreateProvider(details *registry.ProviderDetails) (cqproto.CQProvider, error)
  • func (p *Manager) GetProvider(providerName, version string) (cqproto.CQProvider, error)
  • func (p *Manager) KillProvider(providerName string) error
  • func (p *Manager) ListUnmanaged() map[string]registry.ProviderDetails
  • func (p *Manager) Shutdown()
• type Plugin

Constants

const (
	DefaultOrganization = "cloudquery"
)

Functions

func GetProviderPath

func GetProviderPath(details *registry.ProviderDetails) (string, error)

GetProviderPath returns expected path of provider on file system from name and version of plugin

Types

type Manager

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

Manager handles lifecycle execution of CloudQuery providers

func NewManager

func NewManager() (*Manager, error)

func (*Manager) GetOrCreateProvider

func (p *Manager) GetOrCreateProvider(details *registry.ProviderDetails) (cqproto.CQProvider, error)

func (*Manager) GetProvider

func (p *Manager) GetProvider(providerName, version string) (cqproto.CQProvider, error)

func (*Manager) KillProvider

func (p *Manager) KillProvider(providerName string) error

func (*Manager) ListUnmanaged

func (p *Manager) ListUnmanaged() map[string]registry.ProviderDetails

func (*Manager) Shutdown

func (p *Manager) Shutdown()

Shutdown closes all clients and cleans the managed clients

type Plugin

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