fullnode

Nov 7, 2023

Changes in this version

+ type NodeKey struct

+ PrivKey NodeKeyPrivKey

+ func (nk NodeKey) ID() string

+ type NodeKeyPrivKey struct

+ Type string

+ Value ed25519.PrivateKey

Oct 27, 2023

Changes in this version

+ func BuildRoleBindings(crd *cosmosv1.CosmosFullNode) []diff.Resource[*rbacv1.RoleBinding]

+ func BuildRoles(crd *cosmosv1.CosmosFullNode) []diff.Resource[*rbacv1.Role]

+ func BuildServiceAccounts(crd *cosmosv1.CosmosFullNode) []diff.Resource[*corev1.ServiceAccount]

+ type CacheInvalidator interface

+ Invalidate func(controller client.ObjectKey, pods []string)

+ type PVCStatusChanges struct

+ Deleted []string

+ type RoleBindingControl struct

+ func NewRoleBindingControl(client Client) RoleBindingControl

+ func (sc RoleBindingControl) Reconcile(ctx context.Context, log kube.Logger, crd *cosmosv1.CosmosFullNode) kube.ReconcileError

+ type RoleControl struct

+ func NewRoleControl(client Client) RoleControl

+ func (sc RoleControl) Reconcile(ctx context.Context, log kube.Logger, crd *cosmosv1.CosmosFullNode) kube.ReconcileError

+ type ServiceAccountControl struct

+ func NewServiceAccountControl(client Client) ServiceAccountControl

+ func (sc ServiceAccountControl) Reconcile(ctx context.Context, log kube.Logger, crd *cosmosv1.CosmosFullNode) kube.ReconcileError

Oct 16, 2023

Changes in this version

+ func DownloadAddrbookCommand(cfg cosmosv1.ChainSpec) (string, []string)

Jul 7, 2023

Changes in this version

+ func SyncInfoStatus(ctx context.Context, crd *cosmosv1.CosmosFullNode, collector StatusCollector) cosmosv1.SyncInfoStatus

+ type DriftDetection struct

+ func NewDriftDetection(collector StatusCollector) DriftDetection

+ func (d DriftDetection) LaggingPods(ctx context.Context, crd *cosmosv1.CosmosFullNode) []*corev1.Pod

+ type StatusCollector interface

+ Collect func(ctx context.Context, controller client.ObjectKey) cosmos.StatusCollection

Apr 24, 2023

Changes in this version

+ type Getter interface

