runes

Documentation

Index

• Constants
• Variables
• func New(injector do.Injector) (indexer.IndexerWorker, error)
• type Processor
  • func NewProcessor(runesDg datagateway.RunesDataGateway, ...) *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

const (
	Version          = "v0.0.1"
	DBVersion        = 1
	EventHashVersion = 1
)

Variables

var (
	ErrDBVersionMismatch        = errors.New("db version mismatch: please migrate db")
	ErrEventHashVersionMismatch = errors.New("event hash version mismatch: please reset db and reindex")
)

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(runesDg datagateway.RunesDataGateway, indexerInfoDg datagateway.IndexerInfoDataGateway, bitcoinClient btcclient.Contract, network common.Network, reportingClient *reportingclient.ReportingClient, cleanupFuncs []func(context.Context) error) *Processor

func (*Processor) CurrentBlock

func (p *Processor) CurrentBlock(ctx context.Context) (types.BlockHeader, error)

func (*Processor) GetIndexedBlock

func (p *Processor) GetIndexedBlock(ctx context.Context, height int64) (types.BlockHeader, error)

warning: GetIndexedBlock currently returns a types.BlockHeader with only Height, Hash fields populated. This is because it is known that all usage of this function only requires these fields. In the future, we may want to populate all fields for type safety.

func (*Processor) Name

func (p *Processor) Name() string

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, blocks []*types.Block) error

func (*Processor) RevertData

func (p *Processor) RevertData(ctx context.Context, from int64) error

func (*Processor) Shutdown

func (p *Processor) Shutdown(ctx context.Context) error

func (*Processor) VerifyStates

func (p *Processor) VerifyStates(ctx context.Context) error