syncer

May 8, 2020

Changes in this version

+ const PastBlockSize

type Handler

+ BlockAdded func(ctx context.Context, block *types.Block) error

+ BlockRemoved func(ctx context.Context, block *types.BlockIdentifier) error

type Syncer

+ func New(network *types.NetworkIdentifier, fetcher *fetcher.Fetcher, handler Handler, ...) *Syncer

+ func (s *Syncer) Sync(ctx context.Context, startIndex int64, endIndex int64) error

Apr 30, 2020

Changes in this version

type BaseHandler

+ func (h *BaseHandler) AccountExempt(ctx context.Context, account *types.AccountIdentifier, ...) bool

type Handler

+ AccountExempt func(ctx context.Context, account *types.AccountIdentifier, current *types.Currency) bool

Apr 27, 2020

Changes in this version

+ func BalanceChanges(ctx context.Context, asserter *asserter.Asserter, block *types.Block, ...) ([]*storage.BalanceChange, error)

+ func NextSyncableRange(ctx context.Context, s Syncer, endIndex int64) (int64, int64, bool, error)

+ func Sync(ctx context.Context, cancel context.CancelFunc, s Syncer, startIndex int64, ...) error

+ type BaseHandler struct

+ func (h *BaseHandler) BlockProcessed(ctx context.Context, block *types.Block, reorg bool, ...) error

+ type Handler interface

+ BlockProcessed func(ctx context.Context, block *types.Block, orphan bool, ...) error

+ func NewBaseHandler(logger *logger.Logger, reconciler reconciler.Reconciler) Handler

+ type StatefulSyncer struct

+ func NewStateful(network *types.NetworkIdentifier, storage *storage.BlockStorage, ...) *StatefulSyncer

+ func (s *StatefulSyncer) CurrentIndex(ctx context.Context) (int64, error)

+ func (s *StatefulSyncer) Fetcher(ctx context.Context) *fetcher.Fetcher

+ func (s *StatefulSyncer) Network(ctx context.Context) *types.NetworkIdentifier

+ func (s *StatefulSyncer) SetStartIndex(ctx context.Context, startIndex int64) error

+ func (s *StatefulSyncer) SyncRange(ctx context.Context, startIndex int64, endIndex int64) error

+ type StatelessSyncer struct

+ func NewStateless(network *types.NetworkIdentifier, fetcher *fetcher.Fetcher, handler Handler) *StatelessSyncer

+ func (s *StatelessSyncer) CurrentIndex(ctx context.Context) (int64, error)

+ func (s *StatelessSyncer) Fetcher(ctx context.Context) *fetcher.Fetcher

+ func (s *StatelessSyncer) Network(ctx context.Context) *types.NetworkIdentifier

+ func (s *StatelessSyncer) SetStartIndex(ctx context.Context, startIndex int64) error

+ func (s *StatelessSyncer) SyncRange(ctx context.Context, startIndex int64, endIndex int64) error

+ type Syncer interface

+ CurrentIndex func(ctx context.Context) (int64, error)

+ Fetcher func(ctx context.Context) *fetcher.Fetcher

+ Network func(ctx context.Context) *types.NetworkIdentifier

+ SetStartIndex func(ctx context.Context, startIndex int64) error

+ SyncRange func(ctx context.Context, rangeStart int64, rangeEnd int64) error