mock

Documentation

Index

• func WithBroadcastPeers(f func(context.Context, boson.Address, ...boson.Address) error) optionFunc
• type Discovery
  • func NewDiscovery(opts ...Option) *Discovery
  • func (d *Discovery) AddresseeRecords(addressee boson.Address) (peers []boson.Address, exists bool)
  • func (d *Discovery) BroadcastPeers(ctx context.Context, addressee boson.Address, peers ...boson.Address) error
  • func (d *Discovery) Broadcasts() int
  • func (d *Discovery) DoFindNode(ctx context.Context, target, peer boson.Address, pos []int32, limit int32) (res chan boson.Address, err error)
  • func (d *Discovery) IsHive2() bool
  • func (d *Discovery) IsStart() bool
  • func (d *Discovery) NotifyDiscoverWork(peers ...boson.Address)
  • func (d *Discovery) Reset()
  • func (d *Discovery) SetHive2(is bool)
• type Option

Functions

func WithBroadcastPeers

func WithBroadcastPeers(f func(context.Context, boson.Address, ...boson.Address) error) optionFunc

Types

type Discovery

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

func NewDiscovery

func NewDiscovery(opts ...Option) *Discovery

func (*Discovery) AddresseeRecords

func (d *Discovery) AddresseeRecords(addressee boson.Address) (peers []boson.Address, exists bool)

func (*Discovery) BroadcastPeers

func (d *Discovery) BroadcastPeers(ctx context.Context, addressee boson.Address, peers ...boson.Address) error

func (*Discovery) Broadcasts

func (d *Discovery) Broadcasts() int

func (*Discovery) DoFindNode

func (d *Discovery) DoFindNode(ctx context.Context, target, peer boson.Address, pos []int32, limit int32) (res chan boson.Address, err error)

func (*Discovery) IsHive2

func (d *Discovery) IsHive2() bool

func (*Discovery) IsStart

func (d *Discovery) IsStart() bool

func (*Discovery) NotifyDiscoverWork

func (d *Discovery) NotifyDiscoverWork(peers ...boson.Address)

func (*Discovery) Reset

func (d *Discovery) Reset()

func (*Discovery) SetHive2

func (d *Discovery) SetHive2(is bool)

type Option

type Option interface {
	// contains filtered or unexported methods
}