selfhosted

Documentation

Index

• func DiscoverLogLocation(ctx context.Context, servers []*state.Server, ...)
• func GetSystemState(server *state.Server, logger *util.Logger) (system state.SystemState)
• func SetupLogTailForServer(ctx context.Context, wg *sync.WaitGroup, ...) error
• func SetupLogTails(ctx context.Context, wg *sync.WaitGroup, ...)
• func SetupOtelHandlerForServer(ctx context.Context, wg *sync.WaitGroup, ...) error
• type SelfHostedLogStreamItem

Functions

func DiscoverLogLocation

func DiscoverLogLocation(ctx context.Context, servers []*state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger)

DiscoverLogLocation - Tries to find the log location for a currently running Postgres process and outputs the presumed location using the logger

func GetSystemState

func GetSystemState(server *state.Server, logger *util.Logger) (system state.SystemState)

GetSystemState - Gets system information about a self-hosted (physical/virtual) system

func SetupLogTailForServer

func SetupLogTailForServer(ctx context.Context, wg *sync.WaitGroup, globalCollectionOpts state.CollectionOpts, logger *util.Logger, server *state.Server, parsedLogStream chan state.ParsedLogStreamItem) error

func SetupLogTails

func SetupLogTails(ctx context.Context, wg *sync.WaitGroup, globalCollectionOpts state.CollectionOpts, logger *util.Logger, servers []*state.Server, parsedLogStream chan state.ParsedLogStreamItem)

SetupLogTails - Sets up continuously running log tails for all servers with a local log directory or file specified

func SetupOtelHandlerForServer

func SetupOtelHandlerForServer(ctx context.Context, wg *sync.WaitGroup, globalCollectionOpts state.CollectionOpts, logger *util.Logger, server *state.Server, parsedLogStream chan state.ParsedLogStreamItem) error

Types

type SelfHostedLogStreamItem

type SelfHostedLogStreamItem struct {
	Line string

	// Optional, only used for syslog messages
	OccurredAt         time.Time
	BackendPid         int32
	LogLineNumber      int32
	LogLineNumberChunk int32
}