metamonitoring

Documentation

Index

• Constants
• type MonitoringStatusPublisher
• type MonitoringStatusUpdateService
  • 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) 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 MonitoringStatusPublisher

type MonitoringStatusPublisher interface {
	Publish(isHealthy bool) error
}

type MonitoringStatusUpdateService

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

func NewMonitoringStatusUpdateService

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

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) NetworkBalancesStatusPublisher

func (msus *MonitoringStatusUpdateService) NetworkBalancesStatusPublisher() 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)
}