agent

Documentation

Index

• Variables
• func End() (time.Duration, error)
• func ReloadConf() (time.Duration, error)
• func SetLogger(l *logrus.Logger)
• func Start()
• type MGroupProcessor
  • func InitGroupProcessor(cfg *config.OracleMetricGroupConfig, oralist *oracle.InstanceList) *MGroupProcessor
  • func (mgp *MGroupProcessor) BroadCastInfof(expr string, vars ...interface{})
  • func (mgp *MGroupProcessor) Debugf(i *oracle.OracleInstance, expr string, vars ...interface{})
  • func (mgp *MGroupProcessor) Errorf(i *oracle.OracleInstance, expr string, vars ...interface{})
  • func (mgp *MGroupProcessor) Infof(i *oracle.OracleInstance, expr string, vars ...interface{})
  • func (mgp *MGroupProcessor) ProcesQuery()
  • func (mgp *MGroupProcessor) StartCollection(done chan bool, s *sync.WaitGroup)
  • func (mgp *MGroupProcessor) UpdateInstances() int
  • func (mgp *MGroupProcessor) Warnf(i *oracle.OracleInstance, expr string, vars ...interface{})
• type RInfo
  • func GetRInfo() *RInfo

Variables

var (
	// Version is the app X.Y.Z version
	Version string
	// Commit is the git commit sha1
	Commit string
	// Branch is the git branch
	Branch string
	// BuildStamp is the build timestamp
	BuildStamp string
)

var (

	// MainConfig contains the global configuration
	MainConfig config.Config
)

Functions

func End

func End() (time.Duration, error)

End stops all devices polling.

func ReloadConf

func ReloadConf() (time.Duration, error)

ReloadConf stops the polling, reloads all configuration and restart the polling.

func SetLogger

func SetLogger(l *logrus.Logger)

SetLogger sets the current log output.

func Start

func Start()

Types

type MGroupProcessor

type MGroupProcessor struct {
	InstanceList    *oracle.InstanceList
	OracleInstances []*oracle.OracleInstance

	InstNames []string
	// contains filtered or unexported fields
}

func InitGroupProcessor

func InitGroupProcessor(cfg *config.OracleMetricGroupConfig, oralist *oracle.InstanceList) *MGroupProcessor

func (*MGroupProcessor) BroadCastInfof

func (mgp *MGroupProcessor) BroadCastInfof(expr string, vars ...interface{})

func (*MGroupProcessor) Debugf

func (mgp *MGroupProcessor) Debugf(i *oracle.OracleInstance, expr string, vars ...interface{})

Debugf info

func (*MGroupProcessor) Errorf

func (mgp *MGroupProcessor) Errorf(i *oracle.OracleInstance, expr string, vars ...interface{})

Errorf info

func (*MGroupProcessor) Infof

func (mgp *MGroupProcessor) Infof(i *oracle.OracleInstance, expr string, vars ...interface{})

Infof info

func (*MGroupProcessor) ProcesQuery

func (mgp *MGroupProcessor) ProcesQuery()

func (*MGroupProcessor) StartCollection

func (mgp *MGroupProcessor) StartCollection(done chan bool, s *sync.WaitGroup)

func (*MGroupProcessor) UpdateInstances

func (mgp *MGroupProcessor) UpdateInstances() int

func (*MGroupProcessor) Warnf

func (mgp *MGroupProcessor) Warnf(i *oracle.OracleInstance, expr string, vars ...interface{})

Warnf log warn data

type RInfo

type RInfo struct {
	InstanceID string
	Version    string
	Commit     string
	Branch     string
	BuildStamp string
}

RInfo contains the agent's release and version information.

func GetRInfo

func GetRInfo() *RInfo

GetRInfo returns the agent release information.