csn

Documentation

Index

• func PushTx(tx *wire.MsgTx) error
• func RunIBD(p *chaincfg.Params, host, watchAddr string, check bool, lookahead int, ...) error
• type Csn
  • func (c *Csn) IBDThread(sig chan bool)
  • func (ch *Csn) RegisterAddress(adr [20]byte)
  • func (ch *Csn) RegisterOutPoint(op wire.OutPoint)
  • func (c *Csn) ScanBlock(b wire.MsgBlock)
  • func (c *Csn) Start(height int32, host, path, proxyURL string, params *chaincfg.Params, ...) (chan wire.MsgTx, chan int32, error)
  • func (ch *Csn) UnegisterOutPoint(op wire.OutPoint)

Functions

func PushTx

func PushTx(tx *wire.MsgTx) error

TODO implement. I guess push to the bridge node. But really it'd be better to just push it out to the regular p2p network.

func RunIBD

func RunIBD(
	p *chaincfg.Params, host, watchAddr string, check bool, lookahead int, sig chan bool) error

RunIBD calls everything to run IBD

Types

type Csn

type Csn struct {
	CurrentHeight int32

	WatchOPs  map[wire.OutPoint]bool
	WatchAdrs map[[20]byte]bool
	// TODO use better addresses, either []byte or something fancy
	TxChan     chan wire.MsgTx
	HeightChan chan int32

	CheckSignatures bool
	Params          chaincfg.Params
	// contains filtered or unexported fields
}

CsnHook is the main stateful struct for the Compact State Node. It keeps track of what block its on and what transactions it's looking for

func (*Csn) IBDThread

func (c *Csn) IBDThread(sig chan bool)

run IBD from block proof data we get the new utxo info from the same txos text file

func (*Csn) RegisterAddress

func (ch *Csn) RegisterAddress(adr [20]byte)

func (*Csn) RegisterOutPoint

func (ch *Csn) RegisterOutPoint(op wire.OutPoint)

func (*Csn) ScanBlock

func (c *Csn) ScanBlock(b wire.MsgBlock)

ScanBlock looks through a block using the CSN's maps and sends matches into the tx channel.

func (*Csn) Start

func (c *Csn) Start(height int32,
	host, path, proxyURL string,
	params *chaincfg.Params,
	haltSig chan bool) (chan wire.MsgTx, chan int32, error)

Start starts up a compact state node, and returns channels for txs and block heights.

func (*Csn) UnegisterOutPoint

func (ch *Csn) UnegisterOutPoint(op wire.OutPoint)