collectors

Documentation

Index

• Constants
• func Ping(addrList []string, count int, timeout time.Duration, debug bool) (map[string]*SPingResult, error)
• type BucketStatsOptions
• type PingProbeColectorFactory
  • func (p PingProbeColectorFactory) GetId() string
  • func (p PingProbeColectorFactory) NewCloudReport(provider *common.SProvider, session *mcclient.ClientSession, ...) common.ICloudReport
• type SPingProbeColectorReport
  • func (self *SPingProbeColectorReport) Report() error
• type SPingResult
  • func NewPingResult(addr string, count int) *SPingResult
  • func (pr *SPingResult) Add(rtt time.Duration)
  • func (pr SPingResult) Loss() int
  • func (pr SPingResult) Rtt() (min time.Duration, avg time.Duration, max time.Duration)
  • func (pr SPingResult) String() string
• type SUsageColectorReport
  • func (self *SUsageColectorReport) Report() error
• type TListFunc
• type TProcessFunc
• type UsageColectorFactory
  • func (p UsageColectorFactory) GetId() string
  • func (p UsageColectorFactory) NewCloudReport(provider *common.SProvider, session *mcclient.ClientSession, ...) common.ICloudReport

Constants

const (
	REDIS_CRON_JOB_NAME = "redis_cron"
)

Functions

func Ping

func Ping(addrList []string, count int, timeout time.Duration, debug bool) (map[string]*SPingResult, error)

Types

type BucketStatsOptions

type BucketStatsOptions struct {
	Debug bool `help:"debug"`
}

type PingProbeColectorFactory

type PingProbeColectorFactory struct {
	common.CommonReportFactory
}

func (PingProbeColectorFactory) GetId

func (p PingProbeColectorFactory) GetId() string

func (PingProbeColectorFactory) NewCloudReport

func (p PingProbeColectorFactory) NewCloudReport(provider *common.SProvider, session *mcclient.ClientSession, args *options.ReportOptions, operatorType string) common.ICloudReport

type SPingProbeColectorReport

type SPingProbeColectorReport struct {
	common.CloudReportBase
}

func (*SPingProbeColectorReport) Report

func (self *SPingProbeColectorReport) Report() error

type SPingResult

type SPingResult struct {
	// contains filtered or unexported fields
}

func NewPingResult

func NewPingResult(addr string, count int) *SPingResult

func (*SPingResult) Add

func (pr *SPingResult) Add(rtt time.Duration)

func (SPingResult) Loss

func (pr SPingResult) Loss() int

func (SPingResult) Rtt

func (pr SPingResult) Rtt() (min time.Duration, avg time.Duration, max time.Duration)

func (SPingResult) String

func (pr SPingResult) String() string

type SUsageColectorReport

type SUsageColectorReport struct {
	common.CloudReportBase
}

func (*SUsageColectorReport) Report

func (self *SUsageColectorReport) Report() error

type TListFunc

type TListFunc func(*mcclient.ClientSession, jsonutils.JSONObject) (*modulebase.ListResult, error)

type TProcessFunc

type TProcessFunc func(jsonutils.JSONObject) error

type UsageColectorFactory

type UsageColectorFactory struct {
	common.CommonReportFactory
}

func (UsageColectorFactory) GetId

func (p UsageColectorFactory) GetId() string

func (UsageColectorFactory) NewCloudReport

func (p UsageColectorFactory) NewCloudReport(provider *common.SProvider, session *mcclient.ClientSession, args *options.ReportOptions, operatorType string) common.ICloudReport