chainsync

Documentation

Index

• Variables
• type ChainSync
  • func NewChainSync() (*ChainSync, error)
  • func (cs *ChainSync) Run(ctx context.Context) error
  • func (cs *ChainSync) SetFuncs(pendingEventFunc interfac.PendingEventFunc, eventsFunc interfac.EventsFunc, ...)

Variables

var (
	GatewayOnboardedEvent   = common.BytesToHash(crypto.Keccak256([]byte("GatewayOnboarded(bytes32,address)")))
	GatewayOffboardedEvent  = common.BytesToHash(crypto.Keccak256([]byte("GatewayOffboarded(bytes32)")))
	GatewayUpdatedEvent     = common.BytesToHash(crypto.Keccak256([]byte("GatewayUpdated(bytes32)")))
	GatewayTransferredEvent = common.BytesToHash(crypto.Keccak256([]byte("GatewayTransferred(bytes32,address,address)")))
)

Types

type ChainSync

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

func NewChainSync

func NewChainSync() (*ChainSync, error)

func (*ChainSync) Run

func (cs *ChainSync) Run(ctx context.Context) error

Run implements source.Source

func (*ChainSync) SetFuncs

func (cs *ChainSync) SetFuncs(pendingEventFunc interfac.PendingEventFunc, eventsFunc interfac.EventsFunc, setCurrentBlockFunc chainsync.SetCurrentBlockFunc, currentBlockFunc chainsync.CurrentBlockFunc)

SetFuncs implements source.Source