net

package

v1.0.0-alpha.1 Latest Latest Go to latest Published: Jun 1, 2021 License: Apache-2.0, MIT Imports: 13 Imported by: 0

Details

View Source

const DefaultTTL = time.Hour * 8766

This section is empty.

func WithPeerID(id peer.ID) discovery.Option

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

func New(t Timer) *Env

func (env Env) NewDiscovery(info peer.AddrInfo, t Topology) discovery.Discovery

func (env Env) NewHost(ctx context.Context, opt ...config.Option) (host.Host, error)

NewHost returns a new host with a random identity and the default in-process transport.

type InfoSlice []*peer.AddrInfo

func (is InfoSlice) Len() int

func (is InfoSlice) Less(i, j int) bool

func (is InfoSlice) Swap(i, j int)

type Namespace interface {
	Peers() InfoSlice
	Upsert(*peer.AddrInfo, *discovery.Options) time.Duration
}

type NamespaceProvider interface {
	Load(ns string) (Namespace, bool)
	LoadOrCreate(ns string) Namespace
}

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

func (s SelectAll) Select(_ context.Context, ns Namespace, opts *discovery.Options) (InfoSlice, error)

func (SelectAll) SetDefaultOptions(*discovery.Options) error

type SelectRandom struct {
	Src rand.Source
	// contains filtered or unexported fields
}

func (r *SelectRandom) Select(_ context.Context, ns Namespace, opts *discovery.Options) (InfoSlice, error)

func (SelectRandom) SetDefaultOptions(*discovery.Options) error

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

func (s SelectRing) Select(_ context.Context, ns Namespace, opts *discovery.Options) (InfoSlice, error)

func (SelectRing) SetDefaultOptions(*discovery.Options) error

type Timer interface {
	After(d time.Duration, callback func()) clock.CancelFunc
}

type Topology interface {
	SetDefaultOptions(*discovery.Options) error
	Select(context.Context, Namespace, *discovery.Options) (InfoSlice, error)
}

Topology selects peeers from the environment.