managers

Documentation

Index

• func GetConfigProvider(con ManagerConfig, providers map[string]providers.IProvider) (config.IConfigProvider, error)
• func GetExtConfigProvider(con ManagerConfig, providers map[string]providers.IProvider) (config.IExtConfigProvider, error)
• func GetKeyLockProvider(config ManagerConfig, providers map[string]providers.IProvider) (keylock.IKeyLockProvider, error)
• func GetLedgerProvider(config ManagerConfig, providers map[string]providers.IProvider) (ledger.ILedgerProvider, error)
• func GetPersistentStateProvider(config ManagerConfig, providers map[string]providers.IProvider) (states.IStateProvider, error)
• func GetProbeProvider(config ManagerConfig, providers map[string]providers.IProvider) (probe.IProbeProvider, error)
• func GetQueueProvider(config ManagerConfig, providers map[string]providers.IProvider) (queue.IQueueProvider, error)
• func GetReferenceProvider(config ManagerConfig, providers map[string]providers.IProvider) (reference.IReferenceProvider, error)
• func GetReporter(config ManagerConfig, providers map[string]providers.IProvider) (reporter.IReporter, error)
• func GetSecretProvider(con ManagerConfig, providers map[string]providers.IProvider) (secret.ISecretProvider, error)
• func GetUploaderProvider(config ManagerConfig, providers map[string]providers.IProvider) (uploader.IUploader, error)
• func GetVolatileStateProvider(config ManagerConfig, providers map[string]providers.IProvider) (states.IStateProvider, error)
• func NeedObjectValidate(config ManagerConfig, providers map[string]providers.IProvider) bool
• type IEntityManager
• type IManager
• type IManagerFactroy
• type ISchedulable
• type Manager
  • func (m *Manager) Init(context *contexts.VendorContext, config ManagerConfig, ...) error
  • func (m *Manager) Shutdown(ctx context.Context) error
• type ManagerConfig
• type ProviderConfig

Functions

func GetConfigProvider

func GetConfigProvider(con ManagerConfig, providers map[string]providers.IProvider) (config.IConfigProvider, error)

func GetExtConfigProvider

func GetExtConfigProvider(con ManagerConfig, providers map[string]providers.IProvider) (config.IExtConfigProvider, error)

func GetKeyLockProvider

func GetKeyLockProvider(config ManagerConfig, providers map[string]providers.IProvider) (keylock.IKeyLockProvider, error)

func GetLedgerProvider

func GetLedgerProvider(config ManagerConfig, providers map[string]providers.IProvider) (ledger.ILedgerProvider, error)

func GetPersistentStateProvider

func GetPersistentStateProvider(config ManagerConfig, providers map[string]providers.IProvider) (states.IStateProvider, error)

func GetProbeProvider

func GetProbeProvider(config ManagerConfig, providers map[string]providers.IProvider) (probe.IProbeProvider, error)

func GetQueueProvider

func GetQueueProvider(config ManagerConfig, providers map[string]providers.IProvider) (queue.IQueueProvider, error)

func GetReferenceProvider

func GetReferenceProvider(config ManagerConfig, providers map[string]providers.IProvider) (reference.IReferenceProvider, error)

func GetReporter

func GetReporter(config ManagerConfig, providers map[string]providers.IProvider) (reporter.IReporter, error)

func GetSecretProvider

func GetSecretProvider(con ManagerConfig, providers map[string]providers.IProvider) (secret.ISecretProvider, error)

func GetUploaderProvider

func GetUploaderProvider(config ManagerConfig, providers map[string]providers.IProvider) (uploader.IUploader, error)

func GetVolatileStateProvider

func GetVolatileStateProvider(config ManagerConfig, providers map[string]providers.IProvider) (states.IStateProvider, error)

func NeedObjectValidate

func NeedObjectValidate(config ManagerConfig, providers map[string]providers.IProvider) bool

Types

type IEntityManager

type IEntityManager interface {
	Init(context *contexts.VendorContext, config ManagerConfig, providers map[string]providers.IProvider) error
}

type IManager

type IManager interface {
	Init(context *contexts.VendorContext, config ManagerConfig, providers map[string]providers.IProvider) error
	v1alpha2.Terminable
}

type IManagerFactroy

type IManagerFactroy interface {
	CreateManager(config ManagerConfig) (IManager, error)
}

type ISchedulable

type ISchedulable interface {
	Poll() []error
	Reconcil() []error
	Enabled() bool
}

type Manager

type Manager struct {
	VendorContext *contexts.VendorContext
	Context       *contexts.ManagerContext
	Config        ManagerConfig
}

func (*Manager) Init

func (m *Manager) Init(context *contexts.VendorContext, config ManagerConfig, providers map[string]providers.IProvider) error

func (*Manager) Shutdown

func (m *Manager) Shutdown(ctx context.Context) error

type ManagerConfig

type ManagerConfig struct {
	Name       string                    `json:"name"`
	Type       string                    `json:"type"`
	Properties map[string]string         `json:"properties"`
	Providers  map[string]ProviderConfig `json:"providers"`
}

type ProviderConfig

type ProviderConfig struct {
	Type   string                    `json:"type"`
	Config providers.IProviderConfig `json:"config"`
}