peer

Documentation

Index

• Variables
• type DiscoveryClient
  • func NewDiscoveryClient(opts DiscoveryOptions, transport *transport.Transport) *DiscoveryClient
  • func (dc *DiscoveryClient) DidReceiveMessage(from id.Signatory, msg wire.Msg) error
  • func (dc *DiscoveryClient) DiscoverPeers(ctx context.Context)
• type DiscoveryOptions
  • func DefaultDiscoveryOptions() DiscoveryOptions
• type Gossiper
  • func NewGossiper(opts GossiperOptions, filter *channel.SyncFilter, ...) *Gossiper
  • func (g *Gossiper) DidReceiveMessage(from id.Signatory, msg wire.Msg) error
  • func (g *Gossiper) Gossip(ctx context.Context, contentID []byte, subnet *id.Hash)
  • func (g *Gossiper) Resolve(resolver dht.ContentResolver)
• type GossiperOptions
  • func DefaultGossiperOptions() GossiperOptions
  • func (opts GossiperOptions) WithAlpha(alpha int) GossiperOptions
  • func (opts GossiperOptions) WithLogger(logger *zap.Logger) GossiperOptions
  • func (opts GossiperOptions) WithTimeout(timeout time.Duration) GossiperOptions
• type Options
  • func DefaultOptions() Options
  • func (opts Options) WithGossiperOptions(gossiperOptions GossiperOptions) Options
  • func (opts Options) WithLogger(logger *zap.Logger) Options
  • func (opts Options) WithPrivKey(privKey *id.PrivKey) Options
  • func (opts Options) WithSyncerOptions(syncerOptions SyncerOptions) Options
• type Peer
  • func New(opts Options, transport *transport.Transport) *Peer
  • func (p *Peer) DiscoverPeers(ctx context.Context)
  • func (p *Peer) Gossip(ctx context.Context, contentID []byte, subnet *id.Hash)
  • func (p *Peer) Gossiper() *Gossiper
  • func (p *Peer) ID() id.Signatory
  • func (p *Peer) Link(remote id.Signatory)
  • func (p *Peer) Ping(ctx context.Context) error
  • func (p *Peer) Receive(ctx context.Context, f func(id.Signatory, wire.Msg) error)
  • func (p *Peer) Resolve(ctx context.Context, contentResolver dht.ContentResolver)
  • func (p *Peer) Run(ctx context.Context)
  • func (p *Peer) Send(ctx context.Context, to id.Signatory, msg wire.Msg) error
  • func (p *Peer) Sync(ctx context.Context, contentID []byte, hint *id.Signatory) ([]byte, error)
  • func (p *Peer) Syncer() *Syncer
  • func (p *Peer) Transport() *transport.Transport
  • func (p *Peer) Unlink(remote id.Signatory)
• type Syncer
  • func NewSyncer(opts SyncerOptions, filter *channel.SyncFilter, transport *transport.Transport) *Syncer
  • func (syncer *Syncer) DidReceiveMessage(from id.Signatory, msg wire.Msg) error
  • func (syncer *Syncer) Sync(ctx context.Context, contentID []byte, hint *id.Signatory) ([]byte, error)
• type SyncerOptions
  • func DefaultSyncerOptions() SyncerOptions
  • func (opts SyncerOptions) WithAlpha(alpha int) SyncerOptions
  • func (opts SyncerOptions) WithLogger(logger *zap.Logger) SyncerOptions
  • func (opts SyncerOptions) WithWiggleTimeout(timeout time.Duration) SyncerOptions

Variables

var (
	DefaultSubnet  = id.Hash{0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF}
	DefaultAlpha   = 5
	DefaultTimeout = time.Second
)

var (
	ErrPeerNotFound = errors.New("peer not found")
)

Types

type DiscoveryClient

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

func NewDiscoveryClient

func NewDiscoveryClient(opts DiscoveryOptions, transport *transport.Transport) *DiscoveryClient

func (*DiscoveryClient) DidReceiveMessage

func (dc *DiscoveryClient) DidReceiveMessage(from id.Signatory, msg wire.Msg) error

func (*DiscoveryClient) DiscoverPeers

func (dc *DiscoveryClient) DiscoverPeers(ctx context.Context)

type DiscoveryOptions

type DiscoveryOptions struct {
	Logger           *zap.Logger
	Alpha            int
	MaxExpectedPeers int
	PingTimePeriod   time.Duration
}

func DefaultDiscoveryOptions

