peermgr

Documentation

Index

• type PeerManager
• type PierManager
• type Piers
  • func (p *Piers) CheckMaster(address string) bool
  • func (p *Piers) HasPier(address string) bool
  • func (p *Piers) HeartBeat(address string, index string) error
  • func (p *Piers) SetMaster(address string, index string, timeout int64) error
• type Swarm
  • func New(repoConfig *repo.Repo, logger logrus.FieldLogger, ledger *ledger.Ledger) (*Swarm, error)
  • func (swarm *Swarm) AddNode(newNodeID uint64, vpInfo *pb.VpInfo)
  • func (swarm *Swarm) AskPierMaster(address string) (bool, error)
  • func (swarm *Swarm) AsyncSend(id orderPeerMgr.KeyType, msg *pb.Message) error
  • func (swarm *Swarm) Broadcast(msg *pb.Message) error
  • func (swarm *Swarm) CountConnectedPeers() uint64
  • func (swarm *Swarm) DelNode(delID uint64)
  • func (swarm *Swarm) Disconnect(vpInfos map[uint64]*pb.VpInfo)
  • func (swarm *Swarm) OrderPeers() map[uint64]*pb.VpInfo
  • func (swarm *Swarm) OtherPeers() map[uint64]*peer.AddrInfo
  • func (swarm *Swarm) Peers() map[string]*peer.AddrInfo
  • func (swarm *Swarm) PierManager() PierManager
  • func (swarm *Swarm) Piers() *Piers
  • func (swarm *Swarm) Ping()
  • func (swarm *Swarm) ReConfig(config interface{}) error
  • func (swarm *Swarm) Send(id orderPeerMgr.KeyType, msg *pb.Message) (*pb.Message, error)
  • func (swarm *Swarm) SendWithStream(s network.Stream, msg *pb.Message) error
  • func (swarm *Swarm) Start() error
  • func (swarm *Swarm) Stop() error
  • func (swarm *Swarm) SubscribeOrderMessage(ch chan<- orderPeerMgr.OrderMessageEvent) event.Subscription
  • func (swarm *Swarm) SubscribeTssMessage(ch chan<- *pb.Message) event.Subscription
  • func (swarm *Swarm) SubscribeTssSignRes(ch chan<- *pb.Message) event.Subscription
  • func (swarm *Swarm) UpdateRouter(vpInfos map[uint64]*pb.VpInfo, isNew bool) bool

Types

type PeerManager

type PeerManager interface {
	orderPeerMgr.OrderPeerManager

	orderPeerMgr.TssPeerManager

	// SendWithStream sends message using existed stream
	SendWithStream(network.Stream, *pb.Message) error

	// PierManager
	PierManager() PierManager

	// ReConfig
	ReConfig(config interface{}) error
}

type PierManager

type PierManager interface {
	Piers() *Piers

	AskPierMaster(string) (bool, error)
}

type Piers

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

func (*Piers) CheckMaster

func (p *Piers) CheckMaster(address string) bool

func (*Piers) HasPier

func (p *Piers) HasPier(address string) bool

func (*Piers) HeartBeat

func (p *Piers) HeartBeat(address string, index string) error

func (*Piers) SetMaster

func (p *Piers) SetMaster(address string, index string, timeout int64) error

type Swarm

type Swarm struct {
	Tss tss.Tss
	// contains filtered or unexported fields
}

func New

func New(repoConfig *repo.Repo, logger logrus.FieldLogger, ledger *ledger.Ledger) (*Swarm, error)

func (*Swarm) AddNode

func (swarm *Swarm) AddNode(newNodeID uint64, vpInfo *pb.VpInfo)

func (*Swarm) AskPierMaster

func (swarm *Swarm) AskPierMaster(address string) (bool, error)

func (*Swarm) AsyncSend

func (swarm *Swarm) AsyncSend(id orderPeerMgr.KeyType, msg *pb.Message) error

func (*Swarm) Broadcast

func (swarm *Swarm) Broadcast(msg *pb.Message) error

func (*Swarm) CountConnectedPeers

func (swarm *Swarm) CountConnectedPeers() uint64

func (*Swarm) DelNode

func (swarm *Swarm) DelNode(delID uint64)

func (*Swarm) Disconnect

func (swarm *Swarm) Disconnect(vpInfos map[uint64]*pb.VpInfo)

func (*Swarm) OrderPeers

func (swarm *Swarm) OrderPeers() map[uint64]*pb.VpInfo

func (*Swarm) OtherPeers

func (swarm *Swarm) OtherPeers() map[uint64]*peer.AddrInfo

func (*Swarm) Peers

func (swarm *Swarm) Peers() map[string]*peer.AddrInfo

func (*Swarm) PierManager

func (swarm *Swarm) PierManager() PierManager

func (*Swarm) Piers

func (swarm *Swarm) Piers() *Piers

func (*Swarm) Ping

func (swarm *Swarm) Ping()

func (*Swarm) ReConfig

func (swarm *Swarm) ReConfig(config interface{}) error

func (*Swarm) Send

func (swarm *Swarm) Send(id orderPeerMgr.KeyType, msg *pb.Message) (*pb.Message, error)

func (*Swarm) SendWithStream

func (swarm *Swarm) SendWithStream(s network.Stream, msg *pb.Message) error

func (*Swarm) Start

func (swarm *Swarm) Start() error

func (*Swarm) Stop

func (swarm *Swarm) Stop() error

func (*Swarm) SubscribeOrderMessage

func (swarm *Swarm) SubscribeOrderMessage(ch chan<- orderPeerMgr.OrderMessageEvent) event.Subscription

func (*Swarm) SubscribeTssMessage

func (swarm *Swarm) SubscribeTssMessage(ch chan<- *pb.Message) event.Subscription

func (*Swarm) SubscribeTssSignRes

func (swarm *Swarm) SubscribeTssSignRes(ch chan<- *pb.Message) event.Subscription

func (*Swarm) UpdateRouter

func (swarm *Swarm) UpdateRouter(vpInfos map[uint64]*pb.VpInfo, isNew bool) bool