logMongos

Documentation

Index

• type Conn
  • func NewConn(shards string, db string) *Conn
  • func (x Conn) CountInTimeRange(colName string, text string, timestamp time.Time) (int64, error)
  • func (x Conn) CountInTimeRangeRetry(colName string, text string, timeStamp time.Time, attempts int) (int64, error)
  • func (x Conn) CountJobsInPeriod(since string, hub string) (int64, error)
  • func (x Conn) FindOne(colName string, lvl string, text string) (LogLine, error)
  • func (x Conn) GetCollection(coll string) ([]LogLine, error)
  • func (x Conn) GetCollectionRetry(coll string, attempts int) ([]LogLine, error)
  • func (x Conn) GetCollections() ([]string, error)
  • func (x Conn) GetHubsCount(col string, since string) ([]HubsGroupCount, error)
  • func (x Conn) GetHubsCountRetry(colName string, since string, attempts int) ([]HubsGroupCount, error)
  • func (x Conn) GetTotalJobs(hub string, db string) (int64, error)
  • func (x Conn) GetTotalLinks(hub string) (int64, error)
  • func (x Conn) InsertPost(coll string, line LogLine)
  • func (x Conn) InsertPosts(coll string, lines []LogLine)
• type HubsGroupCount
• type Insertion
• type LogLine

Types

type Conn

type Conn struct {
	DB     string
	URI    string
	OPTS   *options.ClientOptions
	BUFFER []Insertion
}

Conn ...class object of mongo connection

func NewConn

func NewConn(shards string, db string) *Conn

func (Conn) CountInTimeRange

func (x Conn) CountInTimeRange(colName string, text string, timestamp time.Time) (int64, error)

func (Conn) CountInTimeRangeRetry

func (x Conn) CountInTimeRangeRetry(colName string, text string, timeStamp time.Time, attempts int) (int64, error)

func (Conn) CountJobsInPeriod

func (x Conn) CountJobsInPeriod(since string, hub string) (int64, error)

func (Conn) FindOne

func (x Conn) FindOne(colName string, lvl string, text string) (LogLine, error)

func (Conn) GetCollection

func (x Conn) GetCollection(coll string) ([]LogLine, error)

func (Conn) GetCollectionRetry

func (x Conn) GetCollectionRetry(coll string, attempts int) ([]LogLine, error)

func (Conn) GetCollections

func (x Conn) GetCollections() ([]string, error)

func (Conn) GetHubsCount

func (x Conn) GetHubsCount(col string, since string) ([]HubsGroupCount, error)

func (Conn) GetHubsCountRetry

func (x Conn) GetHubsCountRetry(colName string, since string, attempts int) ([]HubsGroupCount, error)

func (Conn) GetTotalJobs

func (x Conn) GetTotalJobs(hub string, db string) (int64, error)

func (Conn) GetTotalLinks

func (x Conn) GetTotalLinks(hub string) (int64, error)

func (Conn) InsertPost

func (x Conn) InsertPost(coll string, line LogLine)

InsertPost ...(column, timestamp, level, message) into the DB

func (Conn) InsertPosts

func (x Conn) InsertPosts(coll string, lines []LogLine)

InsertPosts ...(column, timestamp, level, message) into the DB

type HubsGroupCount

type HubsGroupCount struct {
	Name  string `json:"Name"`
	Count int    `json:"Count"`
}

type Insertion

type Insertion struct {
	Collection string
	Lines      []LogLine
	Attempts   int16
}

type LogLine

type LogLine struct {
	Timestamp time.Time `json:"Timestamp"`
	Filename  string    `json:"Filename"`
	Function  string    `json:"Function"`
	Line      int       `json:"Line"`
	Level     string    `json:"Level"`
	Message   string    `json:"Message"`
}