cluster

Apr 1, 2025

Changes in this version

+ const LabelKeyClusterAgentMapping

+ const LabelValueManagerName

+ var ErrAlreadyMapped = errors.New("agent already mapped")

+ var ErrNotMapped = errors.New("agent not mapped")

+ func ClusterToSecret(c *v1alpha1.Cluster, secret *v1.Secret) error

+ type Manager struct

+ func NewManager(ctx context.Context, namespace, redisAddress string, ...) (*Manager, error)

+ func (m *Manager) HasMapping(agent string) bool

+ func (m *Manager) MapCluster(agent string, cluster *v1alpha1.Cluster) error

+ func (m *Manager) Mapping(agent string) *v1alpha1.Cluster

+ func (m *Manager) Start() error

+ func (m *Manager) Stop() error

+ func (m *Manager) UnmapCluster(agent string) error

+ func (m *Manager) UpdateClusterConnectionInfo(agentName, status string, t time.Time)