resolver

package

v1.0.0 Latest Latest Go to latest Published: Jul 3, 2023 License: Apache-2.0, MIT Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/data-preservation-programs/RetrievalBot

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DecodeMultiaddr(addr multiaddr.Multiaddr) (IPOrHost, IsHostName, PortNumber, error)
type IPInfo
- func GetPublicIPInfo(ctx context.Context, ip string, token string) (IPInfo, error)
- func (i *IPInfo) Resolve()
type IPOrHost
type IsHostName
type LocationResolver
- func NewLocationResolver(ipInfoToken string, ttl time.Duration) LocationResolver
type MinerInfo
type PortNumber
type ProtocolProvider
- func ProtocolResolver(host host.Host, timeout time.Duration) ProtocolProvider
- func (p ProtocolProvider) GetRetrievalProtocols(parent context.Context, minerInfo peer.AddrInfo) ([]model.Protocol, error)
- func (p ProtocolProvider) IsBoostProvider(ctx context.Context, minerInfo peer.AddrInfo) (bool, error)
type ProviderResolver
- func NewProviderResolver(url string, token string, ttl time.Duration) (*ProviderResolver, error)
- func (p *ProviderResolver) ResolveProvider(ctx context.Context, provider string) (MinerInfo, error)

Constants ¶

View Source

const RetrievalProtocolName = "/fil/retrieval/transports/1.0.0"

Variables ¶

This section is empty.

Functions ¶

func DecodeMultiaddr ¶

func DecodeMultiaddr(addr multiaddr.Multiaddr) (IPOrHost, IsHostName, PortNumber, error)

Types ¶

type IPInfo ¶

type IPInfo struct {
	IP        string `json:"ip"`
	City      string `json:"city"`
	Region    string `json:"region"`
	Country   string `json:"country"`
	Continent string `json:"continent"`
	Loc       string `json:"loc"`
	Org       string `json:"org"`
	Postal    string `json:"postal"`
	Timezone  string `json:"timezone"`
	Bogon     bool   `json:"bogon"`
	Latitude  float32
	Longitude float32
	ASN       string
	ISP       string
}

func GetPublicIPInfo ¶

func GetPublicIPInfo(ctx context.Context, ip string, token string) (IPInfo, error)

func (*IPInfo) Resolve ¶

func (i *IPInfo) Resolve()

type IPOrHost ¶

type IPOrHost = string

type IsHostName ¶

type IsHostName = bool

type LocationResolver ¶

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

func NewLocationResolver ¶

func NewLocationResolver(ipInfoToken string, ttl time.Duration) LocationResolver

func (LocationResolver) ResolveIP ¶

func (l LocationResolver) ResolveIP(ctx context.Context, ip net.IP) (IPInfo, error)

func (LocationResolver) ResolveIPStr ¶

func (l LocationResolver) ResolveIPStr(ctx context.Context, ip string) (IPInfo, error)

func (LocationResolver) ResolveMultiaddr ¶

func (l LocationResolver) ResolveMultiaddr(ctx context.Context, addr multiaddr.Multiaddr) (IPInfo, error)

func (LocationResolver) ResolveMultiaddrs ¶

func (l LocationResolver) ResolveMultiaddrs(ctx context.Context, addrs []multiaddr.Multiaddr) (IPInfo, error)

func (LocationResolver) ResolveMultiaddrsBytes ¶

func (l LocationResolver) ResolveMultiaddrsBytes(ctx context.Context, bytesAddrs []abi.Multiaddrs) (IPInfo, error)

type MinerInfo ¶

type MinerInfo struct {
	//nolint:stylecheck
	PeerId string
	//nolint:tagliatelle
	MultiaddrsBase64Encoded []string `json:"Multiaddrs"`
	Multiaddrs              []abi.Multiaddrs
}

type PortNumber ¶

type PortNumber = int

type ProtocolProvider ¶

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

func ProtocolResolver ¶

func ProtocolResolver(host host.Host, timeout time.Duration) ProtocolProvider

func (ProtocolProvider) GetRetrievalProtocols ¶

func (p ProtocolProvider) GetRetrievalProtocols(
	parent context.Context,
	minerInfo peer.AddrInfo,
) ([]model.Protocol, error)

func (ProtocolProvider) IsBoostProvider ¶

func (p ProtocolProvider) IsBoostProvider(ctx context.Context, minerInfo peer.AddrInfo) (bool, error)

type ProviderResolver ¶

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

func NewProviderResolver ¶

func NewProviderResolver(url string, token string, ttl time.Duration) (*ProviderResolver, error)

func (*ProviderResolver) ResolveProvider ¶

func (p *ProviderResolver) ResolveProvider(ctx context.Context, provider string) (MinerInfo, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL