controllers

package

v1.58.0 Latest Latest Go to latest Published: Nov 26, 2025 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/NibiruChain/cosmopilot

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func FormatErrorEvent(context string, err error) string
func FormatEventMessage(format string, args ...interface{}) string
func SummarizeError(err error) string
type ControllerRunOptions

Constants ¶

View Source

const (
	CosmoGuardRpcPortName      = "fw-rpc"
	CosmoGuardRpcPort          = 16657
	CosmoGuardLcdPortName      = "fw-lcd"
	CosmoGuardLcdPort          = 11317
	CosmoGuardGrpcPortName     = "fw-grpc"
	CosmoGuardGrpcPort         = 19090
	CosmoGuardMetricsPortName  = "fw-metrics"
	CosmoGuardMetricsPort      = 9001
	CosmoGuardEvmRpcPortName   = "fw-evm-rpc"
	CosmoGuardEvmRpcPort       = 18545
	CosmoGuardEvmRpcWsPortName = "fw-evm-rpc-ws"
	CosmoGuardEvmRpcWsPort     = 18546

	NonRootId = 1000

	CosmoseedName = "cosmoseed"

	AnnotationStateSyncTrustHeight    = "apps.k8s.nibiru.org/state-sync-trust-height"
	AnnotationStateSyncTrustHash      = "apps.k8s.nibiru.org/state-sync-trust-hash"
	AnnotationDataHeight              = "apps.k8s.nibiru.org/data-height"
	AnnotationSafeEvict               = "cluster-autoscaler.kubernetes.io/safe-to-evict"
	AnnotationConfigHash              = "apps.k8s.nibiru.org/config-hash"
	AnnotationDataInitialized         = "apps.k8s.nibiru.org/data-initialized"
	AnnotationGenesisDownloaded       = "apps.k8s.nibiru.org/genesis-downloaded"
	AnnotationVaultKeyUploaded        = "apps.k8s.nibiru.org/vault-key-uploaded"
	AnnotationPvcSnapshotInProgress   = "apps.k8s.nibiru.org/snapshotting-pvc"
	AnnotationLastPvcSnapshot         = "apps.k8s.nibiru.org/last-pvc-snapshot"
	AnnotationSnapshotRetention       = "apps.k8s.nibiru.org/snapshot-retention"
	AnnotationPvcSnapshotReady        = "apps.k8s.nibiru.org/snapshot-ready"
	AnnotationExportingTarball        = "apps.k8s.nibiru.org/exporting-tarball"
	AnnotationSnapshotIntegrityStatus = "apps.k8s.nibiru.org/snapshot-integrity-status"
	AnnotationPodSpecHash             = "apps.k8s.nibiru.org/pod-spec-hash"
	AnnotationVPAResources            = "apps.k8s.nibiru.org/vpa-resources"
	AnnotationVPALastCPUScale         = "apps.k8s.nibiru.org/last-cpu-scale"
	AnnotationVPALastMemoryScale      = "apps.k8s.nibiru.org/last-memory-scale"
	AnnotationStatefulSetPodName      = "statefulset.kubernetes.io/pod-name"

	LabelNodeID                = "node-id"
	LabelChainID               = "chain-id"
	LabelValidator             = "validator"
	LabelChainNode             = "chain-node"
	LabelChainNodeSet          = "nodeset"
	LabelChainNodeSetGroup     = "group"
	LabelChainNodeSetValidator = "validator"
	LabelGlobalIngress         = "global-ingress"
	LabelScope                 = "scope"
	LabelApp                   = "app"
	LabelSeed                  = "seed"
	LabelPeer                  = "peer"
	LabelUpgrading             = "upgrading"

	StringValueTrue  = "true"
	StringValueFalse = "false"

	EvmRpcPortName   = "evm-rpc"
	EvmRpcPort       = 8545
	EvmRpcWsPortName = "evm-rpc-ws"
	EvmRpcWsPort     = 8546

	AppTomlFile         = "app.toml"
	MinimumGasPricesKey = "minimum-gas-prices"
)

View Source

const (
	LabelWorkerName = "worker-name"
)

Variables ¶

This section is empty.

Functions ¶

func FormatErrorEvent ¶ added in v1.56.0

func FormatErrorEvent(context string, err error) string

FormatErrorEvent creates a clean event message from an error. It extracts the root cause and avoids including verbose error chains.

func FormatEventMessage ¶ added in v1.56.0

func FormatEventMessage(format string, args ...interface{}) string

FormatEventMessage creates a clean, concise event message suitable for Kubernetes events. It sanitizes error messages by: - Limiting total length to avoid cluttering kubectl describe output - Removing newlines and excessive whitespace - Extracting the core error message without stack traces

func SummarizeError ¶ added in v1.56.0

func SummarizeError(err error) string

SummarizeError returns a short, human-readable error summary. This is used when we want just the error type/category, not the full message.

Types ¶

type ControllerRunOptions ¶

type ControllerRunOptions struct {
	WorkerCount              int
	WorkerName               string
	NodeUtilsImage           string
	DisableWebhooks          bool
	CosmoGuardImage          string
	CosmoseedImage           string
	ReleaseName              string
	DisruptionCheckEnabled   bool
	DisruptionMaxUnavailable int
}

func (*ControllerRunOptions) GetDefaultPriorityClassName ¶

func (opts *ControllerRunOptions) GetDefaultPriorityClassName() string

func (*ControllerRunOptions) GetNodesPriorityClassName ¶

func (opts *ControllerRunOptions) GetNodesPriorityClassName() string

func (*ControllerRunOptions) GetValidatorsPriorityClassName ¶

func (opts *ControllerRunOptions) GetValidatorsPriorityClassName() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
chainnode
chainnodeset

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL