logdb

Documentation

Index

• Constants
• 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 = "kubefaasFunctionLog"
	INFLUXDB_URL      = "http://influxdb:8086/query"
)

const (
	INFLUXDB = "influxdb"
)

Types

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
}