util

package

v0.0.0-...-89de7d0 Latest Latest Go to latest Published: Jan 26, 2022 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ImperiumProject/tendermint-test

Documentation ¶

Index ¶

Variables
func GetChainID(r *types.Replica) (string, error)
func GetPrivKey(r *types.Replica) (crypto.PrivKey, error)
func GetProposalBlockID(msg *TMessage) (*ttypes.BlockID, bool)
func GetProposalBlockIDS(msg *TMessage) (string, bool)
func GetReplicaAddress(r *types.Replica) ([]byte, error)
func GetVoteBlockID(msg *TMessage) (*ttypes.BlockID, bool)
func GetVoteBlockIDS(msg *TMessage) (string, bool)
func GetVoteTime(msg *TMessage) (time.Time, bool)
func GetVoteValidator(msg *TMessage) ([]byte, bool)
func IsVoteFrom(msg *TMessage, replica *types.Replica) bool
type GenericPartitioner
- func NewGenericPartitioner(replicasStore *types.ReplicaStore) *GenericPartitioner
- func (g *GenericPartitioner) CreatePartition(sizes []int, labels []string) (*Partition, error)
type MessageType
type Part
- func (p *Part) Contains(replica types.ReplicaID) bool
- func (p *Part) ContainsVal(addr []byte) bool
- func (p *Part) Size() int
- func (p *Part) String() string
type Partition
- func NewPartition(parts ...*Part) *Partition
- func (p *Partition) GetPart(label string) (*Part, bool)
- func (p *Partition) String() string
type ReplicaSet
- func NewReplicaSet() *ReplicaSet
- func (r *ReplicaSet) Add(replica *types.Replica)
- func (r *ReplicaSet) Exists(id types.ReplicaID) bool
- func (r *ReplicaSet) ExistsVal(addr []byte) bool
- func (r *ReplicaSet) GetRandom() *types.Replica
- func (r *ReplicaSet) Iter() []types.ReplicaID
- func (r *ReplicaSet) Size() int
- func (r *ReplicaSet) String() string
type TMessage
- func ChangeProposalBlockIDToNil(replica *types.Replica, pMsg *TMessage) (*TMessage, error)
- func ChangeProposalLockedValue(replica *types.Replica, pMsg *TMessage) (*TMessage, error)
- func ChangeVote(replica *types.Replica, tMsg *TMessage, blockID *ttypes.BlockID) (*TMessage, error)
- func ChangeVoteRound(replica *types.Replica, tMsg *TMessage, round int32) (*TMessage, error)
- func ChangeVoteTime(replica *types.Replica, tMsg *TMessage, add time.Duration) (*TMessage, error)
- func ChangeVoteToNil(replica *types.Replica, voteMsg *TMessage) (*TMessage, error)
- func GetMessageFromEvent(e *types.Event, ctx *testlib.Context) (*TMessage, bool)
- func GetParsedMessage(m *types.Message) (*TMessage, bool)
- func (t *TMessage) Clone() types.ParsedMessage
- func (t *TMessage) Height() int
- func (t *TMessage) HeightRound() (int, int)
- func (t *TMessage) Marshal() ([]byte, error)
- func (t *TMessage) Round() int
- func (t *TMessage) String() string
type TMessageParser
- func (p *TMessageParser) Parse(m []byte) (types.ParsedMessage, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrInvalidVote = errors.New("invalid message type to change vote")
)

Functions ¶

func GetChainID ¶

func GetChainID(r *types.Replica) (string, error)

func GetPrivKey ¶

func GetPrivKey(r *types.Replica) (crypto.PrivKey, error)

Should cache key instead of decoding everytime

func GetProposalBlockID ¶

func GetProposalBlockID(msg *TMessage) (*ttypes.BlockID, bool)

func GetProposalBlockIDS ¶

func GetProposalBlockIDS(msg *TMessage) (string, bool)

func GetReplicaAddress ¶

func GetReplicaAddress(r *types.Replica) ([]byte, error)

func GetVoteBlockID ¶

func GetVoteBlockID(msg *TMessage) (*ttypes.BlockID, bool)

func GetVoteBlockIDS ¶

func GetVoteBlockIDS(msg *TMessage) (string, bool)

func GetVoteTime ¶

func GetVoteTime(msg *TMessage) (time.Time, bool)

func GetVoteValidator ¶

func GetVoteValidator(msg *TMessage) ([]byte, bool)

func IsVoteFrom ¶

func IsVoteFrom(msg *TMessage, replica *types.Replica) bool

Types ¶

type GenericPartitioner ¶

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

func NewGenericPartitioner ¶

func NewGenericPartitioner(replicasStore *types.ReplicaStore) *GenericPartitioner

