store

Documentation

Index

• func FromDbTime(s string) (time.Time, error)
• type Article
• type ArticleRecord
• type DB
  • func Open(dbPath string) (*DB, error)
  • func (db *DB) ArticleCount() (uint, error)
  • func (db *DB) Close() error
  • func (db *DB) CreateNewSpool(startDate time.Time, prefix string) error
  • func (db *DB) DoesGroupMetadataExist(gm *GroupMetadata) (bool, error)
  • func (db *DB) DoesMessageIDExist(msgID string) (bool, error)
  • func (db *DB) FetchNewGroups(dt time.Time) ([]string, error)
  • func (db *DB) FetchNewsgroups() ([]string, error)
  • func (db *DB) GetAllRowIDs(group string) ([]RowID, error)
  • func (db *DB) GetArticleByMsgID(msgID string) (*Article, error)
  • func (db *DB) GetArticleByRowID(rowID RowID) (*Article, error)
  • func (db *DB) GetHeaderByMsgID(msgID string) (*Header, error)
  • func (db *DB) GetHeaderByRowID(rowID RowID) (*Header, error)
  • func (db *DB) GetPrefix() (string, error)
  • func (db *DB) GetRowIDs(group string) ([]RowID, error)
  • func (db *DB) GetStartDate() (*time.Time, error)
  • func (db *DB) GroupArticleCount(group string) (int, error)
  • func (db *DB) InsertArticleRecord(ar *ArticleRecord) error
  • func (db *DB) InsertGroupMetadata(gm *GroupMetadata) error
• type GroupMetadata
• type Header
• type RowID

Functions

func FromDbTime

func FromDbTime(s string) (time.Time, error)

Types

type Article

type Article struct {
	Header Header
	Body   []byte
}

type ArticleRecord

type ArticleRecord struct {
	PostedAt  time.Time
	Newsgroup string
	Subject   string
	Author    string
	MsgID     string
	ParentID  string
	Body      string
}

type DB

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

func Open

func Open(dbPath string) (*DB, error)

func (*DB) ArticleCount

func (db *DB) ArticleCount() (uint, error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) CreateNewSpool

func (db *DB) CreateNewSpool(startDate time.Time, prefix string) error

func (*DB) DoesGroupMetadataExist

func (db *DB) DoesGroupMetadataExist(gm *GroupMetadata) (bool, error)

func (*DB) DoesMessageIDExist

func (db *DB) DoesMessageIDExist(msgID string) (bool, error)

func (*DB) FetchNewGroups

func (db *DB) FetchNewGroups(dt time.Time) ([]string, error)

func (*DB) FetchNewsgroups

func (db *DB) FetchNewsgroups() ([]string, error)

func (*DB) GetAllRowIDs

func (db *DB) GetAllRowIDs(group string) ([]RowID, error)

func (*DB) GetArticleByMsgID

func (db *DB) GetArticleByMsgID(msgID string) (*Article, error)

func (*DB) GetArticleByRowID

func (db *DB) GetArticleByRowID(rowID RowID) (*Article, error)

func (*DB) GetHeaderByMsgID

func (db *DB) GetHeaderByMsgID(msgID string) (*Header, error)

func (*DB) GetHeaderByRowID

func (db *DB) GetHeaderByRowID(rowID RowID) (*Header, error)

func (*DB) GetPrefix

func (db *DB) GetPrefix() (string, error)

func (*DB) GetRowIDs

func (db *DB) GetRowIDs(group string) ([]RowID, error)

func (*DB) GetStartDate

func (db *DB) GetStartDate() (*time.Time, error)

func (*DB) GroupArticleCount

func (db *DB) GroupArticleCount(group string) (int, error)

func (*DB) InsertArticleRecord

func (db *DB) InsertArticleRecord(ar *ArticleRecord) error

func (*DB) InsertGroupMetadata

func (db *DB) InsertGroupMetadata(gm *GroupMetadata) error

type GroupMetadata

type GroupMetadata struct {
	Name         string
	DateCreated  time.Time
	DaysRetained uint
}

type Header

type Header struct {
	PostedAt  string
	Newsgroup string
	Subject   string
	Author    string
	MsgID     string
	ParentID  string
}

type RowID

type RowID uint