cassandra

package
v0.0.0-...-5dcd16a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

Apache Cassandra based Backend for Article Storage.

Warning: This is not the final version - assume breaking changes.

Index

Constants

This section is empty.

Variables

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

Functions

func GnvTable

func GnvTable(ksp gocassa.KeySpace) gocassa.Table

func NewStoredArticleTable

func NewStoredArticleTable(ks gocassa.KeySpace) gocassa.Table

Types

type ArticleStorage

type ArticleStorage struct {
	Policy policies.PostingPolicy
	// contains filtered or unexported fields
}

func NewArticleStorage

func NewArticleStorage(ks gocassa.KeySpace) *ArticleStorage

func (*ArticleStorage) ArticleDirectGet

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

func (*ArticleStorage) ArticleDirectOverview

func (a *ArticleStorage) ArticleDirectOverview(id []byte) *newspolyglot.ArticleOverview

func (*ArticleStorage) ArticleDirectStat

func (a *ArticleStorage) ArticleDirectStat(id []byte) bool

func (*ArticleStorage) ArticleGroupGet

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

func (*ArticleStorage) ArticleGroupList

func (a *ArticleStorage) ArticleGroupList(group []byte, first, last int64, targ func(int64))

func (*ArticleStorage) ArticleGroupMove

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

func (*ArticleStorage) ArticleGroupOverview

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

func (*ArticleStorage) ArticleGroupStat

func (a *ArticleStorage) ArticleGroupStat(group []byte, num int64, id_buf []byte) ([]byte, bool)

func (*ArticleStorage) ArticlePostingCheckPost

func (a *ArticleStorage) ArticlePostingCheckPost() (possible bool)

func (*ArticleStorage) ArticlePostingCheckPostId

func (a *ArticleStorage) ArticlePostingCheckPostId(id []byte) (wanted bool, possible bool)

func (*ArticleStorage) ArticlePostingPost

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

func (*ArticleStorage) Initialize

func (a *ArticleStorage) Initialize()

type GroupNumValue

type GroupNumValue struct {
	Partit   []byte
	Clustr   int
	OrigNo   int64
	Value    []byte
	ExpireAt time.Time
}

type StoredArticle

type StoredArticle struct {
	MsgId, Head, Body, Over []byte
	ExpireAt                time.Time
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL