queue

Documentation

Index

• Variables
• func Close()
• func InitConfig() error
• func ProcessCommentQueue(q *CommentQueue) (err error)
• func ProcessCommentQueueStr(q *CommentQueueStr) (err error)
• func QueueCommentDBCS(bboardID bbs.BBoardID, articleID bbs.ArticleID, ownerID bbs.UUserID, ...) (err error)
• func QueueCommentDBCSStr(bboardID bbs.BBoardID, articleID bbs.ArticleID, ownerID bbs.UUserID, ...) (err error)
• func SetIsTest()
• func Start() error
• func UnsetIsTest()
• type CommentQueue
• type CommentQueueStr

Variables

var (
	QUEUE_SIZE = 4096
	WORKER_NUM = 2
)

var IsTest = false

Functions

func Close

func Close()

func InitConfig

func InitConfig() error

func ProcessCommentQueue

func ProcessCommentQueue(q *CommentQueue) (err error)

ProcessCommentQueue

We use LastTime as the reference time to obtain stable timestamp. (lastTime is from firstComments, assuming not change a lot.) (mtime changes frequently and may result in unstable timestamp.)

func ProcessCommentQueueStr

func ProcessCommentQueueStr(q *CommentQueueStr) (err error)

ProcessCommentQueue

We use LastTime as the reference time to obtain stable timestamp. (lastTime is from firstComments, assuming not change a lot.) (mtime changes frequently and may result in unstable timestamp.)

func QueueCommentDBCS

func QueueCommentDBCS(bboardID bbs.BBoardID, articleID bbs.ArticleID, ownerID bbs.UUserID, commentDBCS []byte, articleCreateTime types.NanoTS, articleMTime types.NanoTS, updateNanoTS types.NanoTS) (err error)

func QueueCommentDBCSStr

func QueueCommentDBCSStr(bboardID bbs.BBoardID, articleID bbs.ArticleID, ownerID bbs.UUserID, commentDBCS string, articleCreateTime types.NanoTS, articleMTime types.NanoTS, updateNanoTS types.NanoTS) (err error)

func SetIsTest

func SetIsTest()

func Start

func Start() error

func UnsetIsTest

func UnsetIsTest()

Types

type CommentQueue

type CommentQueue struct {
	BBoardID          bbs.BBoardID
	ArticleID         bbs.ArticleID
	OwnerID           bbs.UUserID
	CommentDBCS       []byte
	ArticleCreateTime types.NanoTS
	ArticleMTime      types.NanoTS
	UpdateNanoTS      types.NanoTS
}

type CommentQueueStr

type CommentQueueStr struct {
	BBoardID          bbs.BBoardID
	ArticleID         bbs.ArticleID
	OwnerID           bbs.UUserID
	CommentDBCS       string
	ArticleCreateTime types.NanoTS
	ArticleMTime      types.NanoTS
	UpdateNanoTS      types.NanoTS
}