resolver

Documentation

Index

• Constants
• func WithBoostrapPeers(ps ...*peer.ConnectionInfo) func(*resolver)
• type LookupFilter
• type LookupOption
  • func LookupByHash(hash tilde.Digest) LookupOption
  • func LookupByPeerKey(keys ...crypto.PublicKey) LookupOption
  • func LookupOnlyLocal() LookupOption
• type LookupOptions
  • func ParseLookupOptions(opts ...LookupOption) *LookupOptions
  • func (l LookupOptions) Match(p *hyperspace.Announcement) bool
• type Option
• type Resolver
  • func New(ctx context.Context, net network.Network, str *sqlobjectstore.Store, ...) Resolver
• type TildeDigestSyncList
  • func (m *TildeDigestSyncList) Delete(k tilde.Digest)
  • func (m *TildeDigestSyncList) Exists(k tilde.Digest) bool
  • func (m *TildeDigestSyncList) List() []tilde.Digest
  • func (m *TildeDigestSyncList) Put(k tilde.Digest)
  • func (m *TildeDigestSyncList) Range(i func(k tilde.Digest) bool)

Constants

const (
	ErrNoPeersToAsk = errors.Error("no peers to ask")
)

Functions

func WithBoostrapPeers

func WithBoostrapPeers(ps ...*peer.ConnectionInfo) func(*resolver)

WithBoostrapPeers overrides the default bootstrap peers for the resolver.

Types

type LookupFilter

type LookupFilter func(*hyperspace.Announcement) bool

LookupOptions

type LookupOption

type LookupOption func(*LookupOptions)

LookupOptions

func LookupByHash

func LookupByHash(hash tilde.Digest) LookupOption

LookupByHash matches content hashes

func LookupByPeerKey

func LookupByPeerKey(keys ...crypto.PublicKey) LookupOption

LookupByPeerKey matches the peer key

func LookupOnlyLocal

func LookupOnlyLocal() LookupOption

LookupOnlyLocal forces the discoverer to only look at its cache

type LookupOptions

type LookupOptions struct {
	Local bool
	// Lookups are strings we are looking for, will be used to create a
	// bloom filter when forwarding the lookup request to providers
	Lookups []string
	// filters are the lookups equivalents for matching local peers
	Filters []LookupFilter
}

LookupOptions

func ParseLookupOptions

func ParseLookupOptions(opts ...LookupOption) *LookupOptions

func (LookupOptions) Match

func (l LookupOptions) Match(p *hyperspace.Announcement) bool

type Option

type Option func(*resolver)

Option for customizing a new resolver

type Resolver

type Resolver interface {
	Lookup(
		ctx context.Context,
		opts ...LookupOption,
	) ([]*peer.ConnectionInfo, error)
	LookupPeer(
		ctx context.Context,
		publicKey crypto.PublicKey,
	) (*peer.ConnectionInfo, error)
}

func New

func New(
	ctx context.Context,
	net network.Network,
	str *sqlobjectstore.Store,
	opts ...Option,
) Resolver

New returns a new resolver. Object store is currently optional.

type TildeDigestSyncList

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

TildeDigestSyncList -

func (*TildeDigestSyncList) Delete

func (m *TildeDigestSyncList) Delete(k tilde.Digest)

Delete -

func (*TildeDigestSyncList) Exists

func (m *TildeDigestSyncList) Exists(k tilde.Digest) bool

Exists -

func (*TildeDigestSyncList) List

func (m *TildeDigestSyncList) List() []tilde.Digest

List -

func (*TildeDigestSyncList) Put

func (m *TildeDigestSyncList) Put(k tilde.Digest)

Put -

func (*TildeDigestSyncList) Range

func (m *TildeDigestSyncList) Range(i func(k tilde.Digest) bool)

Range -