wendy

package module

Go to main page

Versions in this module

v0

v0.4.0

May 31, 2021

Changes in this version

+ var ErrVoteHashesDontMatch = errors.New("vote hashes don't match")

type Hash

+ func Checksum(v []byte) Hash

type Vote

+ PrevHash Hash

+ func (v *Vote) Hash() Hash

+ func (v *Vote) WithPrevHash(hash Hash) *Vote

type Wendy

+ func (w *Wendy) AddVotes(vs ...*Vote) error

v0.3.0

May 24, 2021

Changes in this version

type NewBlockOptions

+ AddBlock bool

+ type SimpleTx struct

+ func NewSimpleTx(bytes, hash string) *SimpleTx

+ func (tx *SimpleTx) Bytes() []byte

+ func (tx *SimpleTx) Hash() Hash

+ func (tx *SimpleTx) Label() string

+ func (tx *SimpleTx) String() string

+ type Txs struct

+ func NewTxs(list ...Tx) *Txs

+ func (txs *Txs) ByHash(hash Hash) Tx

+ func (txs *Txs) List() []Tx

+ func (txs *Txs) Push(tx Tx) bool

+ func (txs *Txs) RemoveByHash(hash Hash) bool

type Vote

+ func NewVote(pub Pubkey, seq uint64, tx Tx) *Vote

type Wendy

+ func (w *Wendy) AddBlock(block *Block)

+ func (w *Wendy) NewBlock() *Block

+ func (w *Wendy) NewBlockWithOptions(opts NewBlockOptions) *Block

v0.2.2

May 19, 2021

v0.2.1

May 19, 2021

Changes in this version

type BlockingSet

+ func (set BlockingSet) NewBlock() *Block

+ func (set BlockingSet) NewBlockWithOptions(opts NewBlockOptions) *Block

+ type NewBlockOptions struct

+ MaxBlockSize int

+ TxLimit int

v0.2.0

May 19, 2021

Changes in this version

+ const HashLen

+ var Quorum = float64(2) / 3

+ var Rand = rand.New(rand.NewSource(time.Now().UnixNano()))

type Block

+ Txs []Tx

+ type BlockingSet map[Hash][]Tx

+ func (set BlockingSet) String() string

+ type Hash [HashLen]byte

+ func (h Hash) String() string

+ type ID string

+ type Node struct

+ RecvCb func()

+ SendCb func()

+ Wg *sync.WaitGroup

+ func NewNode(pub Pubkey, peers ...*Node) *Node

+ func (n *Node) AddPeer(peer *Node)

+ func (n *Node) AddPeers(peers ...*Node)

+ func (n *Node) AddTx(tx Tx)

+ func (n *Node) Log(msg string, args ...interface{})

+ func (n *Node) WithDebug(fn NodeDebugFn) *Node

+ type NodeDebugFn func(*Node, string) bool

+ type Peer struct

+ func NewPeer(pub Pubkey) *Peer

+ func (r *Peer) AddVote(v *Vote) bool

+ func (r *Peer) AddVotes(vs ...*Vote)

+ func (r *Peer) Before(tx1, tx2 Tx) bool

+ func (r *Peer) LastSeqSeen(label string) uint64

+ func (r *Peer) Seen(tx Tx) bool

+ func (r *Peer) UpdateTxSet(txs ...Tx)

+ type Pubkey []byte

+ func NewPubkeyFromID(id ID) Pubkey

+ func (pk Pubkey) Bytes() []byte

+ func (pk Pubkey) String() string

+ type SignedVote struct

+ Data *Vote

+ Signature []byte

+ func NewSignedVote(key ed25519.PrivateKey, v *Vote) *SignedVote

+ func (sv *SignedVote) Verify() bool

+ type Tx interface

+ Bytes func() []byte

+ Hash func() Hash

+ Label func() string

+ type Validator []byte

type Vote

+ Label string

+ Pubkey Pubkey

+ Seq uint64

+ Time time.Time

+ TxHash Hash

+ func (v *Vote) Key() ID

+ func (v *Vote) String() string

+ type Wendy struct

+ func New() *Wendy

+ func (w *Wendy) AddTx(tx Tx) bool

+ func (w *Wendy) AddVote(v *Vote) bool

+ func (w *Wendy) BlockingSet() BlockingSet

+ func (w *Wendy) CommitBlock(block Block)

+ func (w *Wendy) HonestMajority() int

+ func (w *Wendy) HonestParties() int

+ func (w *Wendy) IsBlocked(tx Tx) bool

+ func (w *Wendy) IsBlockedBy(tx1, tx2 Tx) bool

+ func (w *Wendy) UpdateValidatorSet(vs []Validator)

+ func (w *Wendy) VoteByTxHash(hash Hash) *Vote

v0.1.2

May 17, 2021

v0.1.1

May 12, 2021

Changes in this version

+ func Checkpoint(s string, code int)

+ func RemoveIndexInt(s []int, index int) []int

+ func RemoveIndexMsg(s []message, index int) []message

+ func RemoveIndexStr(s []string, index int) []string

+ type Block struct

+ Payload string

+ type Transaction struct

+ Marketid int

+ Payload string

+ type TransactionV struct

+ Marketid int

+ Payload string

+ ReceivedTime int

+ SeqNumber int

+ Votes []Vote

+ func RemoveIndexTX(s []TransactionV, index int) []TransactionV

+ type Vote struct

+ Marketid int

+ Payload string

+ ReceivedTime int

+ Sender int

+ SeqNumber int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL