message

package

Go to main page

Versions in this module

v0

v0.6.1

Dec 21, 2022

v0.6.0

Sep 7, 2022

Changes in this version

type Message

+ func NewWithMetadata(t topics.Topic, payload interface{}, metadata *Metadata) Message

+ Metadata func() *Metadata

+ type Metadata struct

+ KadcastHeight byte

+ NumNodes byte

+ Source string

type NewBlock

+ func (e NewBlock) WithFields(l *logrus.Entry) *logrus.Entry

type StepVotesMsg

+ Candidate *block.Block

v0.5.0

Mar 18, 2022

v0.4.4

Jan 26, 2022

Changes in this version

+ func MarshalAggrAgreement(r *bytes.Buffer, aggr AggrAgreement) error

+ func MarshalNewBlock(r *bytes.Buffer, sev NewBlock) error

+ func UnmarshalAggrAgreement(r *bytes.Buffer, a *AggrAgreement) error

+ func UnmarshalAggrAgreementMessage(r *bytes.Buffer, m SerializableMessage) error

+ func UnmarshalNewBlock(r *bytes.Buffer, sev *NewBlock) error

+ func UnmarshalNewBlockMessage(r *bytes.Buffer, m SerializableMessage) error

+ type AggrAgreement struct

+ AggrSig []byte

+ Bitset uint64

+ func NewAggrAgreement(payload Agreement, bitset uint64, aggrSig []byte) AggrAgreement

+ func (a AggrAgreement) Copy() payload.Safe

+ func (a AggrAgreement) String() string

type Agreement

+ func (a Agreement) Signature() []byte

+ type NewBlock struct

+ Candidate block.Block

+ PrevHash []byte

+ SignedHash []byte

+ func EmptyNewBlock() NewBlock

+ func MockNewBlock(hdr header.Header, c block.Block) NewBlock

+ func NewNewBlock(hdr header.Header, prevHash []byte, candidate block.Block) *NewBlock

+ func (e NewBlock) Copy() payload.Safe

+ func (e NewBlock) Equal(s NewBlock) bool

+ func (e NewBlock) IsEmpty() bool

+ func (e NewBlock) State() header.Header

+ func (e NewBlock) String() string

+ func (e NewBlock) VoteHash() []byte

type Reduction

+ func (r Reduction) MarshalJSON() ([]byte, error)

v0.4.3

Jun 10, 2021

Changes in this version

+ func UnmarshalAddrMessage(r *bytes.Buffer, m SerializableMessage)

+ func UnmarshalChallengeMessage(r *bytes.Buffer, m SerializableMessage)

+ func UnmarshalResponseMessage(r *bytes.Buffer, m SerializableMessage) error

+ type Addr struct

+ NetAddr string

+ func (a Addr) Copy() payload.Safe

+ type Challenge struct

+ ChallengeString []byte

+ func (c Challenge) Copy() payload.Safe

+ type Response struct

+ HashedChallenge []byte

+ Port string

+ func (r *Response) Decode(b *bytes.Buffer) error

+ func (r *Response) Encode(w *bytes.Buffer) error

+ func (r Response) Copy() payload.Safe

v0.4.2

Mar 25, 2021

v0.4.1

Mar 24, 2021

v0.4.0

Mar 20, 2021

Changes in this version

+ const EMPTY

+ func ConvBool(p payload.Safe) (bool, error)

+ func ConvI(p payload.Safe) (int, error)

+ func ConvI16(p payload.Safe) (int16, error)

+ func ConvI32(p payload.Safe) (int32, error)

+ func ConvI64(p payload.Safe) (int64, error)

+ func ConvI8(p payload.Safe) (int8, error)

+ func ConvStr(p payload.Safe) (string, error)

+ func ConvU(p payload.Safe) (uint, error)

+ func ConvU16(p payload.Safe) (uint16, error)

+ func ConvU32(p payload.Safe) (uint32, error)

+ func ConvU64(p payload.Safe) (uint64, error)

+ func ConvU8(p payload.Safe) (uint8, error)

+ func UnmarshalBlockMessage(r *bytes.Buffer, m SerializableMessage) error

+ func UnmarshalGetBlocksMessage(r *bytes.Buffer, m SerializableMessage) error

+ func UnmarshalGetCandidateMessage(r *bytes.Buffer, m SerializableMessage)

+ func UnmarshalInvMessage(r *bytes.Buffer, m SerializableMessage) error

type Agreement

+ func (a Agreement) Copy() payload.Safe

+ type Certificate struct

+ Ag Agreement

+ Keys [][]byte

+ func NewCertificate(ag Agreement, keys [][]byte) Certificate

+ func (c Certificate) Copy() payload.Safe

+ func (c Certificate) String() string

+ type GetBlocks struct

+ Locators [][]byte

+ func (g *GetBlocks) Decode(r *bytes.Buffer) error

+ func (g *GetBlocks) Encode(w *bytes.Buffer) error

