k8s

Jan 12, 2023

Changes in this version

+ func CreateKubeadmConfiguration(wr io.Writer, config *KubeadmConfig) error

+ func WriteKubeadmConfiguration(fs afero.Fs, config *KubeadmConfig) (f afero.File, err error)

+ type KubeadmConfig struct

+ CreateIp bool

+ DomainName string

+ EnableMDNS bool

+ Ip string

+ KubernetesVersion string

+ NetworkInterface string

+ func (c *KubeadmConfig) GetApiEndPoint() string

May 18, 2022

Changes in this version

+ func GetIkniteConfigMap(client *kubernetes.Clientset) (cm *corev1.ConfigMap, err error)

+ func WriteIkniteConfigMap(client *kubernetes.Clientset, cm *corev1.ConfigMap) (res *corev1.ConfigMap, err error)

May 18, 2022

Changes in this version

+ var ApplicationSchemaGroupVersionKind = schema.GroupVersionKind

+ func AreWorkloadsReady(config *Config, callback WorkloadStateCallbackFunc) wait.ConditionFunc

+ func OkString(b bool) string

+ func StatusViewerFor(kind schema.GroupKind) (polymorphichelpers.StatusViewer, error)

+ type Application struct

+ Status ApplicationStatus

+ type ApplicationStatus struct

+ Health HealthStatus

+ Sync SyncStatus

+ type ApplicationStatusViewer struct

+ func (s *ApplicationStatusViewer) Status(obj runtime.Unstructured, revision int64) (string, bool, error)

type Config

+ func (config *Config) RESTClient() *RESTClientGetter

+ func (config *Config) WaitForWorkloads(timeout time.Duration, callback WorkloadStateCallbackFunc) error

+ type HealthStatus struct

+ Message string

+ Status string

+ type RESTClientGetter struct

+ func (client *RESTClientGetter) AllWorkloadStates() (result []*WorkloadState, err error)

+ func (client *RESTClientGetter) HasApplications() (has bool, err error)

+ func (r *RESTClientGetter) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

+ func (r *RESTClientGetter) ToRESTConfig() (*rest.Config, error)

+ func (r *RESTClientGetter) ToRESTMapper() (meta.RESTMapper, error)

+ func (r *RESTClientGetter) ToRawKubeConfigLoader() clientcmd.ClientConfig

+ type SyncStatus struct

+ Status string

+ type WorkloadState struct

+ Message string

+ Name string

+ Namespace string

+ Ok bool

+ func (r *WorkloadState) LongString() string

+ func (r *WorkloadState) String() string

+ type WorkloadStateCallbackFunc func(state bool, total int, ready []*WorkloadState, unready []*WorkloadState)

May 8, 2022

Changes in this version

+ func GetPodStatus(clientset kubernetes.Interface) (active, unready, stopped []*v1.Pod, err error)

+ func GetPodsSeparatedByStatus(pods []v1.Pod) (active, unready, stopped []*v1.Pod)

+ func IsPodReady(pod *v1.Pod) bool

type Config

+ func (config *Config) WaitForCluster(timeout time.Duration, minimumPodsReady int) (err error)

May 4, 2022

Changes in this version

type Config

+ func LoadFromFile(filename string) (*Config, error)

Jan 22, 2022

Changes in this version

+ const KubernetesVersion

+ func CleanConfig() (err error)

+ func RunKubeadm(parameters []string) (err error)

+ func RunKubeadmInit(ip net.IP) error

+ type Config api.Config

+ func LoadFromDefault() (*Config, error)

+ func (c *Config) RenameConfig(newName string) *Config

+ func (config *Config) CheckClusterRunning() error

+ func (config *Config) Client() (client *kubernetes.Clientset, err error)

+ func (config *Config) IsConfigServerAddress(ip net.IP) bool

+ func (config *Config) RestartProxy() (err error)

+ func (config *Config) WriteToFile(filename string) error