Documentation
¶
Index ¶
- type Client
- func (c *Client) GetCPUStats(since time.Duration) (float64, error)
- func (c *Client) GetDataSize() (int64, error)
- func (c *Client) GetLatestHeight() (int64, error)
- func (c *Client) GetMemoryStats(since time.Duration) (uint64, error)
- func (c *Client) ListSnapshots() ([]int64, error)
- func (c *Client) RequiresUpgrade() (bool, error)
- func (c *Client) ShutdownNodeUtilsServer() error
- type NodeUtils
- type Option
- func CreateFifo(create bool) Option
- func WithBlockThreshold(n time.Duration) Option
- func WithDataPath(path string) Option
- func WithHaltHeight(height int64) Option
- func WithHost(s string) Option
- func WithPort(v int) Option
- func WithTmkmsProxy(enable bool) Option
- func WithTraceStore(path string) Option
- func WithUpgradesConfig(path string) Option
- type Options
- type ProcessStats
- type Upgrade
- type UpgradeChecker
- type UpgradeSource
- type UpgradesConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) GetCPUStats ¶ added in v1.44.0
func (*Client) GetDataSize ¶
func (*Client) GetLatestHeight ¶
func (*Client) GetMemoryStats ¶ added in v1.44.0
func (*Client) ListSnapshots ¶
func (*Client) RequiresUpgrade ¶
func (*Client) ShutdownNodeUtilsServer ¶
type Option ¶
type Option func(*Options)
func CreateFifo ¶
func WithBlockThreshold ¶
func WithDataPath ¶
func WithHaltHeight ¶ added in v1.40.0
func WithTmkmsProxy ¶
func WithTraceStore ¶
func WithUpgradesConfig ¶
type ProcessStats ¶ added in v1.44.0
type ProcessStats struct {
CPUTimeSec float64 `json:"cpu_time_sec"` // total CPU time in seconds
MemoryRSS uint64 `json:"memory_rss_bytes"` // resident memory usage
}
func GetProcessStats ¶ added in v1.44.0
func GetProcessStats(proc *process.Process) (*ProcessStats, error)
GetProcessStats extracts CPU + memory usage from a gopsutil Process
type Upgrade ¶
type Upgrade struct {
Height int64 `json:"height"`
Status string `json:"status"`
Image string `json:"image"`
Source UpgradeSource `json:"source"`
}
type UpgradeChecker ¶
type UpgradeChecker struct {
// contains filtered or unexported fields
}
func NewUpgradeChecker ¶
func NewUpgradeChecker(configFile string) (*UpgradeChecker, error)
func (*UpgradeChecker) GetUpgrade ¶
func (u *UpgradeChecker) GetUpgrade(height int64) (*Upgrade, error)
func (*UpgradeChecker) ShouldUpgrade ¶
func (u *UpgradeChecker) ShouldUpgrade(height int64) bool
func (*UpgradeChecker) WatchConfigFile ¶
func (u *UpgradeChecker) WatchConfigFile() error
type UpgradeSource ¶
type UpgradeSource string
const ( UpgradeScheduled = "scheduled" ManualUpgrade UpgradeSource = "manual" OnChainUpgrade UpgradeSource = "on-chain" )
type UpgradesConfig ¶
type UpgradesConfig struct {
Upgrades []Upgrade `json:"upgrades"`
}
Click to show internal directories.
Click to hide internal directories.