clusteragent

Documentation

Overview

Package clusteragent contains the logic to create the cluster agent flare archive.

Index

• Variables
• func CreateDCAArchive(local bool, distPath, logFilePath string, pdata ProfileData, ...) (string, error)
• func GetClusterAgentConfigCheck(w io.Writer, withDebug bool) error
• func GetClusterAgentDiagnose(w io.Writer) error
• func GetClusterChecks(w io.Writer, checkName string) error
• func GetEndpointsChecks(w io.Writer, checkName string) error
• func QueryDCAMetrics() ([]byte, error)
• type ProfileData

Variables

var (
	// ErrNotCompiled is returned if kubernetes apiserver support is not compiled in.
	// User classes should handle that case as gracefully as possible.
	ErrNotCompiled = errors.New("kubernetes apiserver support not compiled in")
)

Functions

func CreateDCAArchive

func CreateDCAArchive(local bool, distPath, logFilePath string, pdata ProfileData, statusComponent status.Component) (string, error)

CreateDCAArchive packages up the files

func GetClusterAgentConfigCheck

func GetClusterAgentConfigCheck(w io.Writer, withDebug bool) error

GetClusterAgentConfigCheck gets config check from the server for cluster agent

func GetClusterAgentDiagnose

func GetClusterAgentDiagnose(w io.Writer) error

GetClusterAgentDiagnose dumps the connectivity checks diagnose to the writer

func GetClusterChecks

func GetClusterChecks(w io.Writer, checkName string) error

GetClusterChecks dumps the clustercheck dispatching state to the writer

func GetEndpointsChecks

func GetEndpointsChecks(w io.Writer, checkName string) error

GetEndpointsChecks dumps the endpointschecks dispatching state to the writer

func QueryDCAMetrics

func QueryDCAMetrics() ([]byte, error)

QueryDCAMetrics gets the metrics payload exposed by the cluster agent

Types

type ProfileData

type ProfileData map[string][]byte

ProfileData maps (pprof) profile names to the profile data