stream

Documentation

Index

• Constants
• func AnalyzeStreamInGroups(logLines []state.LogLine, now time.Time, server *state.Server, ...) (state.TransientLogState, state.LogFile, []state.LogLine, error)
• func LogTestAnyEvent(server *state.Server, logFile state.LogFile, logTestSucceeded chan<- bool)
• func LogTestCollectorIdentify(server *state.Server, logFile state.LogFile, logTestSucceeded chan<- bool)
• func LogTestNone(server *state.Server, logFile state.LogFile, logTestSucceeded chan<- bool)
• type LogLineReadiness

Constants

const InvalidPid int32 = -1

const StreamReadyThreshold time.Duration = 3 * time.Second

const UnknownPid int32 = 0

Functions

func AnalyzeStreamInGroups

func AnalyzeStreamInGroups(logLines []state.LogLine, now time.Time, server *state.Server, logger *util.Logger) (state.TransientLogState, state.LogFile, []state.LogLine, error)

AnalyzeStreamInGroups - Takes in a set of parsed log lines and analyses the lines that are ready, and returns the rest

The caller is expected to keep a repository of "tooFreshLogLines" that they can send back in again in the next call, combined with new lines received

func LogTestAnyEvent

func LogTestAnyEvent(server *state.Server, logFile state.LogFile, logTestSucceeded chan<- bool)

LogTestAnyEvent - Checks for any log message (used on log pipelines that take longer than 10 seconds, e.g. Azure Event Hub)

func LogTestCollectorIdentify

func LogTestCollectorIdentify(server *state.Server, logFile state.LogFile, logTestSucceeded chan<- bool)

LogTestCollectorIdentify - Checks for the special "pganalyze-collector-identify:" event (used on log pipelines that forward messages under than 10 seconds)

func LogTestNone

func LogTestNone(server *state.Server, logFile state.LogFile, logTestSucceeded chan<- bool)

LogTestNone - Don't confirm the log test

Types

type LogLineReadiness

type LogLineReadiness int

const (
	LogLineDefer LogLineReadiness = iota
	LogLineReady
	LogLineDiscard
)