rildb

Documentation

Overview

Stores reverse index data into a LevelDB database.

Index

• type RiLDB
  • func OpenSpoolRiLDB(spool string, o *opt.Options) (*RiLDB, error)
  • func (r *RiLDB) RiBegin(msgid []byte) storage.RiWriter
  • func (r *RiLDB) RiExpire(msgid []byte) (err error)
  • func (r *RiLDB) RiLookup(msgid []byte, rie *storage.RiElement) (rel storage.Releaser, err error)
  • func (r *RiLDB) RiLookupAll(msgid []byte, rie *storage.RiElement) (rel storage.Cursor, err error)
  • func (r *RiLDB) RiQueryExpired(ow *time.Time, rih *storage.RiHistory) (cur storage.Cursor, err error)

Types

type RiLDB

type RiLDB struct {
	MDB *leveldb.DB
	TDB *leveldb.DB
	RDB *leveldb.DB
}

func OpenSpoolRiLDB

func OpenSpoolRiLDB(spool string, o *opt.Options) (*RiLDB, error)

func (*RiLDB) RiBegin

func (r *RiLDB) RiBegin(msgid []byte) storage.RiWriter

Called for a sequence of group/number-pairs associated to the article This method may return <nil>!

func (*RiLDB) RiExpire

func (r *RiLDB) RiExpire(msgid []byte) (err error)

Expires an article using the message-id.

func (*RiLDB) RiLookup

func (r *RiLDB) RiLookup(msgid []byte, rie *storage.RiElement) (rel storage.Releaser, err error)

Performs a reverse index lookup: message-id to the first group/number pair.

func (*RiLDB) RiLookupAll

func (r *RiLDB) RiLookupAll(msgid []byte, rie *storage.RiElement) (rel storage.Cursor, err error)

Performs a reverse index lookup: message-id to all first group/number pairs.

func (*RiLDB) RiQueryExpired

func (r *RiLDB) RiQueryExpired(ow *time.Time, rih *storage.RiHistory) (cur storage.Cursor, err error)

Query Expired articles. SHOULD return message-ids after their group/number counterparts.