+ func (g GetBlocks) Copy() payload.Safe

+ type GetCandidate struct

+ Hash []byte

+ func (g GetCandidate) Copy() payload.Safe

+ type Initialization struct

+ BLSKeys *key.Keys

+ PublicKey *keys.PublicKey

+ func NewInitialization(pk *keys.PublicKey, blsKeys *key.Keys) Initialization

+ func (i Initialization) Copy() payload.Safe

+ type Inv struct

+ InvList []InvVect

+ func (inv *Inv) AddItem(t InvType, hash []byte)

+ func (inv *Inv) Decode(r *bytes.Buffer) error

+ func (inv *Inv) Encode(w *bytes.Buffer) error

+ func (inv Inv) Copy() payload.Safe

+ type InvType uint8

+ var InvTypeBlock InvType = 1

+ var InvTypeMempoolTx InvType = 0

+ type InvVect struct

+ Hash []byte

+ Type InvType

+ func (i InvVect) Copy() payload.Safe

type Message

+ func Clone(m Message) (Message, error)

+ func NewWithHeader(t topics.Topic, payload interface{}, header []byte) Message

+ CachedBinary func() bytes.Buffer

+ Header func() []byte

type Reduction

+ func (r Reduction) Copy() payload.Safe

+ type SafeBuffer struct

+ func (s SafeBuffer) Copy() payload.Safe

type Score

+ Candidate block.Block

+ func (e Score) Copy() payload.Safe

type ScoreProposal

+ Identity []byte

+ func (e ScoreProposal) Copy() payload.Safe

type StepVotes

+ func (s *StepVotes) Copy() *StepVotes

type StepVotesMsg

+ func (s StepVotesMsg) Copy() payload.Safe

v0.3.0

Apr 27, 2020

Changes in this version

+ func Marshal(s Message) (bytes.Buffer, error)

+ func MarshalAgreement(r *bytes.Buffer, a Agreement) error

+ func MarshalBid(r *bytes.Buffer, tx *transactions.Bid) error

+ func MarshalBlock(r *bytes.Buffer, b *block.Block) error

+ func MarshalCandidate(b *bytes.Buffer, c Candidate) error

+ func MarshalCertificate(r *bytes.Buffer, c *block.Certificate) error

+ func MarshalCoinbase(w *bytes.Buffer, c *transactions.Coinbase) error

+ func MarshalHashable(r *bytes.Buffer, h *block.Header) error

+ func MarshalHeader(r *bytes.Buffer, h *block.Header) error

+ func MarshalInput(w *bytes.Buffer, i *transactions.Input, encodeSignature bool) error

+ func MarshalOutput(w *bytes.Buffer, o *transactions.Output) error

+ func MarshalReduction(r *bytes.Buffer, bev Reduction) error

+ func MarshalScore(r *bytes.Buffer, sev Score) error

+ func MarshalStake(r *bytes.Buffer, tx *transactions.Stake) error

+ func MarshalStandard(w *bytes.Buffer, s *transactions.Standard) error

+ func MarshalStepVotes(r *bytes.Buffer, vote *StepVotes) error

+ func MarshalTimelock(r *bytes.Buffer, tx *transactions.Timelock) error

+ func MarshalTx(r *bytes.Buffer, tx transactions.Transaction) error

+ func MarshalVoteSet(r *bytes.Buffer, evs []Reduction) error

+ func MarshalVotes(r *bytes.Buffer, votes []*StepVotes) error

+ func MockCertificate(hash []byte, round uint64, keys []key.Keys, p *user.Provisioners) *block.Certificate

+ func SignAgreement(a *Agreement, keys key.Keys) error

+ func UnmarshalAgreement(r *bytes.Buffer, a *Agreement) error

+ func UnmarshalAgreementMessage(r *bytes.Buffer, m SerializableMessage) error

+ func UnmarshalBid(r *bytes.Buffer, tx *transactions.Bid) error

+ func UnmarshalBlock(r *bytes.Buffer, b *block.Block) error

+ func UnmarshalCandidate(b *bytes.Buffer, c *Candidate) error

+ func UnmarshalCandidateMessage(b *bytes.Buffer, m SerializableMessage) error

+ func UnmarshalCertificate(r *bytes.Buffer, c *block.Certificate) error

+ func UnmarshalCoinbase(w *bytes.Buffer, c *transactions.Coinbase) error

+ func UnmarshalHeader(r *bytes.Buffer, h *block.Header) error

+ func UnmarshalInput(r *bytes.Buffer, i *transactions.Input) error

+ func UnmarshalLegacyBlock(r *bytes.Buffer, b *block.Block) error

+ func UnmarshalLegacyStake(r *bytes.Buffer, tx *transactions.Stake) error

+ func UnmarshalOutput(r *bytes.Buffer, o *transactions.Output) error

+ func UnmarshalReduction(r *bytes.Buffer, bev *Reduction) error

