orchestrator

Documentation

Index

• Constants
• type BlockNumberWithError
• type ChainTracker
  • func NewChainTracker(rpc common.RPC) *ChainTracker
  • func (ct *ChainTracker) Start()
• type Committer
  • func NewCommitter(rpc common.RPC, storage storage.IStorage) *Committer
  • func (c *Committer) Start()
• type FailureRecoverer
  • func NewFailureRecoverer(rpc common.RPC, storage storage.IStorage) *FailureRecoverer
  • func (fr *FailureRecoverer) Start()
• type Orchestrator
  • func NewOrchestrator(rpc common.RPC) (*Orchestrator, error)
  • func (o *Orchestrator) Start()
• type Poller
  • func NewPoller(rpc common.RPC, storage storage.IStorage) *Poller
  • func (p *Poller) Start()

Constants

const DEFAULT_BLOCKS_PER_COMMIT = 1000

const DEFAULT_BLOCKS_PER_POLL = 10

const DEFAULT_CHAIN_TRACKER_POLL_INTERVAL = 300000 // 5 minutes

const DEFAULT_COMMITTER_TRIGGER_INTERVAL = 2000

const DEFAULT_FAILURES_PER_POLL = 10

const DEFAULT_FAILURE_TRIGGER_INTERVAL = 1000

const DEFAULT_TRIGGER_INTERVAL = 1000

Types

type BlockNumberWithError

type BlockNumberWithError struct {
	BlockNumber *big.Int
	Error       error
}

type ChainTracker

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

func NewChainTracker

func NewChainTracker(rpc common.RPC) *ChainTracker

func (*ChainTracker) Start

func (ct *ChainTracker) Start()

type Committer

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

func NewCommitter

func NewCommitter(rpc common.RPC, storage storage.IStorage) *Committer

func (*Committer) Start

func (c *Committer) Start()

type FailureRecoverer

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

func NewFailureRecoverer

func NewFailureRecoverer(rpc common.RPC, storage storage.IStorage) *FailureRecoverer

func (*FailureRecoverer) Start

func (fr *FailureRecoverer) Start()

type Orchestrator

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

func NewOrchestrator

func NewOrchestrator(rpc common.RPC) (*Orchestrator, error)

func (*Orchestrator) Start

func (o *Orchestrator) Start()

type Poller

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

func NewPoller

func NewPoller(rpc common.RPC, storage storage.IStorage) *Poller

func (*Poller) Start

func (p *Poller) Start()