database

Documentation

Index

• type ClipText
• type DB
  • func (db *DB) AllAnchors() (anchors []Message, err error)
  • func (db *DB) AllByUpdatedAt() (all []Message, err error)
  • func (db *DB) AllClips() (all []ClipText, err error)
  • func (db *DB) AllFiles() (files []Message, err error)
  • func (db *DB) Close() error
  • func (db *DB) Delete(id string) error
  • func (db *DB) DeleteAllClips() error
  • func (db *DB) DeleteAllFiles() error
  • func (db *DB) DeleteClip(id string) error
  • func (db *DB) DeleteMessages(messages []Message) error
  • func (db *DB) ExpiredItems() (items []Message, err error)
  • func (db *DB) GetTotalSize() (size int64, err error)
  • func (db *DB) GreyItems() (items []Message, err error)
  • func (db *DB) Insert(message *Message) error
  • func (db *DB) InsertClip(textMsg string, limit int) (*ClipText, error)
  • func (db *DB) InsertTextMsg(textMsg string) (message *Message, err error)
  • func (db *DB) LastTextMsg() (string, error)
  • func (db *DB) NewFileMsg(filename string) (*Message, error)
  • func (db *DB) NewTextMsg(textMsg string) (*Message, error)
  • func (db *DB) NewZipMsg(filename string) (*Message, error)
  • func (db *DB) OldClips(n int) (items []ClipText, err error)
  • func (db *DB) OldFiles(n int) (files []Message, err error)
  • func (db *DB) OldItems(n int) (items []Message, err error)
  • func (db *DB) Open(maxAge time.Duration, cap int64, dbPath string) (err error)
  • func (db *DB) SessionCheck(c *fiber.Ctx) bool
  • func (db *DB) SessionSet(c *fiber.Ctx) error
  • func (db *DB) UpdateClipDatetime(id string) error
  • func (db *DB) UpdateDatetime(id string) error
• type IncreaseID
• type Message

Types

type ClipText

type ClipText = model.ClipText

type DB

type DB struct {
	DB   *storm.DB
	Sess *session.Store

	// 只在 package database 外部使用锁，不在 package database 内部使用锁。
	sync.Mutex
	// contains filtered or unexported fields
}

DB .

func (*DB) AllAnchors

func (db *DB) AllAnchors() (anchors []Message, err error)

AllAnchors finds all anchors(FileType = GosendAnchor).

func (*DB) AllByUpdatedAt

func (db *DB) AllByUpdatedAt() (all []Message, err error)

AllByUpdatedAt .

func (*DB) AllClips

func (db *DB) AllClips() (all []ClipText, err error)

AllClips .

func (*DB) AllFiles

func (db *DB) AllFiles() (files []Message, err error)

AllFiles finds all files(Type = FileMsg).

func (*DB) Close

func (db *DB) Close() error

Close 只是 db.DB.Close(), 不清空 db 里的其它部分。

func (*DB) Delete

func (db *DB) Delete(id string) error

Delete by id

func (*DB) DeleteAllClips

func (db *DB) DeleteAllClips() error

DeleteAllClips .

func (*DB) DeleteAllFiles

func (db *DB) DeleteAllFiles() error

DeleteAllFiles .

func (*DB) DeleteClip

func (db *DB) DeleteClip(id string) error

DeleteClip a clip by id

func (*DB) DeleteMessages

func (db *DB) DeleteMessages(messages []Message) error

DeleteMessages deletes messages by IDs.

func (*DB) ExpiredItems

func (db *DB) ExpiredItems() (items []Message, err error)

ExpiredItems 找出过期的条目

func (*DB) GetTotalSize

func (db *DB) GetTotalSize() (size int64, err error)

GetTotalSize .

func (*DB) GreyItems

func (db *DB) GreyItems() (items []Message, err error)

GreyItems 找出变灰的条目

func (*DB) Insert

func (db *DB) Insert(message *Message) error

Insert .

func (*DB) InsertClip

func (db *DB) InsertClip(textMsg string, limit int) (*ClipText, error)

InsertClip inserts textMsg as a clip, and delete the oldest clip if the numbers of clips is over limit.

func (*DB) InsertTextMsg

func (db *DB) InsertTextMsg(textMsg string) (message *Message, err error)

InsertTextMsg .

func (*DB) LastTextMsg

func (db *DB) LastTextMsg() (string, error)

LastTextMsg .

func (*DB) NewFileMsg

func (db *DB) NewFileMsg(filename string) (*Message, error)

NewFileMsg .

func (*DB) NewTextMsg

func (db *DB) NewTextMsg(textMsg string) (*Message, error)

NewTextMsg .

func (*DB) NewZipMsg

func (db *DB) NewZipMsg(filename string) (*Message, error)

NewZipMsg 用于自动打包，具有特殊的文件类型，避免重复打包。 注意在该函数里对文件名进行了特殊处理。

func (*DB) OldClips

func (db *DB) OldClips(n int) (items []ClipText, err error)

OldClips 找出最老的 (更新日期最早的) n 条 clip，返回 []ClipText.

func (*DB) OldFiles

func (db *DB) OldFiles(n int) (files []Message, err error)

OldFiles 找出最老的 (更新日期最早的) n 个文件 (Type = FileMsg) 返回 []Message.

func (*DB) OldItems

func (db *DB) OldItems(n int) (items []Message, err error)

OldItems 找出最老的 (更新日期最早的) n 条记录，返回 []Message.

func (*DB) Open

func (db *DB) Open(maxAge time.Duration, cap int64, dbPath string) (err error)

Open .

func (*DB) SessionCheck

func (db *DB) SessionCheck(c *fiber.Ctx) bool

SessionCheck .

func (*DB) SessionSet

func (db *DB) SessionSet(c *fiber.Ctx) error

SessionSet .

func (*DB) UpdateClipDatetime

func (db *DB) UpdateClipDatetime(id string) error

UpdateClipDatetime ...

func (*DB) UpdateDatetime

func (db *DB) UpdateDatetime(id string) error

UpdateDatetime ...

type IncreaseID

type IncreaseID = model.IncreaseID

type Message

type Message = model.Message