thread

Documentation

Index

• Constants
• func CleanRecords()
• func CreateAllCachedirs()
• func Len() int
• func RemoveRemoved()
• type Cache
  • func NewCache(datfile string) *Cache
  • func (c *Cache) CheckData(res string, stamp int64, id string, begin, end int64) error
  • func (c *Cache) Exists() bool
  • func (c *Cache) GetContents() []string
  • func (c *Cache) Gettitle() string
  • func (c *Cache) HasRecord() bool
  • func (c *Cache) Len() int
  • func (c *Cache) LoadRecords(kind int) record.Map
  • func (c *Cache) RecentStamp() int64
  • func (c *Cache) Remove()
  • func (c *Cache) Size() int64
  • func (c *Cache) Stamp() int64
  • func (c *Cache) Subscribe()
  • func (c *Cache) Velocity() int
• type Caches
  • func AllCaches() Caches
  • func MakeRecentCachelist() Caches
  • func Search(q string) Caches
  • func (c Caches) Has(cc *Cache) bool
  • func (c Caches) Len() int
• type SortByStamp
  • func NewSortByStamp(cs Caches, recentStamp bool) *SortByStamp
  • func (c *SortByStamp) Less(i, j int) bool
  • func (c *SortByStamp) Swap(i, j int)
• type SortByVelocity
  • func NewSortByVelocity(cs Caches) *SortByVelocity
  • func (c *SortByVelocity) Less(i, j int) bool
  • func (c *SortByVelocity) Swap(i, j int)

Constants

const (
	//Alive counts records that are not removed.
	Alive = 1
	//Removed counts records that are  removed.
	Removed = 2
	//All counts all records
	All = 3
)

Functions

func CleanRecords

func CleanRecords()

CleanRecords remove old or duplicates records for each Caches.

func CreateAllCachedirs

func CreateAllCachedirs()

CreateAllCachedirs creates all dirs in recentlist to be retrived when called recentlist.getall. (heavymoon)

func Len

func Len() int

Len returns # of Caches

func RemoveRemoved

func RemoveRemoved()

RemoveRemoved removes files in removed dir if old.

Types

type Cache

type Cache struct {
	Datfile string
}

Cache represents cache of one file.

func NewCache

func NewCache(datfile string) *Cache

NewCache read tag files to set and returns cache obj. it uses sync.pool to ensure that only one cache obj exists for one datfile. and garbage collected when not used.

func (*Cache) CheckData

func (c *Cache) CheckData(res string, stamp int64, id string, begin, end int64) error

CheckData makes a record from res and checks its records meets condisions of args. adds the rec to cache if meets conditions. if spam or big data, remove the rec from disk. returns count of added records to the cache and spam/getting error.

func (*Cache) Exists

func (c *Cache) Exists() bool

Exists return true is datapath exists.

func (*Cache) GetContents

func (c *Cache) GetContents() []string

GetContents returns recstrs of cache. len(recstrs) is <=2.

func (*Cache) Gettitle

func (c *Cache) Gettitle() string

Gettitle returns title part if *_*. returns ca.datfile if not.

func (*Cache) HasRecord

func (c *Cache) HasRecord() bool

HasRecord return true if cache has more than one records or removed records.

func (*Cache) Len

func (c *Cache) Len() int

Len returns # of records in the cache.

func (*Cache) LoadRecords

func (c *Cache) LoadRecords(kind int) record.Map

LoadRecords loads and returns record maps from the disk..

func (*Cache) RecentStamp

func (c *Cache) RecentStamp() int64

RecentStamp returns time of getting by /recent.

func (*Cache) Remove

func (c *Cache) Remove()

Remove Remove all files and dirs of cache.

func (*Cache) Size

func (c *Cache) Size() int64

Size returns sum of body char length of records in the cache.

func (*Cache) Stamp

func (c *Cache) Stamp() int64

Stamp returns lastest stampl of records in the cache.

func (*Cache) Subscribe

func (c *Cache) Subscribe()

Subscribe add the thread to thread db.

func (*Cache) Velocity

func (c *Cache) Velocity() int

Velocity returns number of records in one days in the cache.

type Caches

type Caches []*Cache

Caches is a slice of *cache

func AllCaches

func AllCaches() Caches

AllCaches returns all thread names

func MakeRecentCachelist

func MakeRecentCachelist() Caches

MakeRecentCachelist returns sorted cachelist copied from Recentlist. which doens't contain duplicate Caches.

func Search

func Search(q string) Caches

Search reloads records in Caches in cachelist and returns slice of cache which matches query.

func (Caches) Has

func (c Caches) Has(cc *Cache) bool

Has return true is Caches has cache cc

func (Caches) Len

func (c Caches) Len() int

Len returns size of cache slice.

type SortByStamp

type SortByStamp struct {
	Caches
	// contains filtered or unexported fields
}

SortByStamp is for sorting by stamp.

func NewSortByStamp

func NewSortByStamp(cs Caches, recentStamp bool) *SortByStamp

NewSortByStamp makes stamps for caches and returns SortByStamp obj.

func (*SortByStamp) Less

func (c *SortByStamp) Less(i, j int) bool

Less returns true if cache[i].stamp < cache[j].stamp.

func (*SortByStamp) Swap

func (c *SortByStamp) Swap(i, j int)

Swap swaps order of cache slice.

type SortByVelocity

type SortByVelocity struct {
	Caches
	// contains filtered or unexported fields
}

SortByVelocity is for sorting by velocity.

func NewSortByVelocity

func NewSortByVelocity(cs Caches) *SortByVelocity

NewSortByVelocity makes velocity for caches and returns SortByVelocity obj.

func (*SortByVelocity) Less

func (c *SortByVelocity) Less(i, j int) bool

Less returns true if cache[i].velocity < cache[j].velocity. if velocity[i]==velocity[j], returns true if cache[i].size< cache[j].size.

func (*SortByVelocity) Swap

func (c *SortByVelocity) Swap(i, j int)

Swap swaps order of cache slice.