servent

package
v0.0.0-...-a77e882 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 5, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultFileFilter

type DefaultFileFilter string

func (DefaultFileFilter) HideFile

func (dff DefaultFileFilter) HideFile(pth p2p.Path) bool

type FileFilter

type FileFilter interface {
	HideFile(pth p2p.Path) bool
}

type MetadataAdapter

type MetadataAdapter interface {
	GetMetadata(fs p2p.FileSystem, pth p2p.Path) (bson.Document, error)
}

type Servent

type Servent struct {
	ServentConfig
	// contains filtered or unexported fields
}

func (*Servent) AddServer

func (s *Servent) AddServer(domain string) error

func (*Servent) Changed

func (s *Servent) Changed(pths []p2p.Path)

func (*Servent) Created

func (s *Servent) Created(pths []p2p.Path)

func (*Servent) GetClient

func (s *Servent) GetClient(domain string) (*p2p.Client, error)

func (*Servent) GetServers

func (s *Servent) GetServers() []string

func (*Servent) Query

func (s *Servent) Query(terms bson.Document, maxPerConn int) (res []bson.Element, err error)

func (*Servent) RemoveClient

func (s *Servent) RemoveClient(domain string)

func (*Servent) RemoveServer

func (s *Servent) RemoveServer(domain string)

func (*Servent) Removed

func (s *Servent) Removed(pths []p2p.Path)

func (*Servent) ServeP2P

func (s *Servent) ServeP2P(ctx context.Context, l net.Listener)

func (*Servent) ServeP2PConn

func (s *Servent) ServeP2PConn(c net.Conn)

type ServentConfig

type ServentConfig struct {
	FS     p2p.FileSystemEx
	TS     p2p.TargetStore
	MDA    MetadataAdapter
	FF     FileFilter
	Arena  proto.Allocator
	KP     proto.KeyPair
	Dialer proxy.Dialer
}

func (*ServentConfig) Create

func (cfg *ServentConfig) Create() *Servent

Jump to

Keyboard shortcuts

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