persistence

Documentation

Index

• Variables
• type ContentPersistence
• type Params
• type Persistence
• type Result
  • func New(params Params) (Result, error)
• type TorrentContentRef
• type TorrentPersistence

Variables

var ErrRecordNotFound = gorm.ErrRecordNotFound

Types

type ContentPersistence

type ContentPersistence interface {
	GetContent(ctx context.Context, ref model.ContentRef) (movie model.Content, err error)
}

type Params

type Params struct {
	fx.In
	Query *dao.Query
}

type Persistence

type Persistence interface {
	TorrentPersistence
	ContentPersistence
}

type Result

type Result struct {
	fx.Out
	Persistence Persistence
}

func New

func New(params Params) (Result, error)

type TorrentContentRef

type TorrentContentRef struct {
	model.ContentRef
	InfoHash protocol.ID
}

type TorrentPersistence

type TorrentPersistence interface {
	GetTorrent(ctx context.Context, infoHash protocol.ID) (torrent model.Torrent, err error)
	GetTorrents(ctx context.Context, infoHashes ...protocol.ID) (torrents []model.Torrent, missingInfoHashes []protocol.ID, err error)
	PutTorrent(ctx context.Context, torrent model.Torrent) error
	TorrentExists(ctx context.Context, infoHash protocol.ID) (bool, error)
	// GetPersistedInfoHashes returns the subset of provided hashes that are persisted in the database.
	GetPersistedInfoHashes(ctx context.Context, infoHashesToCheck []protocol.ID) ([]protocol.ID, error)
}