types

package

Go to main page

Versions in this module

v1

v1.65.0

Sep 25, 2020

Changes in this version

+ func ReadStreamTimeout(data types.Message, stream core.Stream, timeout time.Duration) error

type BaseStreamHandler

+ func (s *BaseStreamHandler) ReuseStream() bool

+ type IConnManager interface

+ BandTrackerByProtocol func() *types.NetProtocolInfos

+ BoundSize func() (in int, out int)

+ FetchConnPeers func() []peer.ID

+ GetLatencyByPeer func(pids []peer.ID) map[string]time.Duration

+ GetNetRate func() metrics.Stats

+ IsNeighbors func(id peer.ID) bool

+ RateCaculate func(ratebytes float64) string

+ type IPeerInfoManager interface

+ Add func(pid string, info *types.Peer)

+ Copy func(dest *types.Peer, source *types.P2PPeerInfo)

+ FetchPeerInfosInMin func() []*types.Peer

+ GetPeerInfoInMin func(key string) *types.Peer

type P2PEnv

+ Ctx context.Context

+ DB ds.Datastore

+ Pubsub *net.PubSub

+ RoutingTable *kbt.RoutingTable

+ type RoutingTabler interface

+ RoutingTable func() *kbt.RoutingTable

type StreamHandler

+ ReuseStream func() bool

v1.64.0

May 25, 2020

Changes in this version

+ func AuthenticateMessage(message types.Message, data *types.MessageComm) bool

+ func ClearEventHandler()

+ func CloseStream(stream core.Stream)

+ func NewStream(host core.Host, pid core.PeerID, msgID string) (core.Stream, error)

+ func ReadStream(data types.Message, stream core.Stream) error

+ func RegisterEventHandler(eventID int64, handler EventHandler)

+ func RegisterProtocol(typeName string, proto IProtocol)

+ func RegisterStreamHandler(typeName, msgID string, handler StreamHandler)

+ func SignProtoMessage(message types.Message, host core.Host) ([]byte, error)

+ func WriteStream(data types.Message, stream core.Stream) error

+ type BaseProtocol struct

+ func (base *BaseProtocol) GetChainCfg() *types.Chain33Config

+ func (base *BaseProtocol) GetConnsManager() *manage.ConnManager

+ func (base *BaseProtocol) GetHost() core.Host

+ func (base *BaseProtocol) GetP2PEnv() *P2PEnv

+ func (base *BaseProtocol) GetPeerInfoManager() *manage.PeerInfoManager

+ func (base *BaseProtocol) GetQueueClient() queue.Client

+ func (base *BaseProtocol) InitProtocol(data *P2PEnv)

+ func (base *BaseProtocol) NewMessageCommon(msgID, pid string, nodePubkey []byte, gossip bool) *types.MessageComm

+ func (base *BaseProtocol) QueryBlockChain(ty int64, req interface{}) (interface{}, error)

+ func (base *BaseProtocol) QueryMempool(ty int64, req interface{}) (interface{}, error)

+ func (base *BaseProtocol) QueryModule(module string, msgTy int64, req interface{}) (interface{}, error)

+ func (base *BaseProtocol) SendPeer(req *StreamRequest) error

+ func (base *BaseProtocol) SendRecvPeer(req *StreamRequest, resp types.Message) error

+ type BaseStreamHandler struct

+ Protocol IProtocol

+ func (s *BaseStreamHandler) GetProtocol() IProtocol

+ func (s *BaseStreamHandler) Handle(core.Stream)

+ func (s *BaseStreamHandler) HandleStream(stream core.Stream)

+ func (s *BaseStreamHandler) SetProtocol(protocol IProtocol)

+ func (s *BaseStreamHandler) SignProtoMessage(message types.Message, host core.Host) ([]byte, error)

+ func (s *BaseStreamHandler) VerifyRequest(message types.Message, messageComm *types.MessageComm) bool

+ type EventHandler func(*queue.Message)

+ func GetEventHandler(eventID int64) (EventHandler, bool)

+ type IProtocol interface

+ GetP2PEnv func() *P2PEnv

+ InitProtocol func(*P2PEnv)

+ type P2PEnv struct

+ ChainCfg *types.Chain33Config

+ ConnManager *manage.ConnManager

+ Discovery *net.Discovery

+ Host core.Host

+ P2PManager *p2p.Manager

+ PeerInfoManager *manage.PeerInfoManager

+ QueueClient queue.Client

+ SubConfig *p2pty.P2PSubConfig

+ type ProtocolManager struct

+ func (p *ProtocolManager) Init(env *P2PEnv)

+ type StreamHandler interface

+ GetProtocol func() IProtocol

+ Handle func(stream core.Stream)

+ SetProtocol func(protocol IProtocol)

+ SignProtoMessage func(message types.Message, host core.Host) ([]byte, error)

+ VerifyRequest func(message types.Message, messageComm *types.MessageComm) bool

+ type StreamRequest struct

+ Data types.Message

+ MsgID string

+ PeerID core.PeerID

Other modules containing this package

github.com/33cn/chain33/v6

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