logdb

Documentation

Index

• Constants
• func GetFunctionPodLogs(ctx context.Context, client cmd.Client, logFilter LogFilter, ...) (err error)
• func NewKubernetesEndpoint(logDBOptions LogDBOptions) (kubernetesLogs, error)
• 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(ctx context.Context, logDBOptions LogDBOptions) (InfluxDB, error)
  • func (influx InfluxDB) GetLogs(ctx context.Context, filter LogFilter, output *bytes.Buffer) (err error)
• type LogDBOptions
• type LogDatabase
  • func GetLogDB(dbType string, ctx context.Context, logDBOptions LogDBOptions) (LogDatabase, error)
• type LogEntry
• type LogFilter

Constants

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

const (
	INFLUXDB   = "influxdb"
	KUBERNETES = "kubernetes"
)

Functions

func GetFunctionPodLogs

func GetFunctionPodLogs(ctx context.Context, client cmd.Client, logFilter LogFilter, podLogs *bytes.Buffer) (err error)

FunctionPodLogs : Get logs for a function directly from pod

func NewKubernetesEndpoint

func NewKubernetesEndpoint(logDBOptions LogDBOptions) (kubernetesLogs, error)

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(ctx context.Context, logDBOptions LogDBOptions) (InfluxDB, error)

func (InfluxDB) GetLogs

func (influx InfluxDB) GetLogs(ctx context.Context, filter LogFilter, output *bytes.Buffer) (err error)

type LogDBOptions

type LogDBOptions struct {
	Client cmd.Client
}

type LogDatabase

type LogDatabase interface {
	GetLogs(context.Context, LogFilter, *bytes.Buffer) error
}

func GetLogDB

func GetLogDB(dbType string, ctx context.Context, logDBOptions LogDBOptions) (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
	PodNamespace   string
	Function       string
	FuncUid        string
	Since          time.Time
	Reverse        bool
	RecordLimit    int
	FunctionObject *v1.Function
	Details        bool
	WarnUser       bool
	AllPods        bool
}