p2p

Apr 29, 2019

Changes in this version

+ var ProtocolDHT protocol.ID = "/iotex/kad/1.0.0"

Apr 12, 2019

Changes in this version

+ var DefaultRatelimitConfig = RateLimitConfig

type Config

+ EnableRateLimit bool

type Option

+ func WithRateLimit(rcfg RateLimitConfig) Option

+ type RateLimitConfig struct

+ GlobalUnicastAvg int

+ GlobalUnicastBurst int

+ PeerAvg int

+ PeerBurst int

Apr 11, 2019

Changes in this version

type Config

+ AvgNumMsgsPerSec int

+ BlackListCleanupInterval time.Duration

+ BlackListLRUSize int

+ BurstNumMsgsPerSec int

+ RateLimit bool

+ RateLimiterLRUSize int

+ ValidationChanSize int

+ type LRUBlacklist struct

+ func NewLRUBlacklist(cap int) (*LRUBlacklist, error)

+ func (b *LRUBlacklist) Add(p peer.ID)

+ func (b *LRUBlacklist) Contains(p peer.ID) bool

+ func (b *LRUBlacklist) Remove(p peer.ID)

+ func (b *LRUBlacklist) RemoveOldest()

type Option

+ func RateLimit() Option

Apr 11, 2019

Changes in this version

type Config

+ ConnGracePeriod time.Duration

+ ConnHighWater int

+ ConnLowWater int

type Option

+ func WithConnectionManagerConfig(lo, hi int, grace time.Duration) Option

Mar 14, 2019

Changes in this version

+ var DefaultConfig = Config

+ func EnsureIPv4(ipOrHost string) (string, error)

+ func GetBroadcastMsg(ctx context.Context) (*pubsub.Message, bool)

+ func GetUnicastStream(ctx context.Context) (net.Stream, bool)

+ func Logger() *zap.Logger

+ func SetLogger(l *zap.Logger)

+ type Config struct

+ ConnectTimeout time.Duration

+ ExternalHostName string

+ ExternalPort int

+ Gossip bool

+ HostName string

+ MasterKey string

+ Port int

+ Relay string

+ SecureIO bool

+ type HandleBroadcast func(ctx context.Context, data []byte) error

+ type HandleUnicast func(ctx context.Context, w io.Writer, data []byte) error

+ type Host struct

+ func NewHost(ctx context.Context, options ...Option) (*Host, error)

+ func (h *Host) AddBroadcastPubSub(topic string, callback HandleBroadcast) error

+ func (h *Host) AddUnicastPubSub(topic string, callback HandleUnicast) error

+ func (h *Host) Addresses() []multiaddr.Multiaddr

+ func (h *Host) Broadcast(topic string, data []byte) error

+ func (h *Host) Close() error

+ func (h *Host) Connect(ctx context.Context, target peerstore.PeerInfo) error

+ func (h *Host) ConnectWithMultiaddr(ctx context.Context, ma multiaddr.Multiaddr) error

+ func (h *Host) HostIdentity() string

+ func (h *Host) Info() peerstore.PeerInfo

+ func (h *Host) JoinOverlay(ctx context.Context) error

+ func (h *Host) Neighbors(ctx context.Context) ([]peerstore.PeerInfo, error)

+ func (h *Host) OverlayIdentity() string

+ func (h *Host) Unicast(ctx context.Context, target peerstore.PeerInfo, topic string, data []byte) error

+ type Option func(cfg *Config) error

+ func ConnectTimeout(timout time.Duration) Option

+ func ExternalHostName(externalHostName string) Option

+ func ExternalPort(externalPort int) Option

+ func Gossip() Option

+ func HostName(hostName string) Option

+ func MasterKey(masterKey string) Option

+ func Port(port int) Option

+ func SecureIO() Option

+ func WithRelay(relayType string) Option