runner

Documentation

Index

• func CollectActivityFromAllServers(servers []*state.Server, globalCollectionOpts state.CollectionOpts, ...) (allSuccessful bool)
• func CollectAllServers(servers []*state.Server, globalCollectionOpts state.CollectionOpts, ...) (allSuccessful bool)
• func DownloadLogsFromAllServers(servers []*state.Server, globalCollectionOpts state.CollectionOpts, ...)
• func GatherQueryStatsFromAllServers(servers []*state.Server, globalCollectionOpts state.CollectionOpts, ...)
• func RunRequestedReports(servers []*state.Server, globalCollectionOpts state.CollectionOpts, ...)
• func RunTestReport(servers []*state.Server, globalCollectionOpts state.CollectionOpts, ...)
• func TestLogsForAllServers(servers []*state.Server, globalCollectionOpts state.CollectionOpts, ...) (hasFailedServers bool, hasSuccessfulLocalServers bool)
• type RequestedReport

Functions

func CollectActivityFromAllServers

func CollectActivityFromAllServers(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(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 DownloadLogsFromAllServers

func DownloadLogsFromAllServers(servers []*state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger)

DownloadLogsFromAllServers - Downloads logs from all servers that are remote systems and sends them to the pganalyze service

func GatherQueryStatsFromAllServers

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

func RunRequestedReports

func RunRequestedReports(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(servers []*state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger)

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

func TestLogsForAllServers

func TestLogsForAllServers(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"`
}