metamonitoring

package

v0.11.1-preview.1 Latest Latest Go to latest Published: Mar 6, 2024 License: MIT Imports: 16 Imported by: 0

Details

View Source

const (
	BlockDiffHealthyThreshold = 900
	TimeDiffHealthyThreshold  = 10 * time.Minute
)

This section is empty.

This section is empty.

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

func NewHealthCheckService(cfg config.HealthCheckConfig, readService readService, logger *logging.Logger) (*HealthCheckService, error)

func (hc *HealthCheckService) Run(ctx context.Context, port int) error

type MonitoringStatusPublisher interface {
	Publish(isHealthy bool) error
	PublishWithReason(isHealthy bool, reason entities.UnhealthyReason) error
}

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

func NewMonitoringStatusUpdateService(store MonitoringStore, vegaClient VegaClient, logger *logging.Logger) (*MonitoringStatusUpdateService, error)

func (msus *MonitoringStatusUpdateService) AssetPricesStatusPublisher() MonitoringStatusPublisher

func (msus *MonitoringStatusUpdateService) BlockSignersStatusPublisher() MonitoringStatusPublisher

func (msus *MonitoringStatusUpdateService) CometTxsStatusPublisher() MonitoringStatusPublisher

func (msus *MonitoringStatusUpdateService) NetworkBalancesStatusPublisher() MonitoringStatusPublisher

func (msus *MonitoringStatusUpdateService) PrometheusEthereumCalls() MonitoringStatusPublisher

func (msus *MonitoringStatusUpdateService) Run(ctx context.Context, tickInterval time.Duration)

func (msus *MonitoringStatusUpdateService) SegmentsStatusPublisher() MonitoringStatusPublisher

type MonitoringStore interface {
	NewMonitoringStatus() *sqlstore.MonitoringStatus
	NewBlocks() *sqlstore.Blocks
}

type VegaClient interface {
	GetStatistics() (*vegaclient.Statistics, error)
}