metamonitoring

Documentation

Index

• Constants
• type HealthCheckService
  • func NewHealthCheckService(cfg config.HealthCheckConfig, readService readService, logger *logging.Logger) (*HealthCheckService, error)
  • func (hc *HealthCheckService) Run(ctx context.Context, port int) error
• type MetamonitoringService
  • func NewMonitoringStatusUpdateService(store MonitoringStore, vegaClient VegaClient, logger *logging.Logger) (MetamonitoringService, error)
  • func NewNopService() MetamonitoringService
• type MonitoringStatusPublisher
• type MonitoringStatusUpdateService
  • func (msus *MonitoringStatusUpdateService) AssetPricesStatusPublisher() MonitoringStatusPublisher
  • func (msus *MonitoringStatusUpdateService) BlockSignersStatusPublisher() MonitoringStatusPublisher
  • func (msus *MonitoringStatusUpdateService) CometTxsStatusPublisher() MonitoringStatusPublisher
  • func (msus *MonitoringStatusUpdateService) DataNodeStatusPublisher() 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
• type VegaClient

Constants

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

Types

type HealthCheckService

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

func NewHealthCheckService

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

func (*HealthCheckService) Run

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

type MetamonitoringService

type MetamonitoringService interface {
	DataNodeStatusPublisher() MonitoringStatusPublisher
	BlockSignersStatusPublisher() MonitoringStatusPublisher
	SegmentsStatusPublisher() MonitoringStatusPublisher
	CometTxsStatusPublisher() MonitoringStatusPublisher
	NetworkBalancesStatusPublisher() MonitoringStatusPublisher
	AssetPricesStatusPublisher() MonitoringStatusPublisher
	PrometheusEthereumCalls() MonitoringStatusPublisher
	Run(ctx context.Context, tickInterval time.Duration)
}

func NewMonitoringStatusUpdateService

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

func NewNopService

func NewNopService() MetamonitoringService

type MonitoringStatusPublisher

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

type MonitoringStatusUpdateService

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

func (*MonitoringStatusUpdateService) AssetPricesStatusPublisher

func (msus *MonitoringStatusUpdateService) AssetPricesStatusPublisher() MonitoringStatusPublisher

func (*MonitoringStatusUpdateService) BlockSignersStatusPublisher

func (msus *MonitoringStatusUpdateService) BlockSignersStatusPublisher() MonitoringStatusPublisher

func (*MonitoringStatusUpdateService) CometTxsStatusPublisher

func (msus *MonitoringStatusUpdateService) CometTxsStatusPublisher() MonitoringStatusPublisher

func (*MonitoringStatusUpdateService) DataNodeStatusPublisher

func (msus *MonitoringStatusUpdateService) DataNodeStatusPublisher() MonitoringStatusPublisher

func (*MonitoringStatusUpdateService) NetworkBalancesStatusPublisher

func (msus *MonitoringStatusUpdateService) NetworkBalancesStatusPublisher() MonitoringStatusPublisher

func (*MonitoringStatusUpdateService) PrometheusEthereumCalls

func (msus *MonitoringStatusUpdateService) PrometheusEthereumCalls() MonitoringStatusPublisher

func (*MonitoringStatusUpdateService) Run

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

func (*MonitoringStatusUpdateService) SegmentsStatusPublisher

func (msus *MonitoringStatusUpdateService) SegmentsStatusPublisher() MonitoringStatusPublisher

type MonitoringStore

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

type VegaClient

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