stream

package

v0.56.0 Latest Latest Go to latest Published: Apr 19, 2024 License: BSD-2-Clause, BSD-3-Clause, PostgreSQL Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pganalyze/collector

Links

Open Source Insights

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 ¶

View Source

const InvalidPid int32 = -1

View Source

const StreamReadyThreshold time.Duration = 3 * time.Second

View Source

const UnknownPid int32 = 0

Variables ¶

This section is empty.

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 ¶ added in v0.42.1

type LogLineReadiness int

const (
	LogLineDefer LogLineReadiness = iota
	LogLineReady
	LogLineDiscard
)

Source Files ¶

View all Source files

stream.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL