transport

Jan 29, 2024

Changes in this version

type VirtualStorage

+ func (v *VirtualStorage) UpdateUploadStats(bagId []byte, val uint64) error

Jul 18, 2023

Changes in this version

+ var Connector = func(ctx context.Context, addr string, peerKey ed25519.PublicKey, ...) (ADNL, error)

+ type ADNL interface

+ Close func()

+ GetID func() []byte

+ Query func(ctx context.Context, req, result tl.Serializable) error

+ RemoteAddr func() string

+ SendCustomMessage func(ctx context.Context, req tl.Serializable) error

+ SetCustomMessageHandler func(handler func(msg *adnl.MessageCustom) error)

+ SetDisconnectHandler func(handler func(addr string, key ed25519.PublicKey))

+ type DHT interface

+ Close func()

+ FindAddresses func(ctx context.Context, key []byte) (*address.List, ed25519.PublicKey, error)

+ StoreAddress func(ctx context.Context, addresses address.List, ttl time.Duration, ...) (int, []byte, error)

+ type RLDP interface

+ Close func()

+ DoQuery func(ctx context.Context, maxAnswerSize int64, query, result tl.Serializable) error

+ SendAnswer func(ctx context.Context, maxAnswerSize int64, queryId, transferId []byte, ...) error

+ SetOnDisconnect func(handler func())

+ SetOnQuery func(handler func(transferId []byte, query *rldp.Query) error)

+ type Resolver interface

+ Resolve func(ctx context.Context, domain string) (*dns.Domain, error)

+ type Transport struct

+ func NewTransport(dht DHT, resolver Resolver, storeConn storage.NetConnector, ...) *Transport

+ func (t *Transport) RoundTrip(request *http.Request) (_ *http.Response, err error)

+ func (t *Transport) Stop()

+ type VirtualStorage struct

+ func NewVirtualStorage() *VirtualStorage

+ func (v *VirtualStorage) GetActiveFiles(bagId []byte) ([]uint32, error)

+ func (v *VirtualStorage) GetAll() []*storage.Torrent

+ func (v *VirtualStorage) GetFS() storage.FS

+ func (v *VirtualStorage) GetPiece(bagId []byte, id uint32) (*storage.PieceInfo, error)

+ func (v *VirtualStorage) GetTorrentByOverlay(overlay []byte) *storage.Torrent

+ func (v *VirtualStorage) PiecesMask(bagId []byte, num uint32) []byte

+ func (v *VirtualStorage) RemovePiece(bagId []byte, id uint32) error

+ func (v *VirtualStorage) SetActiveFiles(bagId []byte, ids []uint32) error

+ func (v *VirtualStorage) SetPiece(bagId []byte, id uint32, p *storage.PieceInfo) error

+ func (v *VirtualStorage) SetTorrent(t *storage.Torrent) error