memory

package

v0.0.0-...-729a1dc Latest Latest Go to latest Published: Jun 24, 2021 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ConfigDefault = Conf{
	GCInterval: 10 * time.Second,
}

ConfigDefault is the default config

func InitMemoryStore()

type Conf struct {
	// Time before deleting expired keys
	//
	// Default is 10 * time.Second
	GCInterval time.Duration
}

Config defines the config for storage.

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

func NewPeerStore() *PeerStore

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

Storage interface that is implemented by storage providers

var STORE *Storage

func New(conf ...Conf) *Storage

New creates a new memory storage

func (s *Storage) Close() error

Close the memory storage

func (s *Storage) DeleteInfohash(key bittorrent.InfoHash) error

Delete key by key

func (s *Storage) DeletePeer(key bittorrent.InfoHash, peer bittorrent.Peer)

func (s *Storage) GetAllInfoHash() []bittorrent.InfoHash

func (s *Storage) GetAllPeers(key bittorrent.InfoHash, ignore *bittorrent.Peer) []bittorrent.Peer

func (s *Storage) GetPeers(key bittorrent.InfoHash, p *bittorrent.Peer) (bittorrent.Peer, bittorrent.AnnounceRequest)

func (s *Storage) Reset() error

Reset all keys

func (s *Storage) ResetPeer(key bittorrent.InfoHash) error

Reset all peer

func (s *Storage) SetPeer(key bittorrent.InfoHash, peer bittorrent.Peer, a bittorrent.AnnounceRequest) error

SetPeer key with value SetPeer key with value