orchestrator

Documentation

Index

• Constants
• Variables
• type BlockNumberWithError
• type ChainTracker
  • func NewChainTracker(rpc rpc.IRPCClient) *ChainTracker
  • func (ct *ChainTracker) Start(ctx context.Context)
• type Committer
  • func NewCommitter(rpc rpc.IRPCClient, storage storage.IStorage) *Committer
  • func (c *Committer) Start(ctx context.Context)
• type FailureRecoverer
  • func NewFailureRecoverer(rpc rpc.IRPCClient, storage storage.IStorage) *FailureRecoverer
  • func (fr *FailureRecoverer) Start(ctx context.Context)
• type Orchestrator
  • func NewOrchestrator(rpc rpc.IRPCClient) (*Orchestrator, error)
  • func (o *Orchestrator) Shutdown()
  • func (o *Orchestrator) Start()
• type Poller
  • func NewBoundlessPoller(rpc rpc.IRPCClient, storage storage.IStorage) *Poller
  • func NewPoller(rpc rpc.IRPCClient, storage storage.IStorage) *Poller
  • func (p *Poller) Poll(blockNumbers []*big.Int) (lastPolledBlock *big.Int)
  • func (p *Poller) Start(ctx context.Context)
• type ReorgHandler
  • func NewReorgHandler(rpc rpc.IRPCClient, storage storage.IStorage) *ReorgHandler
  • func (rh *ReorgHandler) RunFromBlock(latestCheckedBlock *big.Int) (lastCheckedBlock *big.Int, err error)
  • func (rh *ReorgHandler) Start(ctx context.Context)

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_REORG_HANDLER_BLOCKS_PER_SCAN = 100

const DEFAULT_REORG_HANDLER_INTERVAL = 1000

const DEFAULT_TRIGGER_INTERVAL = 1000

Variables

var ErrNoNewBlocks = fmt.Errorf("no new blocks to poll")

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 rpc.IRPCClient) *ChainTracker

func (*ChainTracker) Start

func (ct *ChainTracker) Start(ctx context.Context)

type Committer

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

func NewCommitter

func NewCommitter(rpc rpc.IRPCClient, storage storage.IStorage) *Committer

func (*Committer) Start

func (c *Committer) Start(ctx context.Context)

type FailureRecoverer

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

func NewFailureRecoverer

func NewFailureRecoverer(rpc rpc.IRPCClient, storage storage.IStorage) *FailureRecoverer

func (*FailureRecoverer) Start

func (fr *FailureRecoverer) Start(ctx context.Context)

type Orchestrator

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

func NewOrchestrator

func NewOrchestrator(rpc rpc.IRPCClient) (*Orchestrator, error)

func (*Orchestrator) Shutdown

func (o *Orchestrator) Shutdown()

func (*Orchestrator) Start

func (o *Orchestrator) Start()

type Poller

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

func NewBoundlessPoller

func NewBoundlessPoller(rpc rpc.IRPCClient, storage storage.IStorage) *Poller

func NewPoller

func NewPoller(rpc rpc.IRPCClient, storage storage.IStorage) *Poller

func (*Poller) Poll

func (p *Poller) Poll(blockNumbers []*big.Int) (lastPolledBlock *big.Int)

func (*Poller) Start

func (p *Poller) Start(ctx context.Context)

type ReorgHandler

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

func NewReorgHandler

func NewReorgHandler(rpc rpc.IRPCClient, storage storage.IStorage) *ReorgHandler

func (*ReorgHandler) RunFromBlock

func (rh *ReorgHandler) RunFromBlock(latestCheckedBlock *big.Int) (lastCheckedBlock *big.Int, err error)

func (*ReorgHandler) Start

func (rh *ReorgHandler) Start(ctx context.Context)