+ Get func(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error

+ type Peer struct

+ ExternalAddress string

+ NodeID p2p.ID

+ PrivateAddress string

+ func (peer Peer) ExternalPeer() string

+ func (peer Peer) PrivatePeer() string

type PeerCollector

+ func (c PeerCollector) Collect(ctx context.Context, crd *cosmosv1.CosmosFullNode) (Peers, kube.ReconcileError)

+ type Peers map[client.ObjectKey]Peer

+ func (peers Peers) AllExternal() []string

+ func (peers Peers) AllPrivate() []string

+ func (peers Peers) Default() Peers

+ func (peers Peers) Except(name, namespace string) Peers

+ func (peers Peers) Get(name, namespace string) Peer

+ func (peers Peers) HasIncompleteExternalAddress() bool

+ func (peers Peers) NodeIDs() []string

Apr 12, 2023

Changes in this version

+ func BuildNodeKeySecrets(existing []*corev1.Secret, crd *cosmosv1.CosmosFullNode) ([]diff.Resource[*corev1.Secret], error)

+ type ConfigChecksums map[client.ObjectKey]string

+ type NodeKeyControl struct

+ func NewNodeKeyControl(client Client) NodeKeyControl

+ func (control NodeKeyControl) Reconcile(ctx context.Context, reporter kube.Reporter, crd *cosmosv1.CosmosFullNode) kube.ReconcileError

+ type PeerCollector struct

+ func NewPeerCollector(client Lister, tmClient cosmos.TendermintStatuser) *PeerCollector

+ func (collector PeerCollector) CollectAddresses(ctx context.Context, crd *cosmosv1.CosmosFullNode) ([]string, error)

Mar 15, 2023

Changes in this version

+ type DiskUsageCollector struct

+ func NewDiskUsageCollector(diskClient DiskUsager, lister Reader) *DiskUsageCollector

+ func (c DiskUsageCollector) CollectDiskUsage(ctx context.Context, crd *cosmosv1.CosmosFullNode) ([]PVCDiskUsage, error)

+ type DiskUsager interface

+ DiskUsage func(ctx context.Context, host string) (healthcheck.DiskUsageResponse, error)

+ type PVCAutoScaler struct

+ func NewPVCAutoScaler(client StatusSyncer) *PVCAutoScaler

+ func (scaler PVCAutoScaler) SignalPVCResize(ctx context.Context, crd *cosmosv1.CosmosFullNode, results []PVCDiskUsage) (bool, error)

+ type PVCDiskUsage struct

+ Capacity resource.Quantity

+ Name string

+ PercentUsed int

+ type Reader = client.Reader

+ type StatusClient struct

+ func NewStatusClient(c client.Client) *StatusClient

+ func (client *StatusClient) SyncUpdate(ctx context.Context, key client.ObjectKey, ...) error

+ type StatusPatcher interface

+ Patch func(ctx context.Context, obj client.Object, patch client.Patch, ...) error

+ type StatusSyncer interface

+ SyncUpdate func(ctx context.Context, key client.ObjectKey, ...) error

Feb 26, 2023

Changes in this version

+ const ChainHomeDir

Feb 15, 2023

Changes in this version

+ type PodFilter interface

+ SyncedPods func(ctx context.Context, log logr.Logger, candidates []*corev1.Pod) []*corev1.Pod

Feb 8, 2023

Changes in this version

+ func BuildConfigMaps(crd *cosmosv1.CosmosFullNode, p2p ExternalAddresses) ([]*corev1.ConfigMap, error)

+ func BuildPVCs(crd *cosmosv1.CosmosFullNode) []*corev1.PersistentVolumeClaim

+ func BuildPods(crd *cosmosv1.CosmosFullNode) []*corev1.Pod

+ func BuildServices(crd *cosmosv1.CosmosFullNode) []*corev1.Service

+ func DownloadGenesisCommand(cfg cosmosv1.ChainSpec) (string, []string)

+ func DownloadSnapshotCommand(cfg cosmosv1.ChainSpec) (string, []string)

+ func PVCName(pod *corev1.Pod) string

+ func ResetStatus(crd *cosmosv1.CosmosFullNode)

+ func SelectorLabels(crd *cosmosv1.CosmosFullNode) client.MatchingLabels

+ type Client interface

+ Scheme func() *runtime.Scheme

+ type ConfigMapControl struct

+ func NewConfigMapControl(client Client) ConfigMapControl

+ func (cmc ConfigMapControl) Reconcile(ctx context.Context, log logr.Logger, crd *cosmosv1.CosmosFullNode, ...) kube.ReconcileError

+ type ExternalAddresses map[string]string

+ func CollectP2PAddresses(ctx context.Context, crd *cosmosv1.CosmosFullNode, c Lister) (ExternalAddresses, kube.ReconcileError)

+ func (addrs ExternalAddresses) Incomplete() bool

+ type Lister interface

+ List func(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

+ type PVCControl struct

+ func NewPVCControl(client Client) PVCControl

+ func (vc PVCControl) Reconcile(ctx context.Context, log logr.Logger, crd *cosmosv1.CosmosFullNode) (bool, kube.ReconcileError)

+ type PodBuilder struct

+ func NewPodBuilder(crd *cosmosv1.CosmosFullNode) PodBuilder

+ func (b PodBuilder) Build() *corev1.Pod

+ func (b PodBuilder) WithOrdinal(ordinal int32) PodBuilder

+ type PodControl struct

+ func NewPodControl(client Client) PodControl

+ func (pc PodControl) Reconcile(ctx context.Context, log logr.Logger, crd *cosmosv1.CosmosFullNode) (bool, kube.ReconcileError)

+ type ServiceControl struct

+ func NewServiceControl(client Client) ServiceControl

+ func (sc ServiceControl) Reconcile(ctx context.Context, log logr.Logger, crd *cosmosv1.CosmosFullNode) kube.ReconcileError