entities

Documentation

Index

• Variables
• func UnHealthyReasonString(reason UnhealthyReason) string
• type BalanceSourceType
  • func (n BalanceSourceType) IsValid() error
• type BlockSigner
• type BlockSignerRole
  • func (n BlockSignerRole) IsValid() error
• type MetaMonitoringStatusCheck
• type MonitoringServiceType
• type MonitoringStatus
  • func (s MonitoringStatus) UnhealthyReasonString() string
• type NetworkBalance
  • func NewAssetPoolBalance(assetID entities.AssetID, time time.Time, assetHexAddress, chainID string, ...) NetworkBalance
• type Statistics
• type TendermintAddress
  • func (pk *TendermintAddress) Bytes() ([]byte, error)
  • func (pk TendermintAddress) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)
  • func (pk *TendermintAddress) String() string
• type UnhealthyReason

Variables

var AllMonitoringServices = []MonitoringServiceType{
	BlockSignersSvc,
	SegmentsSvc,
	CometTxsSvc,
	NetworkBalancesSvc,
	AssetPricesSvc,
}

Functions

func UnHealthyReasonString

func UnHealthyReasonString(reason UnhealthyReason) string

Types

type BalanceSourceType

type BalanceSourceType string

const (
	AssetPoolBalanceType                  BalanceSourceType = "ASSET_POOL"
	PartiesTotalBalanceType               BalanceSourceType = "PARTIES_TOTAL"
	UnrealisedWithdrawalsTotalBalanceType BalanceSourceType = "UNREALISED_WITHDRAWALS_TOTAL"
)

func (BalanceSourceType) IsValid

func (n BalanceSourceType) IsValid() error

type BlockSigner

type BlockSigner struct {
	VegaTime time.Time                         `db:"vega_time"`
	Role     BlockSignerRole                   `db:"role"`
	TmPubKey vega_entities.TendermintPublicKey `db:"tendermint_pub_key"`
}

type BlockSignerRole

type BlockSignerRole string

const (
	BlockSignerRoleProposer BlockSignerRole = "ROLE_PROPOSER"
	BlockSignerRoleSigner   BlockSignerRole = "ROLE_SIGNER"
)

func (BlockSignerRole) IsValid

func (n BlockSignerRole) IsValid() error

type MetaMonitoringStatusCheck

type MetaMonitoringStatusCheck struct {
	CheckName  string
	IsHealthy  int32
	LastUpdate *time.Time
}

type MonitoringServiceType

type MonitoringServiceType string

const (
	BlockSignersSvc       MonitoringServiceType = "BLOCK_SIGNERS"
	DataNodeSvc           MonitoringServiceType = "DATA_NODE"
	SegmentsSvc           MonitoringServiceType = "SEGMENTS"
	CometTxsSvc           MonitoringServiceType = "COMET_TXS"
	NetworkBalancesSvc    MonitoringServiceType = "NETWORK_BALANCES"
	AssetPricesSvc        MonitoringServiceType = "ASSET_PRICES"
	PromEthereumCallsSvc  MonitoringServiceType = "PROMETHEUS_ETHEREUM_CALLS_SERVICE"
	PromEthNodeScannerSvc MonitoringServiceType = "PROMETHEUS_ETH_NODE_SCANNER"
	PromNodeScannerSvc    MonitoringServiceType = "PROMETHEUS_NODE_SCANNER"
	PromMetamonitoringSvc MonitoringServiceType = "PROMETHEUS_METAMONITORING"
)

type MonitoringStatus

type MonitoringStatus struct {
	StatusTime      time.Time             `db:"status_time"`
	IsHealthy       bool                  `db:"is_healthy"`
	Service         MonitoringServiceType `db:"monitoring_service"`
	UnhealthyReason UnhealthyReason       `db:"unhealthy_reason"`
}

func (MonitoringStatus) UnhealthyReasonString

func (s MonitoringStatus) UnhealthyReasonString() string

type NetworkBalance

type NetworkBalance struct {
	AssetID                 entities.AssetID
	BalanceTime             time.Time
	AssetEthereumHexAddress string
	BalanceSource           BalanceSourceType
	Balance                 decimal.Decimal
	ChainID                 string
}

func NewAssetPoolBalance

func NewAssetPoolBalance(assetID entities.AssetID, time time.Time, assetHexAddress, chainID string, balance decimal.Decimal) NetworkBalance

type Statistics

type Statistics struct {
	BlockHeight    uint64 `json:"blockHeight,string"`
	CurrentTime    string `json:"currentTime"`
	VegaTime       string `json:"vegaTime"`
	ChainId        string `json:"chainId"`
	AppVersion     string `json:"appVersion"`
	AppVersionHash string `json:"appVersionHash"`
}

type TendermintAddress

type TendermintAddress string

func (*TendermintAddress) Bytes

func (pk *TendermintAddress) Bytes() ([]byte, error)

func (TendermintAddress) EncodeBinary

func (pk TendermintAddress) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)

func (*TendermintAddress) String

func (pk *TendermintAddress) String() string

type UnhealthyReason

type UnhealthyReason int

const (
	ReasonUnknown                  UnhealthyReason = 0
	ReasonMissingStatusFromService UnhealthyReason = 1
	ReasonNodeIsNotUpToDate        UnhealthyReason = 2
	ReasonTargetConnectionFailure  UnhealthyReason = 3
	ReasonMissingOrInvalidResponse UnhealthyReason = 8

	ReasonEthereumGetBalancesFailure          UnhealthyReason = 4
	ReasonEthereumContractCallFailure         UnhealthyReason = 5
	ReasonEthereumContractInvalidResponseType UnhealthyReason = 6
	ReasonEthereumContractEventFilterFailure  UnhealthyReason = 7
)