Documentation ¶
Index ¶
- Constants
- func New(injector do.Injector) (indexer.IndexerWorker, error)
- type Processor
- func (p *Processor) CurrentBlock(ctx context.Context) (types.BlockHeader, error)
- func (p *Processor) GetIndexedBlock(ctx context.Context, height int64) (types.BlockHeader, error)
- func (p *Processor) Name() string
- func (p *Processor) Process(ctx context.Context, blocks []*types.Block) error
- func (p *Processor) RevertData(ctx context.Context, from int64) error
- func (p *Processor) Shutdown(ctx context.Context) error
- func (p *Processor) VerifyStates(ctx context.Context) error
Constants ¶
View Source
const ( ClientVersion = "v0.0.1" DBVersion = 1 EventHashVersion = 1 )
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(injector do.Injector) (indexer.IndexerWorker, error)
Types ¶
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
func NewProcessor ¶
func NewProcessor(brc20Dg datagateway.BRC20DataGateway, indexerInfoDg datagateway.IndexerInfoDataGateway, btcClient btcclient.Contract, network common.Network, cleanupFuncs []func(context.Context) error) (*Processor, error)
func (*Processor) CurrentBlock ¶
CurrentBlock implements indexer.Processor.
func (*Processor) GetIndexedBlock ¶
GetIndexedBlock implements indexer.Processor.
func (*Processor) RevertData ¶
RevertData implements indexer.Processor.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.