runner

package

v0.56.0 Latest Latest Go to latest Published: Apr 19, 2024 License: BSD-2-Clause, BSD-3-Clause, PostgreSQL Imports: 38 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 CollectActivityFromAllServers(ctx context.Context, servers []*state.Server, ...) (allSuccessful bool)
func CollectAllServers(ctx context.Context, servers []*state.Server, ...) (allSuccessful bool)
func EmitTestExplain(ctx context.Context, server *state.Server, ...) error
func EmitTestLogMsg(ctx context.Context, server *state.Server, ...) error
func GatherQueryStatsFromAllServers(ctx context.Context, servers []*state.Server, ...)
func GenerateStatsHelperSql(ctx context.Context, server *state.Server, ...) (string, error)
func RunRequestedReports(ctx context.Context, servers []*state.Server, ...)
func RunTestReport(ctx context.Context, servers []*state.Server, ...)
func SetupLogCollection(ctx context.Context, wg *sync.WaitGroup, servers []*state.Server, ...)
func TestLogsForAllServers(ctx context.Context, servers []*state.Server, ...) (hasFailedServers bool, hasSuccessfulLocalServers bool)
type RequestedReport

Constants ¶

View Source

const LogDownloadInterval time.Duration = 30 * time.Second

View Source

const LogStreamingInterval time.Duration = 10 * time.Second

Variables ¶

This section is empty.

Functions ¶

func CollectActivityFromAllServers ¶

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

CollectActivityFromAllServers - Collects activity from all servers and sends them to the pganalyze service

func CollectAllServers ¶

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

CollectAllServers - Collects statistics from all servers and sends them as full snapshots to the pganalyze service

func EmitTestExplain ¶ added in v0.45.0

func EmitTestExplain(ctx context.Context, server *state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger) error

func EmitTestLogMsg ¶ added in v0.45.0

func EmitTestLogMsg(ctx context.Context, server *state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger) error

func GatherQueryStatsFromAllServers ¶

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

func GenerateStatsHelperSql ¶ added in v0.56.0

func GenerateStatsHelperSql(ctx context.Context, server *state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger) (string, error)

func RunRequestedReports ¶

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

RunRequestedReports - Retrieves current report requests from the server, runs them and submits their data

func RunTestReport ¶

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

RunTestReport - Runs globalCollectionOpts.TestReport for all servers and outputs the result to stdout

func SetupLogCollection ¶ added in v0.42.1

func SetupLogCollection(ctx context.Context, wg *sync.WaitGroup, servers []*state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger, hasAnyHeroku bool, hasAnyGoogleCloudSQL bool, hasAnyAzureDatabase bool, hasAnyTembo bool)

SetupLogCollection - Starts streaming or scheduled downloads for logs of the specified servers

func TestLogsForAllServers ¶

func TestLogsForAllServers(ctx context.Context, servers []*state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger) (hasFailedServers bool, hasSuccessfulLocalServers bool)

TestLogsForAllServers - Test log download/tailing

Types ¶

type RequestedReport ¶

type RequestedReport struct {
	ReportType  string `json:"report_type"`
	ReportRunID string `json:"report_run_id"`
}

Source Files ¶

View all Source files

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