Versions in this module Expand all Collapse all v0 v0.3.2 Oct 4, 2014 Changes in this version + var ErrNotSubscribed = errors.New("not subscribed") + var ErrSubscribed = errors.New("already subscribed") + type Topic struct + func New(id, owner *big.Int) *Topic + func (t *Topic) Balance(ex *big.Int) (*big.Int, error) + func (t *Topic) Broadcast(ex *big.Int) []*big.Int + func (t *Topic) Cycle() + func (t *Topic) Empty() bool + func (t *Topic) GenerateReports() ([]*big.Int, []int) + func (t *Topic) Neighbor(id *big.Int) bool + func (t *Topic) Parent() *big.Int + func (t *Topic) ProcessReport(id *big.Int, cap int) error + func (t *Topic) Reown(parent *big.Int) + func (t *Topic) Self() *big.Int + func (t *Topic) Subscribe(id *big.Int) error + func (t *Topic) Unsubscribe(id *big.Int) error