func (*GenericPartitioner) CreatePartition ¶

func (g *GenericPartitioner) CreatePartition(sizes []int, labels []string) (*Partition, error)

type MessageType ¶

type MessageType string

const (
	NewRoundStep  MessageType = "NewRoundStep"
	NewValidBlock MessageType = "NewValidBlock"
	Proposal      MessageType = "Proposal"
	ProposalPol   MessageType = "ProposalPol"
	BlockPart     MessageType = "BlockPart"
	Vote          MessageType = "Vote"
	Prevote       MessageType = "Prevote"
	Precommit     MessageType = "Precommit"
	HasVote       MessageType = "HasVote"
	VoteSetMaj23  MessageType = "VoteSetMaj23"
	VoteSetBits   MessageType = "VoteSetBits"
	None          MessageType = "None"
)

type Part ¶

type Part struct {
	ReplicaSet *ReplicaSet
	Label      string
}

func (*Part) Contains ¶

func (p *Part) Contains(replica types.ReplicaID) bool

func (*Part) ContainsVal ¶

func (p *Part) ContainsVal(addr []byte) bool

func (*Part) Size ¶

func (p *Part) Size() int

func (*Part) String ¶

func (p *Part) String() string

type Partition ¶

type Partition struct {
	Parts map[string]*Part
	// contains filtered or unexported fields
}

func NewPartition ¶

func NewPartition(parts ...*Part) *Partition

func (*Partition) GetPart ¶

func (p *Partition) GetPart(label string) (*Part, bool)

func (*Partition) String ¶

func (p *Partition) String() string

type ReplicaSet ¶

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

func NewReplicaSet ¶

func NewReplicaSet() *ReplicaSet

func (*ReplicaSet) Add ¶

func (r *ReplicaSet) Add(replica *types.Replica)

func (*ReplicaSet) Exists ¶

func (r *ReplicaSet) Exists(id types.ReplicaID) bool

func (*ReplicaSet) ExistsVal ¶

func (r *ReplicaSet) ExistsVal(addr []byte) bool

func (*ReplicaSet) GetRandom ¶

func (r *ReplicaSet) GetRandom() *types.Replica

func (*ReplicaSet) Iter ¶

func (r *ReplicaSet) Iter() []types.ReplicaID

func (*ReplicaSet) Size ¶

func (r *ReplicaSet) Size() int

func (*ReplicaSet) String ¶

func (r *ReplicaSet) String() string

type TMessage ¶

type TMessage struct {
	ChannelID uint16          `json:"chan_id"`
	MsgB      []byte          `json:"msg"`
	From      types.ReplicaID `json:"from"`
	To        types.ReplicaID `json:"to"`
	Type      MessageType     `json:"-"`
	Data      *tmsg.Message   `json:"-"`
}

func ChangeProposalBlockIDToNil ¶

func ChangeProposalBlockIDToNil(replica *types.Replica, pMsg *TMessage) (*TMessage, error)

func ChangeProposalLockedValue ¶

func ChangeProposalLockedValue(replica *types.Replica, pMsg *TMessage) (*TMessage, error)

func ChangeVote ¶

func ChangeVote(replica *types.Replica, tMsg *TMessage, blockID *ttypes.BlockID) (*TMessage, error)

func ChangeVoteRound ¶

func ChangeVoteRound(replica *types.Replica, tMsg *TMessage, round int32) (*TMessage, error)

func ChangeVoteTime ¶

func ChangeVoteTime(replica *types.Replica, tMsg *TMessage, add time.Duration) (*TMessage, error)

func ChangeVoteToNil ¶

func ChangeVoteToNil(replica *types.Replica, voteMsg *TMessage) (*TMessage, error)

func GetMessageFromEvent ¶

func GetMessageFromEvent(e *types.Event, ctx *testlib.Context) (*TMessage, bool)

func GetParsedMessage ¶

func GetParsedMessage(m *types.Message) (*TMessage, bool)

func (*TMessage) Clone ¶

func (t *TMessage) Clone() types.ParsedMessage

func (*TMessage) Height ¶

func (t *TMessage) Height() int

func (*TMessage) HeightRound ¶

func (t *TMessage) HeightRound() (int, int)

func (*TMessage) Marshal ¶

func (t *TMessage) Marshal() ([]byte, error)

func (*TMessage) Round ¶

func (t *TMessage) Round() int

func (*TMessage) String ¶

func (t *TMessage) String() string

type TMessageParser ¶

type TMessageParser struct {
}

func (*TMessageParser) Parse ¶

func (p *TMessageParser) Parse(m []byte) (types.ParsedMessage, error)

Source Files ¶

View all Source files

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