sqliteuploader

func (s *Store) ClearInboxFailure(ctx context.Context, fingerprint string) error

func (s *Store) Close() error

func (s *Store) CompleteFederationPublication(ctx context.Context, submissionID, poolID string, state uploader.PublicationState, outcome uploader.PublicationOutcome) (*uploader.FederationPublication, error)

func (s *Store) CreateSubmission(ctx context.Context, submission uploader.Submission, nzbBytes []byte, artifacts []uploader.Artifact) (uploader.CreateResult, error)

func (s *Store) FailFederationPublication(ctx context.Context, submissionID, poolID string, cause error) (*uploader.FederationPublication, error)

func (s *Store) GetSubmission(ctx context.Context, id string) (*uploader.Submission, error)

func (s *Store) GetSubmissionByReleaseID(ctx context.Context, releaseID string) (*uploader.Submission, error)

func (s *Store) GetSubmissionBySHA256(ctx context.Context, hash string) (*uploader.Submission, error)

func (s *Store) ListDueFederationPublications(ctx context.Context, limit int) ([]uploader.FederationPublication, error)

func (s *Store) ListEvents(ctx context.Context, submissionID string) ([]uploader.Event, error)

func (s *Store) ListFederationPublications(ctx context.Context, submissionID string) ([]uploader.FederationPublication, error)

func (s *Store) ListSubmissions(ctx context.Context, filter uploader.ListFilter) ([]uploader.Submission, error)

func (s *Store) OpenArtifact(ctx context.Context, submissionID, artifactID string) (*uploader.Artifact, io.ReadCloser, error)

func (s *Store) OpenNZB(ctx context.Context, id string) (io.ReadCloser, error)

func (s *Store) Ping(ctx context.Context) error

func (s *Store) RecordInboxFailure(ctx context.Context, fingerprint string, modTime time.Time, size int64, code, message string, nextAttempt time.Time) error

func (s *Store) RequestFederationPublication(ctx context.Context, submissionID, poolID, actor string) (*uploader.FederationPublication, error)

func (s *Store) RequestFederationWithdrawal(ctx context.Context, submissionID, poolID, actor, note string) (*uploader.FederationPublication, error)

func (s *Store) RequestSubmissionWithdrawals(ctx context.Context, submissionID, actor, note string) error

func (s *Store) RunMigrations() error

func (s *Store) ShouldAttemptInboxPath(ctx context.Context, fingerprint string, modTime time.Time, size int64, now time.Time) (bool, error)

func (s *Store) TransitionSubmission(ctx context.Context, id string, next uploader.State, actor, note string) (*uploader.Submission, error)

func (s *Store) UpdateSubmission(ctx context.Context, id string, update uploader.Update) (*uploader.Submission, error)

func (s *Store) ValidateSchema(ctx context.Context) error