aks

Documentation

Overview

Package aks provides a datagatherer for AKS.

Index

• type AzureCredentials
• type Config
  • func (c *Config) NewDataGatherer(ctx context.Context) (datagatherer.DataGatherer, error)
• type DataGatherer
  • func (g *DataGatherer) Delete() error
  • func (g *DataGatherer) Fetch() (interface{}, error)
  • func (g *DataGatherer) Run(stopCh <-chan struct{}) error
  • func (g *DataGatherer) WaitForCacheSync(stopCh <-chan struct{}) error
• type Info

Types

type AzureCredentials

type AzureCredentials struct {
	AccessToken  string `json:"accessToken"`
	ExpiresOn    string `json:"expiresOn"`
	Subscription string `json:"subscription"`
	Tenant       string `json:"tenant"`
	TokenType    string `json:"tokenType"`
}

AzureCredentials contains credentials needed to authenticate against Azure APIs.

type Config

type Config struct {
	// ClusterName is the name of the cluster in AKS.
	ClusterName string `yaml:"cluster-name"`
	// ResourceGroup is the resource group the cluster belongs to.
	ResourceGroup string `yaml:"resource-group"`
	// CredentialsPath is the path to the json file containing the credentials to access Azure APIs.
	CredentialsPath string `yaml:"credentials-path"`
}

Config is the configuration for an AKS DataGatherer.

func (*Config) NewDataGatherer

func (c *Config) NewDataGatherer(ctx context.Context) (datagatherer.DataGatherer, error)

NewDataGatherer creates a new AKS DataGatherer. It performs a config validation.

type DataGatherer

type DataGatherer struct {
	// contains filtered or unexported fields
}

DataGatherer is a data-gatherer for AKS.

func (*DataGatherer) Delete

func (g *DataGatherer) Delete() error

func (*DataGatherer) Fetch

func (g *DataGatherer) Fetch() (interface{}, error)

Fetch retrieves cluster information from AKS.

func (*DataGatherer) Run

func (g *DataGatherer) Run(stopCh <-chan struct{}) error

func (*DataGatherer) WaitForCacheSync

func (g *DataGatherer) WaitForCacheSync(stopCh <-chan struct{}) error

type Info

type Info struct {
	// Cluster represents an AKS cluster.
	Cluster *aks.ManagedCluster
}

Info contains the data retrieved from AKS.