cluster

Documentation

Index

• Constants
• func ReadAndParseFile(filePath string) (stats.PerfLogs, error)
• type ClusterRunner
  • func New(options config.Options) *ClusterRunner
  • func (r *ClusterRunner) Cleanup()
  • func (r *ClusterRunner) Config() string
  • func (r *ClusterRunner) Deploy()
  • func (r *ClusterRunner) FetchApplicationLogs() error
  • func (r *ClusterRunner) Namespace() string
  • func (r *ClusterRunner) Pod() string
  • func (r *ClusterRunner) ReadApplicationLogs() (stats.PerfLogs, error)
  • func (r *ClusterRunner) SampleCollector() *stats.Sample

Constants

const (
	PodLogsDirName = "varlogpods"
)

Functions

func ReadAndParseFile

func ReadAndParseFile(filePath string) (stats.PerfLogs, error)

Types

type ClusterRunner

type ClusterRunner struct {
	config.Options
	// contains filtered or unexported fields
}

func New

func New(options config.Options) *ClusterRunner

func (*ClusterRunner) Cleanup

func (r *ClusterRunner) Cleanup()

func (*ClusterRunner) Config

func (r *ClusterRunner) Config() string

func (*ClusterRunner) Deploy

func (r *ClusterRunner) Deploy()

func (*ClusterRunner) FetchApplicationLogs

func (r *ClusterRunner) FetchApplicationLogs() error

func (*ClusterRunner) Namespace

func (r *ClusterRunner) Namespace() string

func (*ClusterRunner) Pod

func (r *ClusterRunner) Pod() string

func (*ClusterRunner) ReadApplicationLogs

func (r *ClusterRunner) ReadApplicationLogs() (stats.PerfLogs, error)

func (*ClusterRunner) SampleCollector

func (r *ClusterRunner) SampleCollector() *stats.Sample