Documentation ¶
Index ¶
- type GenesisKubernetes
- func (g *GenesisKubernetes) GetKubernetesData(orgID int, clusterID string) (common.KubernetesInfo, bool)
- func (g *GenesisKubernetes) GetKubernetesResponse(orgID int, clusterID string, serverIPs []string) (map[string][]string, error)
- func (g *GenesisKubernetes) GetStatter() statsd.StatsdStatter
- func (g *GenesisKubernetes) Start()
- func (s *GenesisKubernetes) Stop()
- type KubernetesStorage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GenesisKubernetes ¶
type GenesisKubernetes struct {
// contains filtered or unexported fields
}
func NewGenesisKubernetes ¶
func NewGenesisKubernetes(ctx context.Context, queue queue.QueueReader, config *config.ControllerConfig) *GenesisKubernetes
func (*GenesisKubernetes) GetKubernetesData ¶
func (g *GenesisKubernetes) GetKubernetesData(orgID int, clusterID string) (common.KubernetesInfo, bool)
func (*GenesisKubernetes) GetKubernetesResponse ¶
func (*GenesisKubernetes) GetStatter ¶
func (g *GenesisKubernetes) GetStatter() statsd.StatsdStatter
func (*GenesisKubernetes) Start ¶
func (g *GenesisKubernetes) Start()
func (*GenesisKubernetes) Stop ¶
func (s *GenesisKubernetes) Stop()
type KubernetesStorage ¶
type KubernetesStorage struct {
// contains filtered or unexported fields
}
func NewKubernetesStorage ¶
func NewKubernetesStorage(ctx context.Context, port, nPort int, cfg config.GenesisConfig, kChan chan common.KubernetesInfo) *KubernetesStorage
func (*KubernetesStorage) Add ¶
func (k *KubernetesStorage) Add(orgID int, newInfo common.KubernetesInfo)
func (*KubernetesStorage) Clear ¶
func (k *KubernetesStorage) Clear()
func (*KubernetesStorage) Start ¶
func (k *KubernetesStorage) Start()
func (*KubernetesStorage) Stop ¶
func (k *KubernetesStorage) Stop()
Click to show internal directories.
Click to hide internal directories.