db

Documentation

Index

• func SaveEntry(signature, message string) (string, error)
• type Entry
  • func GetEntries(signature string) ([]Entry, error)
  • func NewEntry(sender, text string, ts time.Time) *Entry
• type Instance
  • func NewInstance(host, port string) *Instance
  • func (i *Instance) AddEntry(signature, txt string) (bool, error)
  • func (i *Instance) Close()
  • func (i *Instance) Connect(dbname, collname string) (context.CancelFunc, error)
  • func (i *Instance) GetEntries(signature string) ([]Entry, error)

Functions

func SaveEntry

func SaveEntry(signature, message string) (string, error)

SaveEntry is the db wrapper to save an entry

Types

type Entry

type Entry struct {
	Signature string
	TS        time.Time
	Message   string
}

Entry is a MongoDB object

func GetEntries

func GetEntries(signature string) ([]Entry, error)

GetEntries is the db wrapper to get entries

func NewEntry

func NewEntry(sender, text string, ts time.Time) *Entry

NewEntry creates a new MS

type Instance

type Instance struct {
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

Instance is the interface for the database

func NewInstance

func NewInstance(host, port string) *Instance

NewInstance creates a new database engine

func (*Instance) AddEntry

func (i *Instance) AddEntry(signature, txt string) (bool, error)

AddEntry adds an entry to the database

func (*Instance) Close

func (i *Instance) Close()

Close the database connection, to be deferred

func (*Instance) Connect

func (i *Instance) Connect(dbname, collname string) (context.CancelFunc, error)

Connect to the MongoDB database

func (*Instance) GetEntries

func (i *Instance) GetEntries(signature string) ([]Entry, error)

GetEntries given an input signature, returns all entries from the database