manager

Nov 1, 2019

Changes in this version

+ type Emitter interface

+ Emit func(result transaction.Result)

+ type EmitterFunc func(result transaction.Result)

+ func (e EmitterFunc) Emit(result transaction.Result)

+ type Manager struct

+ func New(s Store) (manager *Manager)

+ func (m *Manager) Add(tx transaction.Transaction) (err error)

+ func (m *Manager) AddEmitter(emitter Emitter)

+ func (m *Manager) AddEmitterFunc(emitter func(result transaction.Result))

+ func (m *Manager) AddFromConfig(config transaction.Config) (err error)

+ func (m *Manager) Close() (err error)

+ func (m *Manager) GetResult(name string) (result transaction.Result, err error)

+ func (m *Manager) GetResults() (results []transaction.Result)

+ func (m *Manager) GetTransaction(name string) (tx transaction.Transaction, err error)

+ func (m *Manager) GetTransactionConfig(name string) (config transaction.Config, err error)

+ func (m *Manager) GetTransactionsConfig() (configs []transaction.Config)

+ func (m *Manager) New(config transaction.Config) (tx transaction.Transaction, err error)

+ func (m *Manager) RemoveTransaction(name string) (err error)

+ func (m *Manager) Run(ctx context.Context, name string) (result transaction.Result, err error)

+ type Store interface

+ Close func() (err error)

+ Delete func(name string) (err error)

+ Get func(name string) (config transaction.Config, err error)

+ Has func(name string) (exists bool, err error)

+ Iter func(callback func(name string, config transaction.Config) (proceed bool)) (err error)

+ Set func(name string, config transaction.Config) (err error)