tss

Documentation

Index

• Variables
• func GetTestID(id int) string
• func GetTestPeers(id int, lens int) []string
• func GetTestPeersByArray(id int, ids []int) []string
• type Message
• type StopPeerManager
  • func NewStopPeerManager[Type ~int32](stopMessageType Type, p types.PeerManager) *StopPeerManager[Type]
  • func (p *StopPeerManager[Type]) MustSend(id string, message interface{})
• type TestPeerManager
  • func NewTestPeerManager(id int, lens int) *TestPeerManager
  • func NewTestPeerManagerWithPeers(id int, peers []string) *TestPeerManager
  • func (p *TestPeerManager) MustSend(id string, message interface{})
  • func (p *TestPeerManager) NumPeers() uint32
  • func (p *TestPeerManager) PeerIDs() []string
  • func (p *TestPeerManager) SelfID() string
  • func (p *TestPeerManager) Set(msgMains map[string]types.MessageMain)

Variables

var (
	ErrInvalidMsg                = errors.New("invalid message")
	ErrNotReady                  = errors.New("not ready")
	ErrPeerNotFound              = errors.New("peer message not found")
	ErrNotEnoughBKs              = errors.New("not enough Birkhoff coefficient")
	ErrSelfBKNotFound            = errors.New("self Birkhoff coefficient not found")
	ErrInvalidBK                 = errors.New("invalid Birkhoff coefficient")
	ErrInconsistentThreshold     = errors.New("inconsistent threshold")
	ErrInconsistentPeerNumAndBks = errors.New("inconsistent peer num and bks")
	ErrInconsistentPubKey        = errors.New("inconsistent public key")
)

Functions

func GetTestID

func GetTestID(id int) string

------------ Below funcs are for testing

func GetTestPeers

func GetTestPeers(id int, lens int) []string

func GetTestPeersByArray

func GetTestPeersByArray(id int, ids []int) []string

Types

type Message

type Message[Type ~int32] interface {
	GetType() Type
}

type StopPeerManager

type StopPeerManager[Type ~int32] struct {
	types.PeerManager
	// contains filtered or unexported fields
}

func NewStopPeerManager

func NewStopPeerManager[Type ~int32](stopMessageType Type, p types.PeerManager) *StopPeerManager[Type]

func (*StopPeerManager[Type]) MustSend

func (p *StopPeerManager[Type]) MustSend(id string, message interface{})

type TestPeerManager

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

func NewTestPeerManager

func NewTestPeerManager(id int, lens int) *TestPeerManager

func NewTestPeerManagerWithPeers

func NewTestPeerManagerWithPeers(id int, peers []string) *TestPeerManager

func (*TestPeerManager) MustSend

func (p *TestPeerManager) MustSend(id string, message interface{})

Only send if the msg main exists

func (*TestPeerManager) NumPeers

func (p *TestPeerManager) NumPeers() uint32

func (*TestPeerManager) PeerIDs

func (p *TestPeerManager) PeerIDs() []string

func (*TestPeerManager) SelfID

func (p *TestPeerManager) SelfID() string

func (*TestPeerManager) Set

func (p *TestPeerManager) Set(msgMains map[string]types.MessageMain)