You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
72 lines
1.5 KiB
72 lines
1.5 KiB
package dummy
|
|
|
|
import (
|
|
p2p "github.com/tendermint/tendermint/p2p"
|
|
tmconn "github.com/tendermint/tendermint/p2p/conn"
|
|
cmn "github.com/tendermint/tmlibs/common"
|
|
)
|
|
|
|
type peer struct {
|
|
cmn.BaseService
|
|
kv map[string]interface{}
|
|
}
|
|
|
|
var _ p2p.Peer = (*peer)(nil)
|
|
|
|
// NewPeer creates new dummy peer.
|
|
func NewPeer() *peer {
|
|
p := &peer{
|
|
kv: make(map[string]interface{}),
|
|
}
|
|
p.BaseService = *cmn.NewBaseService(nil, "peer", p)
|
|
return p
|
|
}
|
|
|
|
// ID always returns dummy.
|
|
func (p *peer) ID() p2p.ID {
|
|
return p2p.ID("dummy")
|
|
}
|
|
|
|
// IsOutbound always returns false.
|
|
func (p *peer) IsOutbound() bool {
|
|
return false
|
|
}
|
|
|
|
// IsPersistent always returns false.
|
|
func (p *peer) IsPersistent() bool {
|
|
return false
|
|
}
|
|
|
|
// NodeInfo always returns empty node info.
|
|
func (p *peer) NodeInfo() p2p.NodeInfo {
|
|
return p2p.NodeInfo{}
|
|
}
|
|
|
|
// Status always returns empry connection status.
|
|
func (p *peer) Status() tmconn.ConnectionStatus {
|
|
return tmconn.ConnectionStatus{}
|
|
}
|
|
|
|
// Send does not do anything and just returns true.
|
|
func (p *peer) Send(byte, interface{}) bool {
|
|
return true
|
|
}
|
|
|
|
// TrySend does not do anything and just returns true.
|
|
func (p *peer) TrySend(byte, interface{}) bool {
|
|
return true
|
|
}
|
|
|
|
// Set records value under key specified in the map.
|
|
func (p *peer) Set(key string, value interface{}) {
|
|
p.kv[key] = value
|
|
}
|
|
|
|
// Get returns a value associated with the key. Nil is returned if no value
|
|
// found.
|
|
func (p *peer) Get(key string) interface{} {
|
|
if value, ok := p.kv[key]; ok {
|
|
return value
|
|
}
|
|
return nil
|
|
}
|