boot

Documentation

Index

• type Namespace
  • func (n Namespace) Advertise(ctx context.Context, ns string, opt ...discovery.Option) (time.Duration, error)
  • func (n Namespace) FindPeers(ctx context.Context, ns string, opt ...discovery.Option) (<-chan peer.AddrInfo, error)
• type StaticAddrs
  • func NewStaticAddrStrings(ss ...string) (as StaticAddrs, _ error)
  • func NewStaticAddrs(as ...ma.Multiaddr) (StaticAddrs, error)
  • func (as StaticAddrs) Advertise(_ context.Context, _ string, opt ...discovery.Option) (time.Duration, error)
  • func (StaticAddrs) Close() error
  • func (as StaticAddrs) Filter(f func(peer.AddrInfo) bool) StaticAddrs
  • func (as StaticAddrs) FindPeers(_ context.Context, _ string, opt ...discovery.Option) (<-chan peer.AddrInfo, error)
  • func (as StaticAddrs) Len() int
  • func (as StaticAddrs) Less(i, j int) bool
  • func (as StaticAddrs) Swap(i, j int)

Types

type Namespace

type Namespace struct {
	Match   func(string) bool
	Target  discovery.Discovery
	Default discovery.Discovery
}

func (Namespace) Advertise

func (n Namespace) Advertise(ctx context.Context, ns string, opt ...discovery.Option) (time.Duration, error)

func (Namespace) FindPeers

func (n Namespace) FindPeers(ctx context.Context, ns string, opt ...discovery.Option) (<-chan peer.AddrInfo, error)

type StaticAddrs

type StaticAddrs []peer.AddrInfo

StaticAddrs is a set of bootstrap-peer addresses.

func NewStaticAddrStrings

func NewStaticAddrStrings(ss ...string) (as StaticAddrs, _ error)

func NewStaticAddrs

func NewStaticAddrs(as ...ma.Multiaddr) (StaticAddrs, error)

NewStaticAddrs from one or more multiaddrs.

func (StaticAddrs) Advertise

func (as StaticAddrs) Advertise(_ context.Context, _ string, opt ...discovery.Option) (time.Duration, error)

Advertise is a nop that defaults to PermanentAddrTTL.

func (StaticAddrs) Close

func (StaticAddrs) Close() error

Close is a nop method. It exists to satisfy boot.DiscoveryCloser.

func (StaticAddrs) Filter

func (as StaticAddrs) Filter(f func(peer.AddrInfo) bool) StaticAddrs

func (StaticAddrs) FindPeers

func (as StaticAddrs) FindPeers(_ context.Context, _ string, opt ...discovery.Option) (<-chan peer.AddrInfo, error)

FindPeers converts the static addresses into AddrInfos

func (StaticAddrs) Len

func (as StaticAddrs) Len() int

func (StaticAddrs) Less

func (as StaticAddrs) Less(i, j int) bool

func (StaticAddrs) Swap

func (as StaticAddrs) Swap(i, j int)