servent

Documentation

Index

• type DefaultFileFilter
  • func (dff DefaultFileFilter) HideFile(pth p2p.Path) bool
• type FileFilter
• type MetadataAdapter
• type Servent
  • func (s *Servent) AddServer(domain string) error
  • func (s *Servent) Changed(pths []p2p.Path)
  • func (s *Servent) Created(pths []p2p.Path)
  • func (s *Servent) GetClient(domain string) (*p2p.Client, error)
  • func (s *Servent) GetServers() []string
  • func (s *Servent) Query(terms bson.Document, maxPerConn int) (res []bson.Element, err error)
  • func (s *Servent) RemoveClient(domain string)
  • func (s *Servent) RemoveServer(domain string)
  • func (s *Servent) Removed(pths []p2p.Path)
  • func (s *Servent) ServeP2P(ctx context.Context, l net.Listener)
  • func (s *Servent) ServeP2PConn(c net.Conn)
• type ServentConfig
  • func (cfg *ServentConfig) Create() *Servent

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