Documentation ¶
Index ¶
- type ConsensusData
- type GRPCDialer
- type HighwayDiscoverer
- type Host
- func (_m *Host) Addrs() []multiaddr.Multiaddr
- func (_m *Host) Close() error
- func (_m *Host) ConnManager() connmgr.ConnManager
- func (_m *Host) Connect(ctx context.Context, pi peer.AddrInfo) error
- func (_m *Host) EventBus() event.Bus
- func (_m *Host) ID() peer.ID
- func (_m *Host) Mux() protocol.Switch
- func (_m *Host) Network() network.Network
- func (_m *Host) NewStream(ctx context.Context, p peer.ID, pids ...protocol.ID) (network.Stream, error)
- func (_m *Host) Peerstore() peerstore.Peerstore
- func (_m *Host) RemoveStreamHandler(pid protocol.ID)
- func (_m *Host) SetStreamHandler(pid protocol.ID, handler network.StreamHandler)
- func (_m *Host) SetStreamHandlerMatch(_a0 protocol.ID, _a1 func(string) bool, _a2 network.StreamHandler)
- type Network
- func (_m *Network) Close() error
- func (_m *Network) ClosePeer(_a0 peer.ID) error
- func (_m *Network) Connectedness(_a0 peer.ID) network.Connectedness
- func (_m *Network) Conns() []network.Conn
- func (_m *Network) ConnsToPeer(p peer.ID) []network.Conn
- func (_m *Network) DialPeer(_a0 context.Context, _a1 peer.ID) (network.Conn, error)
- func (_m *Network) InterfaceListenAddresses() ([]multiaddr.Multiaddr, error)
- func (_m *Network) Listen(_a0 ...multiaddr.Multiaddr) error
- func (_m *Network) ListenAddresses() []multiaddr.Multiaddr
- func (_m *Network) LocalPeer() peer.ID
- func (_m *Network) NewStream(_a0 context.Context, _a1 peer.ID) (network.Stream, error)
- func (_m *Network) Notify(_a0 network.Notifiee)
- func (_m *Network) Peers() []peer.ID
- func (_m *Network) Peerstore() peerstore.Peerstore
- func (_m *Network) Process() goprocess.Process
- func (_m *Network) SetConnHandler(_a0 network.ConnHandler)
- func (_m *Network) SetStreamHandler(_a0 network.StreamHandler)
- func (_m *Network) StopNotify(_a0 network.Notifiee)
- type Registerer
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsensusData ¶
ConsensusData is an autogenerated mock type for the ConsensusData type
func (*ConsensusData) GetOneValidator ¶
func (_m *ConsensusData) GetOneValidator() *consensus.Validator
GetOneValidator provides a mock function with given fields:
func (*ConsensusData) GetOneValidatorForEachConsensusProcess ¶
func (_m *ConsensusData) GetOneValidatorForEachConsensusProcess() map[int]*consensus.Validator
GetOneValidatorForEachConsensusProcess provides a mock function with given fields:
type GRPCDialer ¶
GRPCDialer is an autogenerated mock type for the GRPCDialer type
func (*GRPCDialer) Dial ¶
func (_m *GRPCDialer) Dial(ctx context.Context, peerID peer.ID, dialOpts ...grpc.DialOption) (*grpc.ClientConn, error)
Dial provides a mock function with given fields: ctx, peerID, dialOpts
type HighwayDiscoverer ¶
HighwayDiscoverer is an autogenerated mock type for the HighwayDiscoverer type
func (*HighwayDiscoverer) DiscoverHighway ¶
func (_m *HighwayDiscoverer) DiscoverHighway(discoverPeerAddress string, shardsStr []string) (map[string][]rpcclient.HighwayAddr, error)
DiscoverHighway provides a mock function with given fields: discoverPeerAddress, shardsStr
type Host ¶
Host is an autogenerated mock type for the Host type
func (*Host) ConnManager ¶
func (_m *Host) ConnManager() connmgr.ConnManager
ConnManager provides a mock function with given fields:
func (*Host) NewStream ¶
func (_m *Host) NewStream(ctx context.Context, p peer.ID, pids ...protocol.ID) (network.Stream, error)
NewStream provides a mock function with given fields: ctx, p, pids
func (*Host) RemoveStreamHandler ¶
RemoveStreamHandler provides a mock function with given fields: pid
func (*Host) SetStreamHandler ¶
func (_m *Host) SetStreamHandler(pid protocol.ID, handler network.StreamHandler)
SetStreamHandler provides a mock function with given fields: pid, handler
func (*Host) SetStreamHandlerMatch ¶
func (_m *Host) SetStreamHandlerMatch(_a0 protocol.ID, _a1 func(string) bool, _a2 network.StreamHandler)
SetStreamHandlerMatch provides a mock function with given fields: _a0, _a1, _a2
type Network ¶
Network is an autogenerated mock type for the Network type
func (*Network) Connectedness ¶
func (_m *Network) Connectedness(_a0 peer.ID) network.Connectedness
Connectedness provides a mock function with given fields: _a0
func (*Network) ConnsToPeer ¶
ConnsToPeer provides a mock function with given fields: p
func (*Network) InterfaceListenAddresses ¶
InterfaceListenAddresses provides a mock function with given fields:
func (*Network) ListenAddresses ¶
ListenAddresses provides a mock function with given fields:
func (*Network) SetConnHandler ¶
func (_m *Network) SetConnHandler(_a0 network.ConnHandler)
SetConnHandler provides a mock function with given fields: _a0
func (*Network) SetStreamHandler ¶
func (_m *Network) SetStreamHandler(_a0 network.StreamHandler)
SetStreamHandler provides a mock function with given fields: _a0
func (*Network) StopNotify ¶
StopNotify provides a mock function with given fields: _a0
type Registerer ¶
Registerer is an autogenerated mock type for the Registerer type
func (*Registerer) Register ¶
func (_m *Registerer) Register(_a0 context.Context, _a1 string, _a2 []string, _a3 []byte, _a4 peer.ID, _a5 string) ([]*proto.MessageTopicPair, *proto.UserRole, error)
Register provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4, _a5
func (*Registerer) Target ¶
func (_m *Registerer) Target() string
Target provides a mock function with given fields:
func (*Registerer) UpdateTarget ¶
func (_m *Registerer) UpdateTarget(_a0 peer.ID)
UpdateTarget provides a mock function with given fields: _a0
type Subscriber ¶
Subscriber is an autogenerated mock type for the Subscriber type
func (*Subscriber) Subscribe ¶
func (_m *Subscriber) Subscribe(topic string, opts ...pubsub.SubOpt) (*pubsub.Subscription, error)
Subscribe provides a mock function with given fields: topic, opts