da

Documentation

Index

• Constants
• func CreateDBClients(config DBConfig) (*sql.DB, error)
• func Monitor(config Config)
• func MustMonitorFromViper()
• type Config
• type DBConfig
• type DaClient
  • func MustNewDaClient(discordId, validatorAddress, ip string) *DaClient
  • func (daClient *DaClient) CheckStatusSilence(config health.TimedCounterConfig, db *sql.DB)
• type DaNode
  • func MustNewDaNode(discordId, validatorAddress, ip string) *DaNode
  • func (daNode *DaNode) CheckStatusSilence(config health.TimedCounterConfig, db *sql.DB)

Constants

const (
	NodeDisconnected string = "DISCONNECTED"
	NodeConnected    string = "CONNECTED"
)

const ValidatorFile = "data/validator_rpcs.csv"

Functions

func CreateDBClients

func CreateDBClients(config DBConfig) (*sql.DB, error)

func Monitor

func Monitor(config Config)

func MustMonitorFromViper

func MustMonitorFromViper()

Types

type Config

type Config struct {
	Interval       time.Duration `default:"10s"`
	DaNodeReport   health.TimedCounterConfig
	DaClientReport health.TimedCounterConfig
	DbConfig       DBConfig
}

type DBConfig

type DBConfig struct {
	Host     string
	Port     string
	Username string
	Password string
	DbName   string
}

type DaClient

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

func MustNewDaClient

func MustNewDaClient(discordId, validatorAddress, ip string) *DaClient

func (*DaClient) CheckStatusSilence

func (daClient *DaClient) CheckStatusSilence(config health.TimedCounterConfig, db *sql.DB)

type DaNode

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

func MustNewDaNode

func MustNewDaNode(discordId, validatorAddress, ip string) *DaNode

func (*DaNode) CheckStatusSilence

func (daNode *DaNode) CheckStatusSilence(config health.TimedCounterConfig, db *sql.DB)