metrics

Documentation

Index

• func GetJobManagerStatus(jobManagerHost, jobManagerPort string) float64
• func GetOutboundIP() string
• func GetTotalMemory() float64
• type AvsAndEigenMetrics
  • func NewAvsAndEigenMetrics(avsName string, eigenMetrics *metrics.EigenMetrics, reg prometheus.Registerer) *AvsAndEigenMetrics
  • func (m *AvsAndEigenMetrics) IncNumTaskFailed()
  • func (m *AvsAndEigenMetrics) IncNumTaskReceived()
  • func (m *AvsAndEigenMetrics) IncNumTaskSucceed()
  • func (m *AvsAndEigenMetrics) SetTaskExecutionTime(executionTime float64)
  • func (m *AvsAndEigenMetrics) UpdateNodeMetrics(operatorAddress, jobName, jobManagerHost, jobManagerPort string) (string, float64)
• type Metrics
• type NoopMetrics
  • func NewNoopMetrics() *NoopMetrics
  • func (m *NoopMetrics) IncNumTasksReceived()
  • func (m *NoopMetrics) IncNumTasksSuccess()

Functions

func GetJobManagerStatus

func GetJobManagerStatus(jobManagerHost, jobManagerPort string) float64

func GetOutboundIP

func GetOutboundIP() string

func GetTotalMemory

func GetTotalMemory() float64

Types

type AvsAndEigenMetrics

type AvsAndEigenMetrics struct {
	metrics.Metrics
	// contains filtered or unexported fields
}

AvsAndEigenMetrics contains instrumented metrics that should be incremented by the avs node using the methods below

func NewAvsAndEigenMetrics

func NewAvsAndEigenMetrics(avsName string, eigenMetrics *metrics.EigenMetrics, reg prometheus.Registerer) *AvsAndEigenMetrics

func (*AvsAndEigenMetrics) IncNumTaskFailed

func (m *AvsAndEigenMetrics) IncNumTaskFailed()

func (*AvsAndEigenMetrics) IncNumTaskReceived

func (m *AvsAndEigenMetrics) IncNumTaskReceived()

func (*AvsAndEigenMetrics) IncNumTaskSucceed

func (m *AvsAndEigenMetrics) IncNumTaskSucceed()

func (*AvsAndEigenMetrics) SetTaskExecutionTime

func (m *AvsAndEigenMetrics) SetTaskExecutionTime(executionTime float64)

func (*AvsAndEigenMetrics) UpdateNodeMetrics

func (m *AvsAndEigenMetrics) UpdateNodeMetrics(operatorAddress, jobName, jobManagerHost, jobManagerPort string) (string, float64)

type Metrics

type Metrics interface {
	metrics.Metrics
	IncNumTaskReceived()
	IncNumTaskSucceed()
	IncNumTaskFailed()
	SetTaskExecutionTime(executionTime float64)
	UpdateNodeMetrics(operatorAddress, jobName, jobManagerHost, jobManagerPort string) (string, float64)
}

type NoopMetrics

type NoopMetrics struct {
	eigenmetrics.NoopMetrics
}

func NewNoopMetrics

func NewNoopMetrics() *NoopMetrics

func (*NoopMetrics) IncNumTasksReceived

func (m *NoopMetrics) IncNumTasksReceived()

func (*NoopMetrics) IncNumTasksSuccess

func (m *NoopMetrics) IncNumTasksSuccess()