resolver

Documentation

Index

• Constants
• Variables
• type Config
• type ContainerResolver
  • func NewContainerResolver(resolverNames []string, cfg *Config) (*ContainerResolver, error)
  • func (r *ContainerResolver) Resolve(ctx context.Context, cnrName string) (*cid.ID, error)
  • func (r *ContainerResolver) UpdateResolvers(resolverNames []string, cfg *Config) error
• type NeoFS
• type NeoFSResolver
  • func NewNeoFSResolver(p *pool.Pool) *NeoFSResolver
  • func (x *NeoFSResolver) SystemDNS(ctx context.Context) (string, error)
• type Resolver
  • func NewDNSResolver(neoFS NeoFS) (*Resolver, error)
  • func NewNNSResolver(rpcAddress string) (*Resolver, error)
  • func (r *Resolver) Resolve(ctx context.Context, name string) (*cid.ID, error)
  • func (r *Resolver) SetResolveFunc(fn func(context.Context, string) (*cid.ID, error))

Constants

const (
	NNSResolver = "nns"
	DNSResolver = "dns"
)

Variables

var ErrNoResolvers = errors.New("no resolvers")

ErrNoResolvers returns when trying to resolve container without any resolver.

Types

type Config

type Config struct {
	NeoFS      NeoFS
	RPCAddress string
}

type ContainerResolver

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

func NewContainerResolver

func NewContainerResolver(resolverNames []string, cfg *Config) (*ContainerResolver, error)

func (*ContainerResolver) Resolve

func (r *ContainerResolver) Resolve(ctx context.Context, cnrName string) (*cid.ID, error)

func (*ContainerResolver) UpdateResolvers

func (r *ContainerResolver) UpdateResolvers(resolverNames []string, cfg *Config) error

type NeoFS

type NeoFS interface {
	// SystemDNS reads system DNS network parameters of the NeoFS.
	//
	// Returns exactly on non-zero value. Returns any error encountered
	// which prevented the parameter to be read.
	SystemDNS(context.Context) (string, error)
}

NeoFS represents virtual connection to the NeoFS network.

type NeoFSResolver

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

NeoFSResolver represents virtual connection to the NeoFS network. It implements resolver.NeoFS.

func NewNeoFSResolver

func NewNeoFSResolver(p *pool.Pool) *NeoFSResolver

NewNeoFSResolver creates new NeoFSResolver using provided pool.Pool.

func (*NeoFSResolver) SystemDNS

func (x *NeoFSResolver) SystemDNS(ctx context.Context) (string, error)

SystemDNS implements resolver.NeoFS interface method.

type Resolver

type Resolver struct {
	Name string
	// contains filtered or unexported fields
}

func NewDNSResolver

func NewDNSResolver(neoFS NeoFS) (*Resolver, error)

func NewNNSResolver

func NewNNSResolver(rpcAddress string) (*Resolver, error)

func (*Resolver) Resolve

func (r *Resolver) Resolve(ctx context.Context, name string) (*cid.ID, error)

func (*Resolver) SetResolveFunc

func (r *Resolver) SetResolveFunc(fn func(context.Context, string) (*cid.ID, error))