resumer

Documentation

Index

• type Resumer
  • func NewResumer(tr TransactionResumer) *Resumer
  • func (rr *Resumer) Kill()
  • func (rr *Resumer) Stop() error
  • func (rr *Resumer) String() string
  • func (rr *Resumer) Wait() error
• type TransactionResumer

Types

type Resumer

type Resumer struct {
	// contains filtered or unexported fields
}

Resumer is responsible for a periodical resuming of pending transactions.

func NewResumer

func NewResumer(tr TransactionResumer) *Resumer

NewResumer periodically resumes pending transactions.

func (*Resumer) Kill

func (rr *Resumer) Kill()

func (*Resumer) Stop

func (rr *Resumer) Stop() error

func (*Resumer) String

func (rr *Resumer) String() string

func (*Resumer) Wait

func (rr *Resumer) Wait() error

type TransactionResumer

type TransactionResumer interface {
	// ResumeTransactions resumes all pending transactions.
	ResumeTransactions() error
}

TransactionResumer defines the interface for types capable to resume transactions.