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 (
	MapperRegisteredEvent  = common.BytesToHash(crypto.Keccak256([]byte("MapperRegistered(bytes32)")))
	MapperOnboardedEvent   = common.BytesToHash(crypto.Keccak256([]byte("MapperOnboarded(bytes32,address)")))
	MapperClaimedEvent     = common.BytesToHash(crypto.Keccak256([]byte("MapperClaimed(bytes32)")))
	MapperRemovedEvent     = common.BytesToHash(crypto.Keccak256([]byte("MapperRemoved(bytes32)")))
	MapperDeactivatedEvent = common.BytesToHash(crypto.Keccak256([]byte("MapperInactive(bytes32)")))
	MapperActivatedEvent   = common.BytesToHash(crypto.Keccak256([]byte("MapperActive(bytes32)")))
	MapperTransferredEvent = common.BytesToHash(crypto.Keccak256([]byte("MapperTransferred(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