master

Documentation

Index

• type Master
  • func NewMaster(ctx context.Context) *Master
  • func (m *Master) Bootstrap() (e error)
  • func (m *Master) ForceReannounce(wid string) error
  • func (m *Master) GetConnectedWorkers() (_ map[string]*swarm.SwarmWorker)
  • func (*Master) IsMaster() bool
  • func (m *Master) Register(ctx context.Context, req *pb.RegistrationRequest) (_ *emptypb.Empty, e error)
  • func (m *Master) RemoveTorrent(wid string, name string, hash string, wdata ...bool) (uint64, uint64, error)
  • func (m *Master) RequestFreeSpaceFromWorker(wid string) (uint64, error)
  • func (m *Master) RequestTorrentsFromWorker(wid string) ([]*deluge.Torrent, error)
  • func (m *Master) SaveTorrentFile(wid string, fname string, fbytes *[]byte) (int64, error)

Types

type Master

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

func NewMaster

func NewMaster(ctx context.Context) *Master

func (*Master) Bootstrap

func (m *Master) Bootstrap() (e error)

func (*Master) ForceReannounce

func (m *Master) ForceReannounce(wid string) error

func (*Master) GetConnectedWorkers

func (m *Master) GetConnectedWorkers() (_ map[string]*swarm.SwarmWorker)

func (*Master) IsMaster

func (*Master) IsMaster() bool

func (*Master) Register

func (m *Master) Register(ctx context.Context, req *pb.RegistrationRequest) (_ *emptypb.Empty, e error)

func (*Master) RemoveTorrent

func (m *Master) RemoveTorrent(wid string, name string, hash string, wdata ...bool) (uint64, uint64, error)

func (*Master) RequestFreeSpaceFromWorker

func (m *Master) RequestFreeSpaceFromWorker(wid string) (uint64, error)

func (*Master) RequestTorrentsFromWorker

func (m *Master) RequestTorrentsFromWorker(wid string) ([]*deluge.Torrent, error)

func (*Master) SaveTorrentFile

func (m *Master) SaveTorrentFile(wid string, fname string, fbytes *[]byte) (int64, error)