Documentation
¶
Index ¶
- Constants
- Variables
- func New(injector do.Injector) (indexer.IndexerWorker, error)
- type NodeSaleEvent
- 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, 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 ¶
View Source
const (
Version = "v0.0.1-alpha"
)
Variables ¶
View Source
var NODESALE_MAGIC = []byte{0x6e, 0x73, 0x6f, 0x70}
Functions ¶
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 ¶
CurrentBlock implements indexer.Processor.
func (*Processor) GetIndexedBlock ¶
GetIndexedBlock 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 (*Processor) RevertData ¶
RevertData implements indexer.Processor.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.