Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

core

package

Go to main page

Versions in this module

v1

v1.3.0

Nov 26, 2023

v1.2.1

Nov 21, 2023

v1.2.0

Nov 18, 2023

v1.1.0

Feb 27, 2023

v1.0.0

Nov 5, 2022

v0

v0.1.3

Apr 17, 2022

v0.1.2

Mar 13, 2022

v0.1.1

Feb 21, 2022

v0.1.0

Jan 18, 2022

v0.0.11

Jan 15, 2022

v0.0.10

Jan 2, 2022

v0.0.9

Dec 17, 2021

v0.0.8

Dec 10, 2021

v0.0.7

Nov 24, 2021

v0.0.6

Oct 27, 2021

Changes in this version

type EngConfig

+ HookPostURL string

+ ListenCompletion bool

+ NotifyOnComplete bool

+ func (ec *EngConfig) GetHPU() (ret string)

+ func (ec *EngConfig) GetListenC() (ret bool)

+ func (ec *EngConfig) GetNOC() (ret bool)

v0.0.5

Oct 18, 2021

v0.0.4

Oct 13, 2021

v0.0.3

Sep 16, 2021

v0.0.2

Aug 25, 2021

v0.0.1

Aug 25, 2021

Changes in this version

+ const Version

+ var Configmu sync.Mutex

+ var Dirconfig = struct{ ... }

+ var Engine Eng

+ var Err = log.New(os.Stderr, "[ERR ] ", log.LstdFlags)

+ var Flagconfig = struct{ ... }

+ var Info = log.New(os.Stderr, "[INFO] ", log.LstdFlags)

+ var MachInfo machInfo = loadMachInfo()

+ var MachStats machStats

+ var Warn = log.New(os.Stderr, "[WARN] ", log.LstdFlags)

+ func AbandonTorrent(User string, infohash metainfo.Hash)

+ func AddMetaCache(ih metainfo.Hash, mi metainfo.MetaInfo)

+ func AddTrackerstoTorrent(User string, infohash metainfo.Hash, announcelist [][]string)

+ func AddfromSpec(User string, spec *torrent.TorrentSpec, dontstart bool, nofsdb bool)

+ func AuthCheck(w http.ResponseWriter, r *http.Request)

+ func DeleteFilePath(User string, infohash metainfo.Hash, fp string)

+ func DeleteTorrent(User string, infohash metainfo.Hash)

+ func EmptyMetaCache()

+ func GetFsDirInfo(ih metainfo.Hash, fp string) (ret []byte)

+ func GetFsFileInfo(ih metainfo.Hash, fp string) (ret []byte)

+ func GetMetaCache(ih metainfo.Hash) (spec *torrent.TorrentSpec, reterr error)

+ func GetTorrentFileInfo(ih metainfo.Hash, fp string) (ret []byte)

+ func GetTorrentFiles(ih metainfo.Hash) (ret []byte)

+ func GetTorrentInfo(ih metainfo.Hash) (ret []byte)

+ func GetTorrentInfoStat(ih metainfo.Hash) (ret []byte)

+ func GetTorrentKnownSwarm(ih metainfo.Hash) (ret []byte)

+ func GetTorrentMetainfo(ih metainfo.Hash) (ret []byte)

+ func GetTorrentNumpieces(ih metainfo.Hash) (ret []byte)

+ func GetTorrentPeerConns(ih metainfo.Hash) (ret []byte)

+ func GetTorrentPieceStateRuns(ih metainfo.Hash) (ret []byte)

+ func GetTorrentStats(ih metainfo.Hash) (ret []byte)

+ func GetTorrents(lt []metainfo.Hash) (ret []byte)

+ func Initialize()

+ func MetafromHex(infohash string) (h metainfo.Hash, err error)

+ func RemMetaCache(ih metainfo.Hash)

+ func RemTrackersSpec(spec *torrent.TorrentSpec)

+ func RemoveTorrent(User string, infohash metainfo.Hash)

+ func SocketAPI(w http.ResponseWriter, r *http.Request)

+ func SpecfromB64String(trnt string) (spec *torrent.TorrentSpec, reterr error)

+ func SpecfromBytes(trnt []byte) (spec *torrent.TorrentSpec, reterr error)

+ func SpecfromPath(path string) (spec *torrent.TorrentSpec, reterr error)

+ func SpecfromURL(torrentURL string) (spec *torrent.TorrentSpec, reterr error)

+ func StartFile(User string, infohash metainfo.Hash, fp string)

+ func StartTorrent(User string, infohash metainfo.Hash, nofsdb bool)

+ func StopFile(User string, infohash metainfo.Hash, fp string)

+ func StopTorrent(User string, infohash metainfo.Hash)

+ func StreamFile(w http.ResponseWriter, r *http.Request)

+ func TarDir(dirpath string, w http.ResponseWriter, name string)

+ func TorrentRoutine()

+ func TorrentServe(w http.ResponseWriter, r *http.Request)

+ func UpdateTrackers()

+ func ZipDir(dirpath string, w http.ResponseWriter, name string)

+ type ConReq struct

+ Aop int

+ Command string

+ Data1 string

+ Data2 string

+ Data3 string

+ type ConnectionMsg struct

+ Session string

+ Type string

+ type DataMsg struct

+ Data interface{}

+ Infohash string

+ Type string

+ type DiskUsageStat struct

+ Free uint64

+ Total uint64

+ Used uint64

+ UsedPercent float64

+ type Eng struct

+ Econfig EngConfig

