logdb

Documentation

Index

• Constants
• type ByTimestampSort
  • func ByTimestamp(entries []LogEntry, desc bool) ByTimestampSort
  • func (a ByTimestampSort) Len() int
  • func (a ByTimestampSort) Less(i, j int) bool
  • func (a ByTimestampSort) Swap(i, j int)
• type InfluxDB
  • func NewInfluxDB(serverURL string) (InfluxDB, error)
  • func (influx InfluxDB) GetLogs(filter LogFilter) ([]LogEntry, error)
• type LogDatabase
  • func GetLogDB(dbType string, serverURL string) (LogDatabase, error)
• type LogEntry
• type LogFilter

Constants

const (
	INFLUXDB_DATABASE = "fissionFunctionLog"
	INFLUXDB_URL      = "http://influxdb:8086/query"
)

const (
	INFLUXDB = "influxdb"
)

Types

type ByTimestampSort

type ByTimestampSort struct {
	// contains filtered or unexported fields
}

func ByTimestamp

func ByTimestamp(entries []LogEntry, desc bool) ByTimestampSort

func (ByTimestampSort) Len

func (a ByTimestampSort) Len() int

func (ByTimestampSort) Less

func (a ByTimestampSort) Less(i, j int) bool

func (ByTimestampSort) Swap

func (a ByTimestampSort) Swap(i, j int)

type InfluxDB

type InfluxDB struct {
	// contains filtered or unexported fields
}

func NewInfluxDB

func NewInfluxDB(serverURL string) (InfluxDB, error)

func (InfluxDB) GetLogs

func (influx InfluxDB) GetLogs(filter LogFilter) ([]LogEntry, error)

type LogDatabase

type LogDatabase interface {
	GetLogs(LogFilter) ([]LogEntry, error)
}

func GetLogDB

func GetLogDB(dbType string, serverURL string) (LogDatabase, error)

type LogEntry

type LogEntry struct {
	Timestamp time.Time
	Message   string
	Stream    string
	Sequence  int
	Container string
	Namespace string
	FuncName  string
	FuncUid   string
	Pod       string
}

type LogFilter

type LogFilter struct {
	Pod         string
	Function    string
	FuncUid     string
	Since       time.Time
	Reverse     bool
	RecordLimit int
}