kubernetes

Documentation

Index

• type GenesisKubernetes
  • func NewGenesisKubernetes(ctx context.Context, queue queue.QueueReader, config *config.ControllerConfig) *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
  • func NewKubernetesStorage(ctx context.Context, port, nPort int, cfg config.GenesisConfig, ...) *KubernetesStorage
  • func (k *KubernetesStorage) Add(orgID int, newInfo common.KubernetesInfo)
  • func (k *KubernetesStorage) Clear()
  • func (k *KubernetesStorage) Start()
  • func (k *KubernetesStorage) Stop()

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 (g *GenesisKubernetes) GetKubernetesResponse(orgID int, clusterID string, serverIPs []string) (map[string][]string, error)

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()