mirror of
https://github.com/ChronosX88/yans.git
synced 2024-11-08 06:41:00 +00:00
28 lines
1.2 KiB
Go
28 lines
1.2 KiB
Go
package backend
|
|
|
|
import "github.com/ChronosX88/yans/internal/models"
|
|
|
|
const (
|
|
SupportedBackendList = "sqlite"
|
|
)
|
|
|
|
type StorageBackend interface {
|
|
ListGroups() ([]models.Group, error)
|
|
ListGroupsByPattern(pattern string) ([]models.Group, error)
|
|
GetGroup(groupName string) (models.Group, error)
|
|
GetNewGroupsSince(timestamp int64) ([]models.Group, error)
|
|
GetArticlesCount(g *models.Group) (int, error)
|
|
GetGroupLowWaterMark(g *models.Group) (int, error)
|
|
GetGroupHighWaterMark(g *models.Group) (int, error)
|
|
SaveArticle(article models.Article, groups []string) error
|
|
GetArticle(messageID string) (models.Article, error)
|
|
GetArticleByNumber(g *models.Group, num int) (models.Article, error)
|
|
GetArticleNumbers(g *models.Group, low, high int64) ([]int64, error)
|
|
GetNewArticlesSince(timestamp int64) ([]string, error)
|
|
GetLastArticleByNum(g *models.Group, a *models.Article) (models.Article, error)
|
|
GetNextArticleByNum(g *models.Group, a *models.Article) (models.Article, error)
|
|
GetArticlesByRange(g *models.Group, low, high int64) ([]models.Article, error)
|
|
GetNewThreads(g *models.Group, perPage int, pageNum int) ([]int, error)
|
|
GetThread(g *models.Group, threadNum int) ([]int, error)
|
|
}
|