service

Documentation

Index

• Variables
• func EsPut(url string, data []byte) (err error)
• func Init()
• func InitConfig()
• func InitEs()
• func InitServer()
• func InitWorker()
• func NewServer() *webServer
• type Client
• type ClientCollection
  • func NewClientCollection() *ClientCollection
• type Config
• type Count
• type Link
• type Server
  • func NewSniffer() *Server
  • func (m *Server) CheckSpeed()
  • func (m *Server) NewServerConn()
  • func (m *Server) PrintLog()
  • func (m *Server) Refresh()
• type Tool
  • func NewTool() *Tool
  • func (m *Tool) Connect(i int)
  • func (m *Tool) LinksServe()
  • func (m *Tool) MessageStream(stream torrent.RPC_MessageStreamServer) error
  • func (m *Tool) SendData(postData torrent.TData) string
  • func (m *Tool) ToolServer(toolServer *Tool)
• type Worker
  • func NewWorkerServer() *Worker
  • func (m *Worker) AutoSendFindNode()
  • func (m *Worker) FindNode()
  • func (m *Worker) GenerNodes()
  • func (m *Worker) HandleMsg()
  • func (m *Worker) Metadata()
  • func (m *Worker) PrintLog()
  • func (m *Worker) Refresh()
  • func (m *Worker) Server()

Variables

var BootstrappingNodes = []string{
	"9.rarbg.to:2710",
	"9.rarbg.me:2710",
	"open.demonii.com:1337",
	"tracker.opentrackr.org:1337",
	"p4p.arenabg.com:1337",
	"router.utorrent.com:6881",
	"router.bittorrent.com:6881",
	"dht.transmissionbt.com:6881",
}

var ES *elasticsearch.Client

Functions

func EsPut

func EsPut(url string, data []byte) (err error)

func Init

func Init()

func InitConfig

func InitConfig()

func InitEs

func InitEs()

func InitServer

func InitServer()

func InitWorker

func InitWorker()

func NewServer

func NewServer() *webServer

Types

type Client

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

type ClientCollection

type ClientCollection struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewClientCollection

func NewClientCollection() *ClientCollection

type Config

type Config struct {
	EsUsername           string `env:"EsUsername"`
	EsPassWord           string `env:"EsPassWord"`
	HotSearchOnePageSize int    `env:"HotSearchOnePageSize" envDefault:"6"`
	HotSearchPageSize    int    `env:"HotSearchPageSize" envDefault:"3"`
	AuthDataBase         string `env:"AuthDataBase"`
	EnableElasticsearch  bool   `env:"EnableElasticsearch"`
	EsURL                string `env:"EsURL"`
	EsUrlBase            string `env:"EsUrlBase"`
	WebServerAddr        string `env:"WebServerAddr"`
}

var (
	ConfigData *Config
)

type Count

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

type Link

type Link struct {
	Conn         *grpc.ClientConn
	Addr         string
	LinkPostChan chan torrent.TData
}

type Server

type Server struct {
	Nodes       []string
	Tool        Tool
	RedisClient *redis.Client
	// contains filtered or unexported fields
}

func NewSniffer

func NewSniffer() *Server

NewSniffer :NewSniffer

func (*Server) CheckSpeed

func (m *Server) CheckSpeed()

func (*Server) NewServerConn

func (m *Server) NewServerConn()

func (*Server) PrintLog

func (m *Server) PrintLog()

func (*Server) Refresh

func (m *Server) Refresh()

type Tool

type Tool struct {
	torrent.RPCServer
	Links        []Link
	ToolSendChan chan torrent.TData
	ToolRevChan  chan torrent.TData
}

func NewTool

func NewTool() *Tool

func (*Tool) Connect

func (m *Tool) Connect(i int)

func (*Tool) LinksServe

func (m *Tool) LinksServe()

func (*Tool) MessageStream

func (m *Tool) MessageStream(stream torrent.RPC_MessageStreamServer) error

func (*Tool) SendData

func (m *Tool) SendData(postData torrent.TData) string

func (*Tool) ToolServer

func (m *Tool) ToolServer(toolServer *Tool)

type Worker

type Worker struct {
	Tool Tool
	// contains filtered or unexported fields
}

func NewWorkerServer

func NewWorkerServer() *Worker

func (*Worker) AutoSendFindNode

func (m *Worker) AutoSendFindNode()

func (*Worker) FindNode

func (m *Worker) FindNode()

func (*Worker) GenerNodes

func (m *Worker) GenerNodes()

func (*Worker) HandleMsg

func (m *Worker) HandleMsg()

func (*Worker) Metadata

func (m *Worker) Metadata()

func (*Worker) PrintLog

func (m *Worker) PrintLog()

func (*Worker) Refresh

func (m *Worker) Refresh()

func (*Worker) Server

func (m *Worker) Server()