manager

Nov 24, 2019

Changes in this version

+ const DefaultTransactionTimeout

Nov 17, 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.Store, d ...driver.Driver) (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)