articlewrap

Documentation

Index

• Variables
• type ArticleDirectBackend
  • func (adb *ArticleDirectBackend) ArticleDirectGet(id []byte, head, body bool) *newspolyglot.ArticleObject
  • func (adb *ArticleDirectBackend) ArticleDirectOverview(id []byte) *newspolyglot.ArticleOverview
  • func (adb *ArticleDirectBackend) ArticleDirectStat(id []byte) bool
  • func (adb *ArticleDirectBackend) ArticleGroupGet(group []byte, num int64, head, body bool, id_buf []byte) ([]byte, *newspolyglot.ArticleObject)
  • func (adb *ArticleDirectBackend) ArticleGroupList(group []byte, first, last int64, targ func(int64))
  • func (adb *ArticleDirectBackend) ArticleGroupMove(group []byte, i int64, backward bool, id_buf []byte) (ni int64, id []byte, ok bool)
  • func (adb *ArticleDirectBackend) ArticleGroupOverview(group []byte, first, last int64, ...)
  • func (adb *ArticleDirectBackend) ArticleGroupStat(group []byte, num int64, id_buf []byte) ([]byte, bool)
  • func (adb *ArticleDirectBackend) ArticlePostingCheckPost() (possible bool)
  • func (adb *ArticleDirectBackend) ArticlePostingCheckPostId(id []byte) (wanted bool, possible bool)
  • func (adb *ArticleDirectBackend) ArticlePostingPost(headp *posting.HeadInfo, body []byte, ngs [][]byte, numbs []int64) (rejected bool, failed bool, err error)
• type BucketDatabase

Variables

var EBufferTooLarge = fmt.Errorf("E-Buffer-Too-Large")

Types

type ArticleDirectBackend

type ArticleDirectBackend struct {
	Store  bucketstore.OverStore
	Bdb    BucketDatabase
	Policy policies.PostingPolicy
}

func (*ArticleDirectBackend) ArticleDirectGet

func (adb *ArticleDirectBackend) ArticleDirectGet(id []byte, head, body bool) *newspolyglot.ArticleObject

func (*ArticleDirectBackend) ArticleDirectOverview

func (adb *ArticleDirectBackend) ArticleDirectOverview(id []byte) *newspolyglot.ArticleOverview

func (*ArticleDirectBackend) ArticleDirectStat

func (adb *ArticleDirectBackend) ArticleDirectStat(id []byte) bool

func (*ArticleDirectBackend) ArticleGroupGet

func (adb *ArticleDirectBackend) ArticleGroupGet(group []byte, num int64, head, body bool, id_buf []byte) ([]byte, *newspolyglot.ArticleObject)

func (*ArticleDirectBackend) ArticleGroupList

func (adb *ArticleDirectBackend) ArticleGroupList(group []byte, first, last int64, targ func(int64))

func (*ArticleDirectBackend) ArticleGroupMove

func (adb *ArticleDirectBackend) ArticleGroupMove(group []byte, i int64, backward bool, id_buf []byte) (ni int64, id []byte, ok bool)

func (*ArticleDirectBackend) ArticleGroupOverview

func (adb *ArticleDirectBackend) ArticleGroupOverview(group []byte, first, last int64, targ func(int64, *newspolyglot.ArticleOverview))

func (*ArticleDirectBackend) ArticleGroupStat

func (adb *ArticleDirectBackend) ArticleGroupStat(group []byte, num int64, id_buf []byte) ([]byte, bool)

func (*ArticleDirectBackend) ArticlePostingCheckPost

func (adb *ArticleDirectBackend) ArticlePostingCheckPost() (possible bool)

func (*ArticleDirectBackend) ArticlePostingCheckPostId

func (adb *ArticleDirectBackend) ArticlePostingCheckPostId(id []byte) (wanted bool, possible bool)

func (*ArticleDirectBackend) ArticlePostingPost

func (adb *ArticleDirectBackend) ArticlePostingPost(headp *posting.HeadInfo, body []byte, ngs [][]byte, numbs []int64) (rejected bool, failed bool, err error)

type BucketDatabase

type BucketDatabase interface {
	InsertGoupMapping(group []byte, num int64, msgid []byte, expire time.Time) error
	InsertIDMapping(msgid, bucket []byte, expire time.Time) error
	Expire(expire time.Time) error

	QueryGroupMapping(group []byte, num int64) (msgid, bucket bufferex.Binary, err error)
	QueryIDMapping(msgid []byte) (bucket bufferex.Binary, err error)
	QueryGroupShift(group []byte, num int64, backward bool) (nxt int64, msgid bufferex.Binary, err error)
	QueryGroupList(group []byte, first, last int64, targ func(num int64, bucket, msgid bufferex.Binary)) error
}