connector

Documentation

Index

• type Registry
  • func NewRegistry(configDir string) *Registry
  • func (reg *Registry) AddConnection(id string, name string, connType string, conn model.ConnInterface)
  • func (reg *Registry) AddInstance(inst *model.Instance)
  • func (reg *Registry) CreateInstance(id string, name string, plugin string, config interface{}) model.ConnInterface
  • func (reg *Registry) GetAllInstances() []model.InstanceView
  • func (reg *Registry) GetInstance(id string) *model.Instance
  • func (reg *Registry) LoadInstancesFromDisk() error

Types

type Registry

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

func NewRegistry

func NewRegistry(configDir string) *Registry

func (*Registry) AddConnection

func (reg *Registry) AddConnection(id string, name string, connType string, conn model.ConnInterface)

Adds existing connection as connector instance into the registry

func (*Registry) AddInstance

func (reg *Registry) AddInstance(inst *model.Instance)

Adds existing instance to registry

func (*Registry) CreateInstance

func (reg *Registry) CreateInstance(id string, name string, plugin string, config interface{}) model.ConnInterface

Creates instance of connector using one of registered plugins

func (*Registry) GetAllInstances

func (reg *Registry) GetAllInstances() []model.InstanceView

Returns pointer to existing instance of connector

func (*Registry) GetInstance

func (reg *Registry) GetInstance(id string) *model.Instance

Returns pointer to existing instance of connector

func (*Registry) LoadInstancesFromDisk

func (reg *Registry) LoadInstancesFromDisk() error