func DefaultDiscoveryOptions() DiscoveryOptions

type Gossiper

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

func NewGossiper

func NewGossiper(opts GossiperOptions, filter *channel.SyncFilter, transport *transport.Transport) *Gossiper

func (*Gossiper) DidReceiveMessage

func (g *Gossiper) DidReceiveMessage(from id.Signatory, msg wire.Msg) error

func (*Gossiper) Gossip

func (g *Gossiper) Gossip(ctx context.Context, contentID []byte, subnet *id.Hash)

func (*Gossiper) Resolve

func (g *Gossiper) Resolve(resolver dht.ContentResolver)

type GossiperOptions

type GossiperOptions struct {
	Logger  *zap.Logger
	Alpha   int
	Timeout time.Duration
}

func DefaultGossiperOptions

func DefaultGossiperOptions() GossiperOptions

func (GossiperOptions) WithAlpha

func (opts GossiperOptions) WithAlpha(alpha int) GossiperOptions

func (GossiperOptions) WithLogger

func (opts GossiperOptions) WithLogger(logger *zap.Logger) GossiperOptions

func (GossiperOptions) WithTimeout

func (opts GossiperOptions) WithTimeout(timeout time.Duration) GossiperOptions

type Options

type Options struct {
	SyncerOptions
	GossiperOptions
	DiscoveryOptions

	Logger  *zap.Logger
	PrivKey *id.PrivKey
}

func DefaultOptions

func DefaultOptions() Options

func (Options) WithGossiperOptions

func (opts Options) WithGossiperOptions(gossiperOptions GossiperOptions) Options

func (Options) WithLogger

func (opts Options) WithLogger(logger *zap.Logger) Options

func (Options) WithPrivKey

func (opts Options) WithPrivKey(privKey *id.PrivKey) Options

func (Options) WithSyncerOptions

func (opts Options) WithSyncerOptions(syncerOptions SyncerOptions) Options

type Peer

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

func New

func New(opts Options, transport *transport.Transport) *Peer

func (*Peer) DiscoverPeers

func (p *Peer) DiscoverPeers(ctx context.Context)

func (*Peer) Gossip

func (p *Peer) Gossip(ctx context.Context, contentID []byte, subnet *id.Hash)

func (*Peer) Gossiper

func (p *Peer) Gossiper() *Gossiper

func (*Peer) ID

func (p *Peer) ID() id.Signatory

func (*Peer) Link

func (p *Peer) Link(remote id.Signatory)

func (*Peer) Ping

func (p *Peer) Ping(ctx context.Context) error

func (*Peer) Receive

func (p *Peer) Receive(ctx context.Context, f func(id.Signatory, wire.Msg) error)

func (*Peer) Resolve

func (p *Peer) Resolve(ctx context.Context, contentResolver dht.ContentResolver)

func (*Peer) Run

func (p *Peer) Run(ctx context.Context)

func (*Peer) Send

func (p *Peer) Send(ctx context.Context, to id.Signatory, msg wire.Msg) error

func (*Peer) Sync

func (p *Peer) Sync(ctx context.Context, contentID []byte, hint *id.Signatory) ([]byte, error)

func (*Peer) Syncer

func (p *Peer) Syncer() *Syncer

func (*Peer) Transport

func (p *Peer) Transport() *transport.Transport

func (*Peer) Unlink

func (p *Peer) Unlink(remote id.Signatory)

type Syncer

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

func NewSyncer

func NewSyncer(opts SyncerOptions, filter *channel.SyncFilter, transport *transport.Transport) *Syncer

func (*Syncer) DidReceiveMessage

func (syncer *Syncer) DidReceiveMessage(from id.Signatory, msg wire.Msg) error

func (*Syncer) Sync

func (syncer *Syncer) Sync(ctx context.Context, contentID []byte, hint *id.Signatory) ([]byte, error)

type SyncerOptions

type SyncerOptions struct {
	Logger        *zap.Logger
	Alpha         int
	WiggleTimeout time.Duration
}

func DefaultSyncerOptions

func DefaultSyncerOptions() SyncerOptions

func (SyncerOptions) WithAlpha

func (opts SyncerOptions) WithAlpha(alpha int) SyncerOptions

func (SyncerOptions) WithLogger

func (opts SyncerOptions) WithLogger(logger *zap.Logger) SyncerOptions

func (SyncerOptions) WithWiggleTimeout

func (opts SyncerOptions) WithWiggleTimeout(timeout time.Duration) SyncerOptions