+ func UnmarshalReductionMessage(r *bytes.Buffer, m SerializableMessage) error

+ func UnmarshalScore(r *bytes.Buffer, sev *Score) error

+ func UnmarshalScoreMessage(r *bytes.Buffer, m SerializableMessage) error

+ func UnmarshalStake(r *bytes.Buffer, tx *transactions.Stake) error

+ func UnmarshalStandard(w *bytes.Buffer, s *transactions.Standard) error

+ func UnmarshalTimelock(r *bytes.Buffer, tx *transactions.Timelock) error

+ func UnmarshalTx(r *bytes.Buffer) (transactions.Transaction, error)

+ func UnmarshalTxMessage(r *bytes.Buffer, m SerializableMessage) error

+ func UnmarshalVotes(r *bytes.Buffer, votes []*StepVotes) error

+ type Agreement struct

+ Repr *big.Int

+ VotesPerStep []*StepVotes

+ func MockAgreement(hash []byte, round uint64, step uint8, keys []key.Keys, p *user.Provisioners, ...) Agreement

+ func NewAgreement(hdr header.Header) *Agreement

+ func (a *Agreement) SetSignature(signedVotes []byte)

+ func (a Agreement) Cmp(other Agreement) int

+ func (a Agreement) Equal(aev Agreement) bool

+ func (a Agreement) GenerateCertificate() *block.Certificate

+ func (a Agreement) Sender() []byte

+ func (a Agreement) SignedVotes() []byte

+ func (a Agreement) State() header.Header

+ func (a Agreement) String() string

+ type Candidate struct

+ func MakeCandidate(blk *block.Block, cert *block.Certificate) Candidate

+ func NewCandidate() *Candidate

+ func (c Candidate) Equal(m Message) bool

+ func (c Candidate) Sender() []byte

+ func (c Candidate) State() header.Header

+ func (c Candidate) String() string

+ type Message interface

+ Category func() topics.Topic

+ Equal func(Message) bool

+ Id func() []byte

+ Payload func() interface{}

+ func New(t topics.Topic, payload interface{}) Message

+ func Unmarshal(b *bytes.Buffer) (Message, error)

+ type Reduction struct

+ SignedHash []byte

+ func MockCommitteeVoteSet(p *user.Provisioners, k []key.Keys, hash []byte, committeeSize int, ...) []Reduction

+ func MockReduction(hash []byte, round uint64, step uint8, keys []key.Keys, iterativeIdx ...int) Reduction

+ func MockVoteSet(hash []byte, round uint64, step uint8, keys []key.Keys, amount int) []Reduction

+ func MockVotes(hash []byte, round uint64, step uint8, keys []key.Keys, amount int) []Reduction

+ func NewReduction(hdr header.Header) *Reduction

+ func UnmarshalVoteSet(r *bytes.Buffer) ([]Reduction, error)

+ func (r Reduction) Equal(msg Message) bool

+ func (r Reduction) Sender() []byte

+ func (r Reduction) State() header.Header

+ func (r Reduction) String() string

+ type Score struct

+ PrevHash []byte

+ VoteHash []byte

+ func EmptyScore() Score

+ func MockScore(hdr header.Header, hash []byte) Score

+ func NewScore(proposal ScoreProposal, pubkey, prevHash, voteHash []byte) *Score

+ func (e Score) Equal(s Score) bool

+ func (e Score) String() string

+ type ScoreProposal struct

+ BidListSubset []byte

+ Proof []byte

+ Score []byte

+ Seed []byte

+ Z []byte

+ func EmptyScoreProposal(hdr header.Header) ScoreProposal

+ func MockScoreProposal(hdr header.Header) ScoreProposal

+ func NewScoreProposal(hdr header.Header, seed []byte, proof zkproof.ZkProof) ScoreProposal

+ func (e ScoreProposal) IsEmpty() bool

+ func (e ScoreProposal) Sender() []byte

+ func (e ScoreProposal) State() header.Header

+ func (e ScoreProposal) String() string

+ type Serializable interface

+ SetPayload func(interface{})

+ type SerializableMessage interface

+ type StepVotes struct

+ Apk *bls.Apk

+ BitSet uint64

+ Signature *bls.Signature

+ Step uint8

+ func GenVotes(hash []byte, round uint64, step uint8, keys []key.Keys, p *user.Provisioners) []*StepVotes

+ func NewStepVotes() *StepVotes

+ func UnmarshalStepVotes(r *bytes.Buffer) (*StepVotes, error)

+ func (s *StepVotes) Add(signature, sender []byte, step uint8) error

+ func (s *StepVotes) Equal(other *StepVotes) bool

+ func (s StepVotes) IsEmpty() bool

+ func (s StepVotes) String() string

+ type StepVotesMsg struct

+ func NewStepVotesMsg(round uint64, hash []byte, sender []byte, sv StepVotes) StepVotesMsg

+ func (s StepVotesMsg) State() header.Header

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