+ FsDb db.FileStateDb

+ LsDb db.LockStateDb

+ PcDb db.PcDb

+ PsqlCon string

+ TUDb db.TorrentUserDb

+ Tconfig TorConfig

+ TorDb db.TorrentDb

+ Torc *torrent.Client

+ TrackerDB db.TrackerDb

+ UDb db.UserDb

+ type EngConfig struct

+ DisAllowTrackersCache bool

+ DisAllowTrackersUser bool

+ DisableLocalCache bool

+ DontRemoveCacheInfo bool

+ GlobalSeedRatio float64

+ LockbyDefault bool

+ OnlineCacheURL string

+ SRRefresh int64

+ TrackerListURLs []string

+ TrackerRefresh int64

+ func (ec *EngConfig) DRCI() (ret bool)

+ func (ec *EngConfig) GetDLC() (ret bool)

+ func (ec *EngConfig) GetDTC() (ret bool)

+ func (ec *EngConfig) GetDTU() (ret bool)

+ func (ec *EngConfig) GetGSR() (ret float64)

+ func (ec *EngConfig) GetLBD() (ret bool)

+ func (ec *EngConfig) GetOCU() (ret string)

+ func (ec *EngConfig) GetSRR() (ret int64)

+ func (ec *EngConfig) GetTLU() (ret []string)

+ func (ec *EngConfig) GetTR() (ret int64)

+ func (ec *EngConfig) WriteConfig() (err error)

+ type FileInfo struct

+ BytesCompleted int64

+ DisplayPath string

+ Length int64

+ Offset int64

+ Path string

+ Priority byte

+ type FsFileInfo struct

+ IsDir bool

+ Name string

+ Path string

+ Size int64

+ type Hub struct

+ Conns map[string]*UserConn

+ var MainHub Hub = Hub{ ... }

+ func (h *Hub) Add(Uc *UserConn)

+ func (h *Hub) ListUsers() (ret []byte)

+ func (h *Hub) Remove(Uc *UserConn)

+ func (h *Hub) RemoveUser(Username string)

+ func (h *Hub) SendMsg(User string, Type string, State string, Resp string)

+ func (h *Hub) SendMsgU(User string, Type string, Infohash string, State string, Resp string)

+ type MutInt struct

+ func (M *MutInt) Dec()

+ func (M *MutInt) Get() (ret int)

+ func (M *MutInt) Inc()

+ func (M *MutInt) Set(v int)

+ type Mutbool struct

+ func (M *Mutbool) Get() (ret bool)

+ func (M *Mutbool) Set(v bool)

+ type Resp struct

+ Infohash string

+ Msg string

+ State string

+ Type string

+ type TorConfig struct

+ AcceptPeerConnections *bool

+ Bep20 *string

+ CryptoProvides *uint32

+ Debug *bool

+ DisableAcceptRateLimiting *bool

+ DisableAggressiveUpload *bool

+ DisableIPv4 *bool

+ DisableIPv4Peers *bool

+ DisableIPv6 *bool

+ DisablePEX *bool

+ DisableTCP *bool

+ DisableTrackers *bool

+ DisableUTP *bool

+ DisableWebseeds *bool

+ DisableWebtorrent *bool

+ DownloadLimiterBurst *int

+ DownloadLimiterLimit *float64

+ DropDuplicatePeerIds *bool

+ DropMutuallyCompletePeers *bool

+ EstablishedConnsPerTorrent *int

+ ExtendedHandshakeClientVersion *string

+ HTTPUserAgent *string

+ HalfOpenConnsPerTorrent *int

+ HandshakesTimeout *int64

+ HeaderObfuscationPolicy *string

+ IPBlocklist *bool

+ ListenHost *string

+ ListenPort *int

+ Logger *bool

+ MaxUnverifiedBytes *int64

+ MinDialTimeout *int64

+ NoDHT *bool

+ NoDefaultPortForwarding *bool

+ NoUpload *bool

+ NominalDialTimeout *int64

+ PeerID *string

+ PeriodicallyAnnounceTorrentsToDht *bool

+ PublicIP4 *string

+ PublicIP6 *string

+ Seed *bool

+ TorrentPeersHighWater *int

+ TorrentPeersLowWater *int

+ TotalHalfOpenConns *int

+ UploadLimiterBurst *int

+ UploadLimiterLimit *float64

+ UpnpID *string

+ func (t *TorConfig) ToTorrentConfig() (tc *torrent.ClientConfig)

+ type Torrent1 struct

+ BytesCompleted int64

+ BytesMissing int64

+ Infohash string

+ Length int64

+ Name string

+ Seeding bool

+ State string

+ type Torrent2 struct

+ AddedAt time.Time

+ StartedAt time.Time

+ type UserConn struct

+ Conn *websocket.Conn

+ IsAdmin bool

+ Sendmu sync.Mutex

+ Stream sync.Mutex

+ Streamers MutInt

+ Time time.Time

+ Username string

+ func NewUserConn(Username string, Conn *websocket.Conn, IsAdmin bool) (uc *UserConn)

+ func (uc *UserConn) Close()

+ func (uc *UserConn) Send(v []byte) (err error)

+ func (uc *UserConn) SendMsg(Type string, State string, Msg string) (err error)

+ func (uc *UserConn) SendMsgU(Type string, State string, Infohash string, Msg string) (err error)

+ func (uc *UserConn) StopStream()

+ type UserConnMsg struct

+ IsAdmin bool

+ Time time.Time

+ Username string