Documentation
¶
Index ¶
- Constants
- type AWSLogrusBridgeLogger
- type AkamaiStore
- func (s *AkamaiStore) GetContextPrefix(path string) string
- func (s *AkamaiStore) GetID() string
- func (s *AkamaiStore) GetKind() types.StoreKind
- func (s *AkamaiStore) GetKubeconfigForPath(path string, tags map[string]string) ([]byte, error)
- func (s *AkamaiStore) GetLogger() *logrus.Entry
- func (s *AkamaiStore) GetStoreConfig() types.KubeconfigStore
- func (s *AkamaiStore) InitializeAkamaiStore() error
- func (s *AkamaiStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *AkamaiStore) VerifyKubeconfigPaths() error
- type AzureStore
- func (s *AzureStore) GetContextPrefix(path string) string
- func (s *AzureStore) GetID() string
- func (s *AzureStore) GetKind() types.StoreKind
- func (s *AzureStore) GetKubeconfigForPath(path string, tags map[string]string) ([]byte, error)
- func (s *AzureStore) GetLogger() *logrus.Entry
- func (s *AzureStore) GetSearchPreview(path string, _ map[string]string) (string, error)
- func (s *AzureStore) GetStoreConfig() types.KubeconfigStore
- func (s *AzureStore) InitializeAzureStore() error
- func (s *AzureStore) IsInitialized() bool
- func (s *AzureStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *AzureStore) VerifyKubeconfigPaths() error
- type CapiStore
- func (s *CapiStore) GetContextPrefix(path string) string
- func (s *CapiStore) GetID() string
- func (s *CapiStore) GetKind() types.StoreKind
- func (s *CapiStore) GetKubeconfigForPath(path string, tags map[string]string) ([]byte, error)
- func (s *CapiStore) GetLogger() *logrus.Entry
- func (s *CapiStore) GetStoreConfig() types.KubeconfigStore
- func (s *CapiStore) InitializeCapiStore() error
- func (s *CapiStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *CapiStore) VerifyKubeconfigPaths() error
- type DigitalOceanStore
- func (s *DigitalOceanStore) GetContextPrefix(path string) string
- func (s *DigitalOceanStore) GetID() string
- func (s *DigitalOceanStore) GetKind() types.StoreKind
- func (d *DigitalOceanStore) GetKubeconfigForPath(path string, tags map[string]string) ([]byte, error)
- func (s *DigitalOceanStore) GetLogger() *logrus.Entry
- func (d *DigitalOceanStore) GetSearchPreview(_ string, tags map[string]string) (string, error)
- func (s *DigitalOceanStore) GetStoreConfig() types.KubeconfigStore
- func (d *DigitalOceanStore) InitializeDigitalOceanStore() error
- func (s *DigitalOceanStore) IsInitialized() bool
- func (d *DigitalOceanStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *DigitalOceanStore) VerifyKubeconfigPaths() error
- type EKSStore
- func (s *EKSStore) GetContextPrefix(path string) string
- func (s *EKSStore) GetID() string
- func (s *EKSStore) GetKind() types.StoreKind
- func (s *EKSStore) GetKubeconfigForPath(path string, _ map[string]string) ([]byte, error)
- func (s *EKSStore) GetLogger() *logrus.Entry
- func (s *EKSStore) GetSearchPreview(path string, optionalTags map[string]string) (string, error)
- func (s *EKSStore) GetStoreConfig() types.KubeconfigStore
- func (s *EKSStore) InitializeEKSStore() error
- func (s *EKSStore) IsInitialized() bool
- func (s *EKSStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *EKSStore) VerifyKubeconfigPaths() error
- type FilesystemStore
- func (s *FilesystemStore) GetContextPrefix(path string) string
- func (s *FilesystemStore) GetID() string
- func (s *FilesystemStore) GetKind() types.StoreKind
- func (s *FilesystemStore) GetKubeconfigForPath(path string, _ map[string]string) ([]byte, error)
- func (s *FilesystemStore) GetLogger() *logrus.Entry
- func (s *FilesystemStore) GetStoreConfig() types.KubeconfigStore
- func (s *FilesystemStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *FilesystemStore) VerifyKubeconfigPaths() error
- type GKEStore
- func (s *GKEStore) GetContextPrefix(path string) string
- func (s *GKEStore) GetID() string
- func (s *GKEStore) GetKind() types.StoreKind
- func (s *GKEStore) GetKubeconfigForPath(path string, _ map[string]string) ([]byte, error)
- func (s *GKEStore) GetLogger() *logrus.Entry
- func (s *GKEStore) GetStoreConfig() types.KubeconfigStore
- func (s *GKEStore) InitializeGKEStore() error
- func (s *GKEStore) IsInitialized() bool
- func (s *GKEStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *GKEStore) VerifyKubeconfigPaths() error
- type GardenConfig
- type GardenerStore
- func (s *GardenerStore) GetContextPrefix(path string) string
- func (s *GardenerStore) GetControlplaneKubeconfigForShoot(shootName, project string) ([]byte, *string, error)
- func (s *GardenerStore) GetID() string
- func (s *GardenerStore) GetKind() types.StoreKind
- func (s *GardenerStore) GetKubeconfigForPath(path string, _ map[string]string) ([]byte, error)
- func (s *GardenerStore) GetLogger() *logrus.Entry
- func (s *GardenerStore) GetSearchPreview(path string, optionalTags map[string]string) (string, error)
- func (s *GardenerStore) GetStoreConfig() types.KubeconfigStore
- func (s *GardenerStore) InitializeGardenerStore() error
- func (s *GardenerStore) IsInitialized() bool
- func (s *GardenerStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *GardenerStore) VerifyKubeconfigPaths() error
- type GardenloginConfig
- type OVHKube
- type OVHStore
- func (r *OVHStore) GetContextPrefix(path string) string
- func (r *OVHStore) GetID() string
- func (r *OVHStore) GetKind() types.StoreKind
- func (r *OVHStore) GetKubeconfigForPath(path string, _ map[string]string) ([]byte, error)
- func (r *OVHStore) GetLogger() *logrus.Entry
- func (r *OVHStore) GetStoreConfig() types.KubeconfigStore
- func (r *OVHStore) StartSearch(channel chan storetypes.SearchResult)
- func (r *OVHStore) VerifyKubeconfigPaths() error
- type PluginStore
- func (s *PluginStore) GetContextPrefix(path string) string
- func (s *PluginStore) GetID() string
- func (s *PluginStore) GetKind() types.StoreKind
- func (s *PluginStore) GetKubeconfigForPath(path string, tags map[string]string) ([]byte, error)
- func (s *PluginStore) GetLogger() *logrus.Entry
- func (s *PluginStore) GetStoreConfig() types.KubeconfigStore
- func (s *PluginStore) InitializePluginStore() error
- func (s *PluginStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *PluginStore) VerifyKubeconfigPaths() error
- type RancherStore
- func (r *RancherStore) GetContextPrefix(path string) string
- func (r *RancherStore) GetID() string
- func (r *RancherStore) GetKind() types.StoreKind
- func (r *RancherStore) GetKubeconfigForPath(path string, _ map[string]string) ([]byte, error)
- func (r *RancherStore) GetLogger() *logrus.Entry
- func (r *RancherStore) GetStoreConfig() types.KubeconfigStore
- func (r *RancherStore) StartSearch(channel chan storetypes.SearchResult)
- func (r *RancherStore) VerifyKubeconfigPaths() error
- type ScalewayKube
- type ScalewayStore
- func (s *ScalewayStore) GetContextPrefix(path string) string
- func (s *ScalewayStore) GetID() string
- func (r *ScalewayStore) GetKind() types.StoreKind
- func (s *ScalewayStore) GetKubeconfigForPath(path string, _ map[string]string) ([]byte, error)
- func (s *ScalewayStore) GetLogger() *logrus.Entry
- func (s *ScalewayStore) GetStoreConfig() types.KubeconfigStore
- func (s *ScalewayStore) StartSearch(channel chan storetypes.SearchResult)
- func (r *ScalewayStore) VerifyKubeconfigPaths() error
- type VaultStore
- func (s *VaultStore) GetContextPrefix(path string) string
- func (s *VaultStore) GetID() string
- func (s *VaultStore) GetKind() types.StoreKind
- func (s *VaultStore) GetKubeconfigForPath(path string, _ map[string]string) ([]byte, error)
- func (s *VaultStore) GetLogger() *logrus.Entry
- func (s *VaultStore) GetStoreConfig() types.KubeconfigStore
- func (s *VaultStore) StartSearch(channel chan storetypes.SearchResult)
- func (s *VaultStore) VerifyKubeconfigPaths() error
Constants ¶
const ( // CmNameClusterIdentity is the config map name that contains the gardener cluster identity CmNameClusterIdentity = "cluster-identity" // KeyClusterIdentity is the key in the cluster identity config map KeyClusterIdentity = CmNameClusterIdentity // AllNamespacesDenominator is a character that indicates that all Shoot clusters should be considered for the search AllNamespacesDenominator = "/" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AWSLogrusBridgeLogger ¶
AWSLogrusBridgeLogger is a Logger implementation that wraps the standard library logger, and delegates logging to it's Printf method.
func (AWSLogrusBridgeLogger) Logf ¶
func (s AWSLogrusBridgeLogger) Logf(classification logging.Classification, format string, v ...interface{})
Logf logs the given classification and message to the underlying logger.
type AkamaiStore ¶
type AkamaiStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore Client *linodego.Client Config *types.StoreConfigAkamai }
func NewAkamaiStore ¶
func NewAkamaiStore(store types.KubeconfigStore) (*AkamaiStore, error)
func (*AkamaiStore) GetContextPrefix ¶
func (s *AkamaiStore) GetContextPrefix(path string) string
func (*AkamaiStore) GetKind ¶
func (s *AkamaiStore) GetKind() types.StoreKind
func (*AkamaiStore) GetKubeconfigForPath ¶
func (*AkamaiStore) GetLogger ¶
func (s *AkamaiStore) GetLogger() *logrus.Entry
func (*AkamaiStore) GetStoreConfig ¶
func (s *AkamaiStore) GetStoreConfig() types.KubeconfigStore
func (*AkamaiStore) InitializeAkamaiStore ¶
func (s *AkamaiStore) InitializeAkamaiStore() error
InitializeAkamaiStore the Akamai client
func (*AkamaiStore) StartSearch ¶
func (s *AkamaiStore) StartSearch(channel chan storetypes.SearchResult)
func (*AkamaiStore) VerifyKubeconfigPaths ¶
func (s *AkamaiStore) VerifyKubeconfigPaths() error
type AzureStore ¶
type AzureStore struct { Logger *logrus.Entry // DiscoveredClustersMutex is a mutex allow many reads, one write mutex to synchronize writes // to the DiscoveredClusters map. // This can happen when a goroutine still discovers clusters while another goroutine computes the preview for a missing cluster. DiscoveredClustersMutex sync.RWMutex KubeconfigStore types.KubeconfigStore AksClient *armcontainerservice.ManagedClustersClient Config *types.StoreConfigAzure // DiscoveredClusters maps the kubeconfig path (az_<resource-group>--<cluster-name>) -> cluster // This is a cache for the clusters discovered during the initial search for kubeconfig paths // when not using a search index DiscoveredClusters map[string]*armcontainerservice.ManagedCluster StateDirectory string }
func NewAzureStore ¶
func NewAzureStore(store types.KubeconfigStore, stateDir string) (*AzureStore, error)
NewAzureStore creates a new Azure store
func (*AzureStore) GetContextPrefix ¶
func (s *AzureStore) GetContextPrefix(path string) string
func (*AzureStore) GetID ¶
func (s *AzureStore) GetID() string
func (*AzureStore) GetKind ¶
func (s *AzureStore) GetKind() types.StoreKind
func (*AzureStore) GetKubeconfigForPath ¶
func (*AzureStore) GetLogger ¶
func (s *AzureStore) GetLogger() *logrus.Entry
func (*AzureStore) GetSearchPreview ¶
func (*AzureStore) GetStoreConfig ¶
func (s *AzureStore) GetStoreConfig() types.KubeconfigStore
func (*AzureStore) InitializeAzureStore ¶
func (s *AzureStore) InitializeAzureStore() error
InitializeAzureStore initializes the Azure store
func (*AzureStore) IsInitialized ¶
func (s *AzureStore) IsInitialized() bool
IsInitialized checks if the store has been initialized already
func (*AzureStore) StartSearch ¶
func (s *AzureStore) StartSearch(channel chan storetypes.SearchResult)
StartSearch starts the search for AKS clusters Limitation: Two seperate subscriptions should not have the same (resource_group, cluster-name) touple
func (*AzureStore) VerifyKubeconfigPaths ¶
func (s *AzureStore) VerifyKubeconfigPaths() error
type CapiStore ¶
type CapiStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore Client client.Client Config *types.StoreConfigCapi }
func NewCapiStore ¶
func NewCapiStore(store types.KubeconfigStore, stateDir string) (*CapiStore, error)
func (*CapiStore) GetContextPrefix ¶
GetContextPrefix returns the context prefix
func (*CapiStore) GetKubeconfigForPath ¶
GetKubeconfigForPath returns the kubeconfig for the path
func (*CapiStore) GetStoreConfig ¶
func (s *CapiStore) GetStoreConfig() types.KubeconfigStore
func (*CapiStore) InitializeCapiStore ¶
func (*CapiStore) StartSearch ¶
func (s *CapiStore) StartSearch(channel chan storetypes.SearchResult)
StartSearch starts the search over the configured search paths
func (*CapiStore) VerifyKubeconfigPaths ¶
VerifyKubeconfigPaths verifies the kubeconfig paths
type DigitalOceanStore ¶
type DigitalOceanStore struct { Logger *logrus.Entry // DiscoveredClustersMutex is a mutex allow many reads, one write mutex to synchronize writes // to the DiscoveredClusters map. // This can happen when a goroutine still discovers clusters while another goroutine computes the preview for a missing cluster. DiscoveredClustersMutex sync.RWMutex ContextNameAndClusterNameToClusterIDMutex sync.RWMutex KubeconfigStore types.KubeconfigStore ContextToKubernetesService map[string]do.KubernetesService Config doks.DoctlConfig }
func NewDigitalOceanStore ¶
func NewDigitalOceanStore(store types.KubeconfigStore) (*DigitalOceanStore, error)
NewDigitalOceanStore creates a new DigitalOcean store
func (*DigitalOceanStore) GetContextPrefix ¶
func (s *DigitalOceanStore) GetContextPrefix(path string) string
func (*DigitalOceanStore) GetID ¶
func (s *DigitalOceanStore) GetID() string
func (*DigitalOceanStore) GetKind ¶
func (s *DigitalOceanStore) GetKind() types.StoreKind
func (*DigitalOceanStore) GetKubeconfigForPath ¶
func (d *DigitalOceanStore) GetKubeconfigForPath(path string, tags map[string]string) ([]byte, error)
GetKubeconfigForPath gets the kubeconfig bytes for the given kubeconfig path and tags For this store, instead of using the path to identify the kubeconfig in the backing store, the cluster ID in the tags metadata is used. Reason: the clusterID is a long non-intuitive string that we don't want to
func (*DigitalOceanStore) GetLogger ¶
func (s *DigitalOceanStore) GetLogger() *logrus.Entry
func (*DigitalOceanStore) GetSearchPreview ¶
GetSearchPreview enhances the preview with information stored in the metadata tags (no API requests are being performed)
func (*DigitalOceanStore) GetStoreConfig ¶
func (s *DigitalOceanStore) GetStoreConfig() types.KubeconfigStore
func (*DigitalOceanStore) InitializeDigitalOceanStore ¶
func (d *DigitalOceanStore) InitializeDigitalOceanStore() error
InitializeDigitalOceanStore initializes the DigitalOcean store with digital ocean clients
func (*DigitalOceanStore) IsInitialized ¶
func (s *DigitalOceanStore) IsInitialized() bool
IsInitialized checks if the store has been initialized with clients already
func (*DigitalOceanStore) StartSearch ¶
func (d *DigitalOceanStore) StartSearch(channel chan storetypes.SearchResult)
StartSearch starts the search for Digital Ocean clusters
func (*DigitalOceanStore) VerifyKubeconfigPaths ¶
func (s *DigitalOceanStore) VerifyKubeconfigPaths() error
type EKSStore ¶
type EKSStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore Client *awseks.Client Config *types.StoreConfigEKS // DiscoveredClusters maps the kubeconfig path (az_<resource-group>--<cluster-name>) -> cluster // This is a cache for the clusters discovered during the initial search for kubeconfig paths // when not using a search index DiscoveredClusters map[string]*eks.Cluster StateDirectory string }
func NewEKSStore ¶
func NewEKSStore(store types.KubeconfigStore, stateDir string) (*EKSStore, error)
func (*EKSStore) GetContextPrefix ¶
func (*EKSStore) GetKubeconfigForPath ¶
func (*EKSStore) GetSearchPreview ¶
func (*EKSStore) GetStoreConfig ¶
func (s *EKSStore) GetStoreConfig() types.KubeconfigStore
func (*EKSStore) InitializeEKSStore ¶
func (*EKSStore) IsInitialized ¶
func (*EKSStore) StartSearch ¶
func (s *EKSStore) StartSearch(channel chan storetypes.SearchResult)
func (*EKSStore) VerifyKubeconfigPaths ¶
type FilesystemStore ¶
type FilesystemStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore KubeconfigName string // contains filtered or unexported fields }
func NewFilesystemStore ¶
func NewFilesystemStore( kubeconfigName string, kubeconfigStore types.KubeconfigStore, ) (*FilesystemStore, error)
func (*FilesystemStore) GetContextPrefix ¶
func (s *FilesystemStore) GetContextPrefix(path string) string
func (*FilesystemStore) GetID ¶
func (s *FilesystemStore) GetID() string
func (*FilesystemStore) GetKind ¶
func (s *FilesystemStore) GetKind() types.StoreKind
func (*FilesystemStore) GetKubeconfigForPath ¶
func (*FilesystemStore) GetLogger ¶
func (s *FilesystemStore) GetLogger() *logrus.Entry
func (*FilesystemStore) GetStoreConfig ¶
func (s *FilesystemStore) GetStoreConfig() types.KubeconfigStore
func (*FilesystemStore) StartSearch ¶
func (s *FilesystemStore) StartSearch(channel chan storetypes.SearchResult)
func (*FilesystemStore) VerifyKubeconfigPaths ¶
func (s *FilesystemStore) VerifyKubeconfigPaths() error
type GKEStore ¶
type GKEStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore GkeClient *gkev1.Service Config *types.StoreConfigGKE // DiscoveredClusters maps the kubeconfig path (gke--project-name--clusterName) -> cluster // This is a cache for the clusters discovered during the initial search for kubeconfig paths // when not using a search index DiscoveredClusters map[string]*gkev1.Cluster // ProjectNameToID contains a mapping projectName -> project ID // used to construct the kubeconfig path containing the project name instead of a technical project id ProjectNameToID map[string]string StateDirectory string }
func NewGKEStore ¶
func NewGKEStore(store types.KubeconfigStore, stateDir string) (*GKEStore, error)
NewGKEStore creates a new GKE store
func (*GKEStore) GetContextPrefix ¶
func (*GKEStore) GetKubeconfigForPath ¶
func (*GKEStore) GetStoreConfig ¶
func (s *GKEStore) GetStoreConfig() types.KubeconfigStore
func (*GKEStore) InitializeGKEStore ¶
InitializeGKEStore initializes the store by listing all available projects for the Google Account Decoupled from the NewGKEStore() to be called when starting the search to reduce time when the CLI can start showing the fuzzy search
func (*GKEStore) IsInitialized ¶
IsInitialized checks if the store has been initialized already
func (*GKEStore) StartSearch ¶
func (s *GKEStore) StartSearch(channel chan storetypes.SearchResult)
func (*GKEStore) VerifyKubeconfigPaths ¶
type GardenConfig ¶
type GardenConfig struct { // Identity is the cluster identity of the garden cluster. // See cluster-identity ConfigMap in kube-system namespace of the garden cluster Identity string `yaml:"identity"` // Kubeconfig holds the path for the kubeconfig of the garden cluster Kubeconfig string `yaml:"kubeconfig"` }
GardenConfig holds the config of a garden cluster
type GardenerStore ¶
type GardenerStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore GardenClient gardenclient.Client Client client.Client Config *types.StoreConfigGardener LandscapeIdentity string LandscapeName string StateDirectory string CachePathToShoot map[string]gardencorev1beta1.Shoot PathToShootLock sync.RWMutex CachePathToManagedSeed map[string]seedmanagementv1alpha1.ManagedSeed PathToManagedSeedLock sync.RWMutex CacheCaSecretNameToSecret map[string]corev1.Secret CaSecretNameToSecretLock sync.RWMutex }
func NewGardenerStore ¶
func NewGardenerStore(store types.KubeconfigStore, stateDir string) (*GardenerStore, error)
NewGardenerStore creates a new Gardener store
func (*GardenerStore) GetContextPrefix ¶
func (s *GardenerStore) GetContextPrefix(path string) string
func (*GardenerStore) GetControlplaneKubeconfigForShoot ¶
func (s *GardenerStore) GetControlplaneKubeconfigForShoot(shootName, project string) ([]byte, *string, error)
func (*GardenerStore) GetID ¶
func (s *GardenerStore) GetID() string
func (*GardenerStore) GetKind ¶
func (s *GardenerStore) GetKind() types.StoreKind
func (*GardenerStore) GetKubeconfigForPath ¶
func (*GardenerStore) GetLogger ¶
func (s *GardenerStore) GetLogger() *logrus.Entry
func (*GardenerStore) GetSearchPreview ¶
func (*GardenerStore) GetStoreConfig ¶
func (s *GardenerStore) GetStoreConfig() types.KubeconfigStore
func (*GardenerStore) InitializeGardenerStore ¶
func (s *GardenerStore) InitializeGardenerStore() error
InitializeGardenerStore initializes the store using the provided Gardener kubeconfig decoupled from the NewGardenerStore() to be called when starting the search to reduce time when the CLI can start showing the fuzzy search
func (*GardenerStore) IsInitialized ¶
func (s *GardenerStore) IsInitialized() bool
IsInitialized checks if the store has been initialized already
func (*GardenerStore) StartSearch ¶
func (s *GardenerStore) StartSearch(channel chan storetypes.SearchResult)
StartSearch starts the search for Shoots and Managed Seeds
func (*GardenerStore) VerifyKubeconfigPaths ¶
func (s *GardenerStore) VerifyKubeconfigPaths() error
type GardenloginConfig ¶
type GardenloginConfig struct { // Gardens is a list of known GardenConfig clusters Gardens []GardenConfig `yaml:"gardens"` }
GardenloginConfig represents the config for the Gardenlogin-exec-provider that is required to work with the kubeconfig files obtained from the GardenConfig cluster If missing, this configuration is generated based on the Kubeswitch config
type OVHStore ¶
type OVHStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore Client *ovh.Client OVHKubeCache map[string]OVHKube // map[clusterID]OVHKube }
func NewOVHStore ¶
func NewOVHStore(store types.KubeconfigStore) (*OVHStore, error)
func (*OVHStore) GetContextPrefix ¶
func (*OVHStore) GetKubeconfigForPath ¶
func (*OVHStore) GetStoreConfig ¶
func (r *OVHStore) GetStoreConfig() types.KubeconfigStore
func (*OVHStore) StartSearch ¶
func (r *OVHStore) StartSearch(channel chan storetypes.SearchResult)
func (*OVHStore) VerifyKubeconfigPaths ¶
type PluginStore ¶
type PluginStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore Config *types.StoreConfigPlugin Client plugins.Store }
func NewPluginStore ¶
func NewPluginStore(store types.KubeconfigStore) (*PluginStore, error)
func (*PluginStore) GetContextPrefix ¶
func (s *PluginStore) GetContextPrefix(path string) string
func (*PluginStore) GetKind ¶
func (s *PluginStore) GetKind() types.StoreKind
func (*PluginStore) GetKubeconfigForPath ¶
func (*PluginStore) GetLogger ¶
func (s *PluginStore) GetLogger() *logrus.Entry
func (*PluginStore) GetStoreConfig ¶
func (s *PluginStore) GetStoreConfig() types.KubeconfigStore
func (*PluginStore) InitializePluginStore ¶
func (s *PluginStore) InitializePluginStore() error
InitializePluginStore initializes the plugin store
func (*PluginStore) StartSearch ¶
func (s *PluginStore) StartSearch(channel chan storetypes.SearchResult)
func (*PluginStore) VerifyKubeconfigPaths ¶
func (s *PluginStore) VerifyKubeconfigPaths() error
type RancherStore ¶
type RancherStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore ClientOpts *clientbase.ClientOpts Client *managementClient.Client }
func NewRancherStore ¶
func NewRancherStore(store types.KubeconfigStore) (*RancherStore, error)
func (*RancherStore) GetContextPrefix ¶
func (r *RancherStore) GetContextPrefix(path string) string
func (*RancherStore) GetID ¶
func (r *RancherStore) GetID() string
func (*RancherStore) GetKind ¶
func (r *RancherStore) GetKind() types.StoreKind
func (*RancherStore) GetKubeconfigForPath ¶
func (*RancherStore) GetLogger ¶
func (r *RancherStore) GetLogger() *logrus.Entry
func (*RancherStore) GetStoreConfig ¶
func (r *RancherStore) GetStoreConfig() types.KubeconfigStore
func (*RancherStore) StartSearch ¶
func (r *RancherStore) StartSearch(channel chan storetypes.SearchResult)
func (*RancherStore) VerifyKubeconfigPaths ¶
func (r *RancherStore) VerifyKubeconfigPaths() error
type ScalewayKube ¶
type ScalewayStore ¶
type ScalewayStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore Client *scw.Client DiscoveredClusters map[string]ScalewayKube }
func NewScalewayStore ¶
func NewScalewayStore(store types.KubeconfigStore) (*ScalewayStore, error)
func (*ScalewayStore) GetContextPrefix ¶
func (s *ScalewayStore) GetContextPrefix(path string) string
func (*ScalewayStore) GetID ¶
func (s *ScalewayStore) GetID() string
func (*ScalewayStore) GetKind ¶
func (r *ScalewayStore) GetKind() types.StoreKind
func (*ScalewayStore) GetKubeconfigForPath ¶
func (*ScalewayStore) GetLogger ¶
func (s *ScalewayStore) GetLogger() *logrus.Entry
func (*ScalewayStore) GetStoreConfig ¶
func (s *ScalewayStore) GetStoreConfig() types.KubeconfigStore
func (*ScalewayStore) StartSearch ¶
func (s *ScalewayStore) StartSearch(channel chan storetypes.SearchResult)
func (*ScalewayStore) VerifyKubeconfigPaths ¶
func (r *ScalewayStore) VerifyKubeconfigPaths() error
type VaultStore ¶
type VaultStore struct { Logger *logrus.Entry KubeconfigStore types.KubeconfigStore Client *vaultapi.Client VaultKeyKubeconfig string KubeconfigName string EngineVersion string // contains filtered or unexported fields }
func NewVaultStore ¶
func NewVaultStore(vaultAPIAddressFromFlag, vaultTokenFileName, kubeconfigName string, kubeconfigStore types.KubeconfigStore) (*VaultStore, error)
func (*VaultStore) GetContextPrefix ¶
func (s *VaultStore) GetContextPrefix(path string) string
func (*VaultStore) GetID ¶
func (s *VaultStore) GetID() string
func (*VaultStore) GetKind ¶
func (s *VaultStore) GetKind() types.StoreKind
func (*VaultStore) GetKubeconfigForPath ¶
func (*VaultStore) GetLogger ¶
func (s *VaultStore) GetLogger() *logrus.Entry
func (*VaultStore) GetStoreConfig ¶
func (s *VaultStore) GetStoreConfig() types.KubeconfigStore
func (*VaultStore) StartSearch ¶
func (s *VaultStore) StartSearch(channel chan storetypes.SearchResult)
func (*VaultStore) VerifyKubeconfigPaths ¶
func (s *VaultStore) VerifyKubeconfigPaths() error
Source Files
¶
- kubeconfig_store_akamai.go
- kubeconfig_store_azure.go
- kubeconfig_store_capi.go
- kubeconfig_store_digital_ocean.go
- kubeconfig_store_eks.go
- kubeconfig_store_file.go
- kubeconfig_store_gardener.go
- kubeconfig_store_gke.go
- kubeconfig_store_ovh.go
- kubeconfig_store_plugins.go
- kubeconfig_store_rancher.go
- kubeconfig_store_scaleway.go
- kubeconfig_store_vault.go
- types.go