Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var NewResumer = func(tr TransactionResumer) worker.Worker { rr := &Resumer{tr: tr} go func() { defer rr.tomb.Done() rr.tomb.Kill(rr.loop()) }() return rr }
NewResumer periodically resumes pending transactions.
Functions ¶
func Manifold ¶
func Manifold(config ManifoldConfig) dependency.Manifold
Manifold returns a dependency manifold that runs a resumer worker, using the api connection resource named in the supplied config.
Types ¶
type ManifoldConfig ¶
type ManifoldConfig util.AgentApiManifoldConfig
ManifoldConfig defines the names of the manifolds on which a Manifold will depend.
type Resumer ¶
type Resumer struct {
// contains filtered or unexported fields
}
Resumer is responsible for a periodical resuming of pending transactions.
type TransactionResumer ¶
type TransactionResumer interface {
// ResumeTransactions resumes all pending transactions.
ResumeTransactions() error
}
TransactionResumer defines the interface for types capable to resume transactions.
Source Files
Click to show internal directories.
Click to hide internal directories.