registry

Documentation

Overview

Package registry is the central hub for Drivers and other types that follow the init-time registration.

Index

• Variables
• func ConfigRegs(ctx types.Context) <-chan gofig.ConfigRegistration
• func IntegrationDrivers() <-chan types.IntegrationDriver
• func NewIntegrationDriver(name string) (types.IntegrationDriver, error)
• func NewIntegrationDriverManager(d types.IntegrationDriver) types.IntegrationDriver
• func NewOSDriver(name string) (types.OSDriver, error)
• func NewOSDriverManager(d types.OSDriver) types.OSDriver
• func NewStorageDriver(name string) (types.StorageDriver, error)
• func NewStorageExecutor(name string) (types.StorageExecutor, error)
• func OSDrivers() <-chan types.OSDriver
• func ProcessRegisteredConfigs(ctx types.Context)
• func RegisterConfigReg(name string, f types.NewConfigReg)
• func RegisterIntegrationDriver(name string, ctor types.NewIntegrationDriver)
• func RegisterOSDriver(name string, ctor types.NewOSDriver)
• func RegisterRouter(router types.Router)
• func RegisterStorageDriver(name string, ctor types.NewStorageDriver)
• func RegisterStorageExecutor(name string, ctor types.NewStorageExecutor)
• func Routers() <-chan types.Router
• func StorageDrivers() <-chan types.StorageDriver
• func StorageExecutors() <-chan types.StorageExecutor

Variables

var NewConfig = gofig.New

NewConfig is a function that returns a new Config object.

var NewConfigReg = gofig.NewRegistration

NewConfigReg is a function that returns a new ConfigRegistration object.

Functions

func ConfigRegs

func ConfigRegs(ctx types.Context) <-chan gofig.ConfigRegistration

ConfigRegs returns a channel on which all registered configuration registrations are returned.

func IntegrationDrivers

func IntegrationDrivers() <-chan types.IntegrationDriver

IntegrationDrivers returns a channel on which new instances of all registered integration drivers can be received.

func NewIntegrationDriver

func NewIntegrationDriver(name string) (types.IntegrationDriver, error)

NewIntegrationDriver returns a new instance of the driver specified by the driver name.

func NewIntegrationDriverManager

func NewIntegrationDriverManager(
	d types.IntegrationDriver) types.IntegrationDriver

NewIntegrationDriverManager returns a new integration driver manager.

func NewOSDriver

func NewOSDriver(name string) (types.OSDriver, error)

NewOSDriver returns a new instance of the driver specified by the driver name.

func NewOSDriverManager

func NewOSDriverManager(
	d types.OSDriver) types.OSDriver

NewOSDriverManager returns a new OS driver manager.

func NewStorageDriver

func NewStorageDriver(name string) (types.StorageDriver, error)

NewStorageDriver returns a new instance of the driver specified by the driver name.

func NewStorageExecutor

func NewStorageExecutor(name string) (types.StorageExecutor, error)

NewStorageExecutor returns a new instance of the executor specified by the executor name.

func OSDrivers

func OSDrivers() <-chan types.OSDriver

OSDrivers returns a channel on which new instances of all registered OS drivers can be received.

func ProcessRegisteredConfigs

func ProcessRegisteredConfigs(ctx types.Context)

ProcessRegisteredConfigs processes the registered configuration requests.

func RegisterConfigReg

func RegisterConfigReg(name string, f types.NewConfigReg)

RegisterConfigReg registers a new configuration registration request.

func RegisterIntegrationDriver

func RegisterIntegrationDriver(name string, ctor types.NewIntegrationDriver)

RegisterIntegrationDriver registers a IntegrationDriver.

func RegisterOSDriver

func RegisterOSDriver(name string, ctor types.NewOSDriver)

RegisterOSDriver registers a OSDriver.

func RegisterRouter

func RegisterRouter(router types.Router)

RegisterRouter registers a Router.

func RegisterStorageDriver

func RegisterStorageDriver(
	name string, ctor types.NewStorageDriver)

RegisterStorageDriver registers a StorageDriver.

func RegisterStorageExecutor

func RegisterStorageExecutor(name string, ctor types.NewStorageExecutor)

RegisterStorageExecutor registers a StorageExecutor.

func Routers

func Routers() <-chan types.Router

Routers returns a channel on which new instances of all registered routers can be received.

func StorageDrivers

func StorageDrivers() <-chan types.StorageDriver

StorageDrivers returns a channel on which new instances of all registered remote storage drivers can be received.

func StorageExecutors

func StorageExecutors() <-chan types.StorageExecutor

StorageExecutors returns a channel on which new instances of all registered storage executors can be received.