accumulator

Documentation

Overview

Router keeps track of all the chains in flight. It routes transactions to the right chain.

Index

• type Chain
  • func (c *Chain) AddToMR(hash []byte)
  • func (c *Chain) CloseMR() []byte
  • func (c *Chain) Run(txs HashStream)
• type ChainAcc
• type HashStream
• type Router
  • func (r *Router) AddTx(chainId [32]byte, hash []byte)
  • func (r *Router) CloseAll() (chains int64, count int64, pending int64)
  • func (r *Router) Init()

Types

type Chain

type Chain struct {
	MR    [][]byte   // Array of hashes that represent the right edge of the Merkle tree
	Txs   HashStream // stream of hashes going into the Merkle tree
	Mux   sync.Mutex // Allow the chain to be locked when closing
	Count int64      // How many hashes we have processed.
}

Structure for accepting hashes to go into a chain.

func (*Chain) AddToMR

func (c *Chain) AddToMR(hash []byte)

Add a Hash to a building Merkle Tree

func (*Chain) CloseMR

func (c *Chain) CloseMR() []byte

CloseMR Pad the rest of the inputs into the Merkle tree until we match a power of two.

func (*Chain) Run

func (c *Chain) Run(txs HashStream)

go routine that pulls transactions out of the hashstream and pushes them into adding to the Merkle tree

type ChainAcc

type ChainAcc struct {
	// contains filtered or unexported fields
}

type HashStream

type HashStream chan []byte

type Router

type Router struct {
	Mux sync.Mutex
	// contains filtered or unexported fields
}

func (*Router) AddTx

func (r *Router) AddTx(chainId [32]byte, hash []byte)

AddTx Add a TX to its chain. Allocates a chain if one does not exist.

func (*Router) CloseAll

func (r *Router) CloseAll() (chains int64, count int64, pending int64)

CloseAll Close all the accumulators and sum up the results, and pass results back to caller.

func (*Router) Init

func (r *Router) Init()

We create an initial Map to track the chains we are writing to.