nodesale

Documentation

Index

• Constants
• Variables
• func New(injector do.Injector) (indexer.IndexerWorker, error)
• type NodeSaleEvent
• type Processor
  • func NewProcessor(repository datagateway.NodeSaleDataGateway, ...) *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, inputs []*types.Block) error
  • func (p *Processor) ProcessDelegate(ctx context.Context, qtx datagateway.NodeSaleDataGatewayWithTx, ...) error
  • func (p *Processor) ProcessDeploy(ctx context.Context, qtx datagateway.NodeSaleDataGatewayWithTx, ...) error
  • func (p *Processor) ProcessPurchase(ctx context.Context, qtx datagateway.NodeSaleDataGatewayWithTx, ...) error
  • func (p *Processor) PubkeyToPkHashAddress(pubKey *btcec.PublicKey) btcutil.Address
  • 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-alpha"
)

Variables

var NODESALE_MAGIC = []byte{0x6e, 0x73, 0x6f, 0x70}

Functions

func New

func New(injector do.Injector) (indexer.IndexerWorker, error)

Types

type NodeSaleEvent

type NodeSaleEvent struct {
	Transaction  *types.Transaction
	EventMessage *protobuf.NodeSaleEvent
	EventJson    []byte
	TxPubkey     *btcec.PublicKey
	RawData      []byte
	InputValue   uint64
}

type Processor

type Processor struct {
	NodeSaleDg datagateway.NodeSaleDataGateway
	BtcClient  *datasources.BitcoinNodeDatasource
	Network    common.Network
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor(repository datagateway.NodeSaleDataGateway,
	datasource *datasources.BitcoinNodeDatasource,
	network common.Network,
	cleanupFuncs []func(context.Context) error,
	lastBlockDefault int64,
) *Processor

func (*Processor) CurrentBlock

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

CurrentBlock implements indexer.Processor.

func (*Processor) GetIndexedBlock

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

GetIndexedBlock implements indexer.Processor.

func (*Processor) Name

func (p *Processor) Name() string

Name implements indexer.Processor.

func (*Processor) Process

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

Process implements indexer.Processor.

func (*Processor) ProcessDelegate

func (p *Processor) ProcessDelegate(ctx context.Context, qtx datagateway.NodeSaleDataGatewayWithTx, block *types.Block, event NodeSaleEvent) error

func (*Processor) ProcessDeploy

func (p *Processor) ProcessDeploy(ctx context.Context, qtx datagateway.NodeSaleDataGatewayWithTx, block *types.Block, event NodeSaleEvent) error

func (*Processor) ProcessPurchase

func (p *Processor) ProcessPurchase(ctx context.Context, qtx datagateway.NodeSaleDataGatewayWithTx, block *types.Block, event NodeSaleEvent) error

func (*Processor) PubkeyToPkHashAddress

func (p *Processor) PubkeyToPkHashAddress(pubKey *btcec.PublicKey) btcutil.Address

func (*Processor) RevertData

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

RevertData implements indexer.Processor.

func (*Processor) Shutdown

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

func (*Processor) VerifyStates

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

VerifyStates implements indexer.Processor.