cke

May 24, 2024

Changes in this version

type Constraints

+ RepairRebootingSeconds int

Apr 30, 2024

Changes in this version

+ const KeyAutoRepairDisabled

+ const KeyAutoRepairQueryVariables

type Constraints

+ MaximumRepairs int

type Storage

+ func (s Storage) EnableAutoRepair(ctx context.Context, enable bool) error

+ func (s Storage) GetAutoRepairQueryVariables(ctx context.Context) ([]byte, error)

+ func (s Storage) IsAutoRepairDisabled(ctx context.Context) (bool, error)

+ func (s Storage) SetAutoRepairQueryVariables(ctx context.Context, vars string) error

Jan 29, 2024

Changes in this version

+ const DefaultMaxConcurrentRepairs

+ const DefaultRepairCommandTimeoutSeconds

+ const DefaultRepairEvictionTimeoutSeconds

+ const DefaultRepairHealthCheckCommandTimeoutSeconds

+ const KeyRepairsDisabled

+ const KeyRepairsPrefix

+ const KeyRepairsWriteIndex

+ const PhaseRepairMachines

+ const RepairStatusFailed

+ const RepairStatusProcessing

+ const RepairStatusQueued

+ const RepairStatusSucceeded

+ const RepairStepStatusDraining

+ const RepairStepStatusWaiting

+ const RepairStepStatusWatching

+ var ErrRepairOperationNotFound = errors.New("repair operation not found for repair queue entry")

+ var ErrRepairProcedureNotFound = errors.New("repair procedure not found for repair queue entry")

+ var ErrRepairStepOutOfRange = errors.New("repair step of repair queue entry is out of range")

+ func BuildMachineRepairStatus(nodes []*Node, entries []*RepairQueueEntry) map[string]map[string]bool

+ func CountRepairQueueEntries(entries []*RepairQueueEntry) map[string]int

type Cluster

+ Repair Repair

type ClusterStatus

+ RepairQueue RepairQueueStatus

+ type Repair struct

+ EvictInterval *int

+ EvictRetries *int

+ EvictionTimeoutSeconds *int

+ MaxConcurrentRepairs *int

+ ProtectedNamespaces *metav1.LabelSelector

+ RepairProcedures []RepairProcedure

+ type RepairOperation struct

+ CommandTimeoutSeconds *int

+ HealthCheckCommand []string

+ Operation string

+ RepairSteps []RepairStep

+ type RepairProcedure struct

+ MachineTypes []string

+ RepairOperations []RepairOperation

+ type RepairQueueEntry struct

+ Address string

+ Deleted bool

+ DrainBackOffCount int

+ DrainBackOffExpire time.Time

+ Index int64

+ LastTransitionTime time.Time

+ MachineType string

+ Nodename string

+ Operation string

+ Status RepairStatus

+ Step int

+ StepStatus RepairStepStatus

+ func NewRepairQueueEntry(operation, machineType, address string) *RepairQueueEntry

+ func (entry *RepairQueueEntry) FillNodename(cluster *Cluster)

+ func (entry *RepairQueueEntry) GetCurrentRepairStep(cluster *Cluster) (*RepairStep, error)

+ func (entry *RepairQueueEntry) GetMatchingRepairOperation(cluster *Cluster) (*RepairOperation, error)

+ func (entry *RepairQueueEntry) HasFinished() bool

+ func (entry *RepairQueueEntry) IsInCluster() bool

+ type RepairQueueStatus struct

+ DrainCompleted map[string]bool

+ Enabled bool

+ Entries []*RepairQueueEntry

+ RepairCompleted map[string]bool

+ type RepairStatus string

+ type RepairStep struct

+ CommandInterval *int

+ CommandRetries *int

+ CommandTimeoutSeconds *int

+ NeedDrain bool

+ RepairCommand []string

+ WatchSeconds *int

+ type RepairStepStatus string

type Storage

+ func (s Storage) DeleteRepairsEntry(ctx context.Context, leaderKey string, index int64) error

+ func (s Storage) EnableRepairQueue(ctx context.Context, enable bool) error

+ func (s Storage) GetRepairsEntries(ctx context.Context) ([]*RepairQueueEntry, error)

+ func (s Storage) GetRepairsEntry(ctx context.Context, index int64) (*RepairQueueEntry, error)

+ func (s Storage) IsRepairQueueDisabled(ctx context.Context) (bool, error)

+ func (s Storage) RegisterRepairsEntry(ctx context.Context, r *RepairQueueEntry) error

+ func (s Storage) UpdateRepairsEntry(ctx context.Context, r *RepairQueueEntry) error

Dec 19, 2023

Changes in this version

+ const KeyRebootsRunning

type Storage

+ func (s Storage) IsRebootQueueRunning(ctx context.Context) (bool, error)

+ func (s Storage) SetRebootQueueRunning(ctx context.Context, flag bool) error

Aug 17, 2023

Changes in this version

type Reboot

+ EvictInterval *int

+ EvictRetries *int

Jul 19, 2023

Changes in this version

type Reboot

+ CommandInterval *int

Jun 2, 2023

Changes in this version

+ const AnnotationResourceRank

+ const RankClusterRole

+ const RankClusterRoleBinding

+ const RankClusterScopedResourceDefault

+ const RankConfigMap

+ const RankCustomResourceDefinition

+ const RankNamespace

+ const RankNamespaceScopedResourceDefault

+ const RankNetworkPolicy

+ const RankRole

+ const RankRoleBinding

+ const RankSecret

+ const RankServiceAccount

+ func DecideRank(kind, namespace string, rank uint32) (uint32, error)

type ResourceDefinition

+ Rank uint32

type ResourceStatus

+ Completed bool

Apr 30, 2023

Changes in this version

type Reboot

+ CommandRetries *int

Jan 31, 2023

Changes in this version

type EtcdStatus

+ IsAddedMember bool

Jan 18, 2023

Changes in this version

+ func BuildNodeRebootStatus(nodes []*Node, entries []*RebootQueueEntry) map[string]map[string]bool

Oct 21, 2022

Changes in this version

type Cluster

+ CPTolerations []string

Sep 14, 2022

Changes in this version

type Infrastructure

+ ReleaseAgent func(addrs string)

Jul 22, 2022

Changes in this version

+ const DefaultMaxConcurrentReboots

+ const DefaultRebootEvictionTimeoutSeconds

+ const RebootStatusDraining

+ func CountRebootQueueEntries(entries []*RebootQueueEntry) map[string]int

type Reboot

+ BootCheckCommand []string

+ MaxConcurrentReboots *int

+ RebootCommand []string

type RebootQueueEntry

+ DrainBackOffCount int

+ DrainBackOffExpire time.Time

+ LastTransitionTime time.Time

+ Node string

+ func DedupRebootQueueEntries(entries []*RebootQueueEntry) []*RebootQueueEntry

+ func (entry *RebootQueueEntry) ClusterMember(c *Cluster) bool

May 19, 2022

Changes in this version

+ const UnboundExporterImage

Oct 19, 2021

Changes in this version

type KubernetesClusterStatus

+ EtcdEndpointSlice *discoveryv1.EndpointSlice

+ MasterEndpointSlice *discoveryv1.EndpointSlice

Aug 26, 2021

Changes in this version

type ProxyParams

+ Disable bool

May 12, 2021

Changes in this version

+ func ValidateProxyMode(mode proxyv1alpha1.ProxyMode) error

type ProxyParams

+ Config *unstructured.Unstructured

+ func (p ProxyParams) MergeConfig(base *proxyv1alpha1.KubeProxyConfiguration) (*proxyv1alpha1.KubeProxyConfiguration, error)

+ type ProxyStatus struct

+ Config *proxyv1alpha1.KubeProxyConfiguration

+ IsHealthy bool

Mar 22, 2021

Changes in this version

+ const CKELabelName

+ type KubeHTTP struct

+ func (k *KubeHTTP) CACert() string

+ func (k *KubeHTTP) Client() *well.HTTPClient

+ func (k *KubeHTTP) GetCert(ctx context.Context, inf Infrastructure) (cert, key []byte, err error)

+ func (k *KubeHTTP) Init(ctx context.Context, inf Infrastructure) error

Mar 13, 2021

Changes in this version

type APIServerParams

+ AuditLogPath string

Jan 28, 2021

Changes in this version

+ type ProxyMode string

+ const ProxyModeIPVS

+ const ProxyModeIptables

+ const ProxyModeUserspace

+ func (m ProxyMode) Validate() error

+ type ProxyParams struct

+ Mode ProxyMode

+ func (p ProxyParams) GetMode() ProxyMode

Jan 20, 2021

Changes in this version

type KubeletParams

+ CRIEndpoint string

+ func (p KubeletParams) MergeConfig(base *kubeletv1beta1.KubeletConfiguration) (*kubeletv1beta1.KubeletConfiguration, error)

type SchedulerParams

+ func (p SchedulerParams) MergeConfig(base *schedulerv1beta1.KubeSchedulerConfiguration) (*schedulerv1beta1.KubeSchedulerConfiguration, error)

Jan 6, 2021

Changes in this version

type KubeletParams

+ func (p KubeletParams) MergeConfigV1Beta1(base *kubeletv1beta1.KubeletConfiguration) (*kubeletv1beta1.KubeletConfiguration, error)

type SchedulerParams

+ func (p SchedulerParams) GetAPIversion() (string, error)

+ func (p SchedulerParams) MergeConfigV1Alpha2(base *schedulerv1alpha2.KubeSchedulerConfiguration) (*schedulerv1alpha2.KubeSchedulerConfiguration, error)

Dec 7, 2020

Changes in this version

+ const KeyRebootsDisabled

type Storage

+ func (s Storage) EnableRebootQueue(ctx context.Context, flag bool) error

+ func (s Storage) IsRebootQueueDisabled(ctx context.Context) (bool, error)

Dec 1, 2020

Changes in this version

+ const PhaseUncordonNodes

Nov 18, 2020

Changes in this version

+ const KeyRebootsPrefix

+ const KeyRebootsWriteIndex

+ const PhaseRebootNodes

+ const RebootStatusCancelled

+ const RebootStatusQueued

+ const RebootStatusRebooting

type Cluster

+ Reboot Reboot

type Constraints

+ RebootMaximumUnreachable int

+ type InfoOperator interface

+ Info func() string

+ type Reboot struct

+ Command []string

+ CommandTimeoutSeconds *int

+ EvictionTimeoutSeconds *int

+ ProtectedNamespaces *metav1.LabelSelector

+ type RebootQueueEntry struct

+ Index int64

+ Nodes []string

+ Status RebootStatus

+ func NewRebootQueueEntry(nodes []string) *RebootQueueEntry

+ type RebootStatus string

type Record

+ Info string

+ func (r *Record) SetInfo(i string)

type Storage

+ func (s Storage) DeleteRebootsEntry(ctx context.Context, leaderKey string, index int64) error

+ func (s Storage) GetRebootsEntries(ctx context.Context) ([]*RebootQueueEntry, error)

+ func (s Storage) GetRebootsEntry(ctx context.Context, index int64) (*RebootQueueEntry, error)

+ func (s Storage) GetRebootsFrontEntry(ctx context.Context) (*RebootQueueEntry, error)

+ func (s Storage) RegisterRebootsEntry(ctx context.Context, r *RebootQueueEntry) error

+ func (s Storage) UpdateRebootsEntry(ctx context.Context, r *RebootQueueEntry) error

Oct 12, 2020

Changes in this version

+ const AnnotationResourceInjectCA

+ const AnnotationResourceIssueCert

+ const CAWebhook

+ const KindMutatingWebhookConfiguration

+ const KindSecret

+ const KindValidatingWebhookConfiguration

+ func VaultPKIKey(caKey string) string

+ type WebhookCA struct

+ func (WebhookCA) IssueCertificate(ctx context.Context, inf Infrastructure, namespace, name string) (cert, key string, err error)

Oct 5, 2020

Changes in this version

type KubeletParams

+ Config *unstructured.Unstructured

+ func (p KubeletParams) GetConfigV1Beta1(base *kubeletv1beta1.KubeletConfiguration) (*kubeletv1beta1.KubeletConfiguration, error)

type KubeletStatus

+ Config *kubeletv1beta1.KubeletConfiguration

type SchedulerParams

+ Config *unstructured.Unstructured

+ func (p SchedulerParams) GetConfigV1Alpha2(base *schedulerv1alpha2.KubeSchedulerConfiguration) (*schedulerv1alpha2.KubeSchedulerConfiguration, error)

+ func (p SchedulerParams) IsConfigV1Alpha1() bool

type SchedulerStatus

+ Config *schedulerv1alpha2.KubeSchedulerConfiguration

May 29, 2020

Changes in this version

+ const PhaseUpgradeAborted

type KubeletParams

+ CgroupDriver string

type KubeletStatus

+ CgroupDriver string

type Node

+ func Workers(nodes []*Node) []*Node

type SchedulerParams

+ Predicates []string

+ Priorities []string

type SchedulerStatus

+ Predicates []schedulerv1.PredicatePolicy

+ Priorities []schedulerv1.PriorityPolicy

Apr 10, 2020

Changes in this version

type Infrastructure

+ K8sConfig func(ctx context.Context, n *Node) (*rest.Config, error)

Apr 2, 2020

Changes in this version

+ const KubernetesImage

type ContainerEngine

+ RunWithOutput func(img Image, binds []Mount, command string) ([]byte, []byte, error)

type KubeletStatus

+ NeedUpdateBlockPVsUpToV1_16 []string

+ type ResourceStatus struct

+ Annotations map[string]string

+ HasBeenSSA bool

Feb 20, 2020

Changes in this version

+ var AllOperationPhases = []OperationPhase

type Storage

+ func (s Storage) IsLeader(ctx context.Context, leaderKey string) (bool, error)

Dec 25, 2019

Changes in this version

+ const KeyStatus

+ const PhaseCompleted

+ const PhaseEtcdBoot

+ const PhaseEtcdBootAborted

+ const PhaseEtcdMaintain

+ const PhaseEtcdStart

+ const PhaseEtcdWait

+ const PhaseK8sMaintain

+ const PhaseK8sStart

+ const PhaseRivers

+ const PhaseStopCP

+ const PhaseUpgrade

+ type OperationPhase string

+ type ServerStatus struct

+ Phase OperationPhase

+ Timestamp time.Time

type Storage

+ func (s Storage) GetStatus(ctx context.Context) (*ServerStatus, error)

+ func (s Storage) SetStatus(ctx context.Context, lease clientv3.LeaseID, st *ServerStatus) error

Dec 13, 2019

Changes in this version

+ const ConfigVersion

+ const KeyConfigVersion

type ClusterStatus

+ ConfigVersion string

type Storage

+ func (s Storage) GetConfigVersion(ctx context.Context) (string, error)

+ func (s Storage) PutConfigVersion(ctx context.Context, leaderKey string) error

Oct 8, 2019

Changes in this version

type NodeStatus

+ SSHConnected bool

Sep 30, 2019

Changes in this version

+ const KindPodDisruptionBudget

Aug 15, 2019

Changes in this version

+ const AdminGroup

+ func UserKubeconfig(cluster, userName, ca, clientCrt, clientKey, server string) *api.Config

type KubernetesCA

+ func (k KubernetesCA) IssueUserCert(ctx context.Context, inf Infrastructure, userName, groupName string, ...) (crt, key string, err error)

Aug 1, 2019

Changes in this version

type KubernetesClusterStatus

+ EtcdService *corev1.Service

+ MasterEndpoints *corev1.Endpoints

Jul 15, 2019

Changes in this version

type Cluster

+ TaintCP bool

Jul 9, 2019

Changes in this version

+ const RoleAdmin

+ const RoleKubeControllerManager

+ const RoleKubeProxy

+ const RoleKubeScheduler

+ const RoleKubelet

+ const RoleServiceAccount

+ const RoleSystem

+ var CAKeys = []string

Jun 27, 2019

Changes in this version

+ type SchedulerParams struct

+ Extenders []string

+ type SchedulerStatus struct

+ Extenders []*scheduler.ExtenderConfig

+ IsHealthy bool

Jun 14, 2019

Changes in this version

+ const KeySabakanDisabled

type Storage

+ func (s Storage) EnableSabakan(ctx context.Context, flag bool) error

+ func (s Storage) IsSabakanDisabled(ctx context.Context) (bool, error)

Jun 4, 2019

Changes in this version

+ const CAKubernetesAggregation

+ const CNAPIServer

+ type AggregationCA struct

+ func (a AggregationCA) IssueClientCertificate(ctx context.Context, inf Infrastructure) (cert, key string, err error)

May 28, 2019

Changes in this version

type NodeStatus

+ EtcdRivers ServiceStatus

type Operator

+ Targets func() []string

type Options

+ EtcdRivers ServiceParams

type Record

+ Targets []string

+ type RecordChan <-chan *Record

type Storage

+ func (s Storage) WatchRecords(ctx context.Context, initialCount int64) (RecordChan, error)

Mar 29, 2019

Changes in this version

+ const K8sSecret

Mar 19, 2019

Changes in this version

type KubernetesClusterStatus

+ IsControlPlaneReady bool

Mar 18, 2019

Changes in this version

+ const AnnotationResourceImage

+ func SortResources(res []ResourceDefinition)

type ResourceDefinition

+ Image string

+ func (d ResourceDefinition) NeedUpdate(annotations map[string]string) bool

Mar 15, 2019

Changes in this version

+ const AnnotationResourceOriginal

+ const AnnotationResourceRevision

+ const KeyResourcePrefix

+ const KindClusterRole

+ const KindClusterRoleBinding

+ const KindConfigMap

+ const KindCronJob

+ const KindDaemonSet

+ const KindDeployment

+ const KindNamespace

+ const KindNetworkPolicy

+ const KindPodSecurityPolicy

+ const KindRole

+ const KindRoleBinding

+ const KindService

+ const KindServiceAccount

+ func ApplyResource(clientset *kubernetes.Clientset, data []byte, rev int64) error

+ func ParseResource(data []byte) (key string, jsonData []byte, err error)

+ type Kind string

+ func (k Kind) IsSupported() bool

+ func (k Kind) Order() int

type KubernetesClusterStatus

+ ResourceStatuses map[string]int64

+ func (s KubernetesClusterStatus) SetResourceStatus(rkey string, annotations map[string]string) error

+ type ResourceDefinition struct

+ Definition []byte

+ Key string

+ Kind Kind

+ Name string

+ Namespace string

+ Revision int64

+ func (d ResourceDefinition) String() string

type Storage

+ func (s Storage) DeleteResource(ctx context.Context, key string) error

+ func (s Storage) GetAllResources(ctx context.Context) ([]ResourceDefinition, error)

+ func (s Storage) GetResource(ctx context.Context, key string) ([]byte, int64, error)

+ func (s Storage) ListResources(ctx context.Context) ([]string, error)

+ func (s Storage) SetResource(ctx context.Context, key, value string) error

Mar 7, 2019

Changes in this version

+ type CNIConfFile struct

+ Content string

+ Name string

type KubeletParams

+ CNIConfFile CNIConfFile

Feb 26, 2019

Changes in this version

type KubeletParams

+ ContainerLogMaxFiles int32

+ ContainerLogMaxSize string

+ ContainerRuntime string

+ ContainerRuntimeEndpoint string

type KubeletStatus

+ ContainerLogMaxFiles int32

+ ContainerLogMaxSize string

Feb 12, 2019

Changes in this version

+ type APIServerParams struct

+ AuditLogEnabled bool

+ AuditLogPolicy string

Jan 24, 2019

Changes in this version

+ const CAEtcdClient

+ const CAEtcdPeer

+ const CAKubernetes

+ const CAServer

+ const CKESecret

+ const CoreDNSImage

+ const DefaultRunTimeout

+ const EtcdImage

+ const HyperkubeImage

+ const KeyCA

+ const KeyCluster

+ const KeyClusterRevision

+ const KeyConstraints

+ const KeyLeader

+ const KeyRecordID

+ const KeyRecords

+ const KeySabakanQueryVariables

+ const KeySabakanTemplate

+ const KeySabakanURL

+ const KeyServiceAccountCert

+ const KeyServiceAccountKey

+ const KeyVault

+ const LabelPrivate

+ const LabelShared

+ const PauseImage

+ const PropagationPrivate

+ const PropagationRPrivate

+ const PropagationRShared

+ const PropagationRSlave

+ const PropagationShared

+ const PropagationSlave

+ const SSHSecret

+ const StatusCancelled

+ const StatusCompleted

+ const StatusNew

+ const StatusRunning

+ const ToolsImage

+ const UnboundImage

+ const Version

+ var ErrNoLeader = errors.New("lost leadership")

+ var ErrNotFound = errors.New("not found")

+ func AddUserRole(ctx context.Context, cli *clientv3.Client, name, prefix string) error

+ func AdminKubeconfig(cluster, ca, clientCrt, clientKey, server string) *api.Config

+ func AllImages() []string

+ func ConnectVault(ctx context.Context, data []byte) error

+ func GetUserRoles(ctx context.Context, cli *clientv3.Client, user string) ([]string, error)

+ func IssueEtcdClientCertificate(inf Infrastructure, username, ttl string) (cert, key string, err error)

+ func Kubeconfig(cluster, user, ca, clientCrt, clientKey string) *api.Config

+ func NewEtcdConfig() *etcdutil.Config

+ func VaultClient(cfg *VaultConfig) (*vault.Client, *vault.Secret, error)

+ type Agent interface

+ Close func() error

+ Run func(command string) (stdout, stderr []byte, err error)

+ RunWithInput func(command, input string) error

+ RunWithTimeout func(command, input string, timeout time.Duration) (stdout, stderr []byte, err error)

+ func SSHAgent(node *Node, privkey string) (Agent, error)

+ type BindPropagation string

+ func (p BindPropagation) String() string

+ type Cluster struct

+ DNSServers []string

+ DNSService string

+ EtcdBackup EtcdBackup

+ Name string

+ Nodes []*Node

+ Options Options

+ PodSubnet string

+ ServiceSubnet string

+ func NewCluster() *Cluster

+ func (c *Cluster) Validate() error

+ type ClusterDNSStatus struct

+ ClusterDomain string

+ ClusterIP string

+ ConfigMap *corev1.ConfigMap

+ Deployment *appsv1.Deployment

+ RBACRoleBindingExists bool

+ RBACRoleExists bool

+ ServiceAccountExists bool

+ ServiceExists bool

+ type ClusterStatus struct

+ Etcd EtcdClusterStatus

+ Kubernetes KubernetesClusterStatus

+ Name string

+ NodeStatuses map[string]*NodeStatus

+ type Command struct

+ Detail string

+ Name string

+ Target string

+ func (c Command) String() string

+ type Commander interface

+ Command func() Command

+ Run func(ctx context.Context, inf Infrastructure) error

+ type Constraints struct

+ ControlPlaneCount int

+ MaximumWorkers int

+ MinimumWorkers int

+ func DefaultConstraints() *Constraints

+ func (c *Constraints) Check(cluster *Cluster) error

+ type ContainerEngine interface

+ Exists func(name string) (bool, error)

+ Inspect func(name []string) (map[string]ServiceStatus, error)

+ Kill func(name string) error

+ PullImage func(img Image) error

+ Remove func(name string) error

+ Run func(img Image, binds []Mount, command string) error

+ RunSystem func(name string, img Image, opts []string, params, extra ServiceParams) error

+ RunWithInput func(img Image, binds []Mount, command, input string) error

+ Stop func(name string) error

+ VolumeCreate func(name string) error

+ VolumeExists func(name string) (bool, error)

+ VolumeRemove func(name string) error

+ func Docker(agent Agent) ContainerEngine

+ type EtcdBackup struct

+ Enabled bool

+ PVCName string

+ Rotate int

+ Schedule string

+ type EtcdBackupStatus struct

+ ConfigMap *corev1.ConfigMap

+ CronJob *batchv1beta1.CronJob

+ Pod *corev1.Pod

+ Secret *corev1.Secret

+ Service *corev1.Service

+ type EtcdCA struct

+ func (e EtcdCA) IssueForAPIServer(ctx context.Context, inf Infrastructure, node *Node) (crt, key string, err error)

+ func (e EtcdCA) IssueForBackup(ctx context.Context, inf Infrastructure) (cert, key string, err error)

+ func (e EtcdCA) IssuePeerCert(ctx context.Context, inf Infrastructure, node *Node) (crt, key string, err error)

+ func (e EtcdCA) IssueRoot(ctx context.Context, inf Infrastructure) (cert, key string, err error)

+ func (e EtcdCA) IssueServerCert(ctx context.Context, inf Infrastructure, node *Node, domain string) (crt, key string, err error)

+ type EtcdClusterStatus struct

+ InSyncMembers map[string]bool

+ IsHealthy bool

+ Members map[string]*etcdserverpb.Member

+ type EtcdParams struct

+ VolumeName string

+ type EtcdStatus struct

+ HasData bool

+ type Image string

+ func (i Image) Name() string

+ type Infrastructure interface

+ Agent func(addr string) Agent

+ Close func()

+ Engine func(addr string) ContainerEngine

+ HTTPClient func() *well.HTTPClient

+ HTTPSClient func(ctx context.Context) (*well.HTTPClient, error)

+ K8sClient func(ctx context.Context, n *Node) (*kubernetes.Clientset, error)

+ NewEtcdClient func(ctx context.Context, endpoints []string) (*clientv3.Client, error)

+ Storage func() Storage

+ Vault func() (*vault.Client, error)

+ func NewInfrastructure(ctx context.Context, c *Cluster, s Storage) (Infrastructure, error)

+ type IssueResponse struct

+ CACert string

+ Cert string

+ Key string

+ type KubeComponentStatus struct

+ IsHealthy bool

+ type KubeletParams struct

+ AllowSwap bool

+ BootTaints []corev1.Taint

+ Domain string

+ type KubeletStatus struct

+ AllowSwap bool

+ Domain string

+ IsHealthy bool

+ type KubernetesCA struct

+ func (k KubernetesCA) IssueAdminCert(ctx context.Context, inf Infrastructure, ttl string) (crt, key string, err error)

+ func (k KubernetesCA) IssueForAPIServer(ctx context.Context, inf Infrastructure, n *Node, serviceSubnet, domain string) (crt, key string, err error)

+ func (k KubernetesCA) IssueForControllerManager(ctx context.Context, inf Infrastructure) (crt, key string, err error)

+ func (k KubernetesCA) IssueForKubelet(ctx context.Context, inf Infrastructure, node *Node) (crt, key string, err error)

+ func (k KubernetesCA) IssueForProxy(ctx context.Context, inf Infrastructure) (crt, key string, err error)

+ func (k KubernetesCA) IssueForScheduler(ctx context.Context, inf Infrastructure) (crt, key string, err error)

+ func (k KubernetesCA) IssueForServiceAccount(ctx context.Context, inf Infrastructure) (crt, key string, err error)

+ type KubernetesClusterStatus struct

+ ClusterDNS ClusterDNSStatus

+ DNSService *corev1.Service

+ EtcdBackup EtcdBackupStatus

+ EtcdEndpoints *corev1.Endpoints

+ IsReady bool

+ NodeDNS NodeDNSStatus

+ Nodes []corev1.Node

+ RBACRoleBindingExists bool

+ RBACRoleExists bool

+ type Mount struct

+ Destination string

+ Label SELinuxLabel

+ Propagation BindPropagation

+ ReadOnly bool

+ Source string

+ func (m Mount) Equal(o Mount) bool

+ type Node struct

+ Address string

+ Annotations map[string]string

+ ControlPlane bool

+ Hostname string

+ Labels map[string]string

+ Taints []corev1.Taint

+ User string

+ func ControlPlanes(nodes []*Node) []*Node

+ func (n *Node) Nodename() string

+ type NodeDNSStatus struct

+ ConfigMap *corev1.ConfigMap

+ DaemonSet *appsv1.DaemonSet

+ type NodeStatus struct

+ APIServer KubeComponentStatus

+ ControllerManager KubeComponentStatus

+ Etcd EtcdStatus

+ Kubelet KubeletStatus

+ Labels map[string]string

+ Proxy KubeComponentStatus

+ Rivers ServiceStatus

+ Scheduler KubeComponentStatus

+ type Operator interface

+ Name func() string

+ NextCommand func() Commander

+ type Options struct

+ APIServer ServiceParams

+ ControllerManager ServiceParams

+ Etcd EtcdParams

+ Kubelet KubeletParams

+ Proxy ServiceParams

+ Rivers ServiceParams

+ Scheduler ServiceParams

+ type Record struct

+ Command Command

+ EndAt time.Time

+ Error string

+ ID int64

+ Operation string

+ StartAt time.Time

+ Status RecordStatus

+ func NewRecord(id int64, op string) *Record

+ func (r *Record) Cancel()

+ func (r *Record) Complete()

+ func (r *Record) SetCommand(c Command)

+ func (r *Record) SetError(e error)

+ type RecordStatus string

+ type SELinuxLabel string

+ func (l SELinuxLabel) String() string

+ type ServiceParams struct

+ ExtraArguments []string

+ ExtraBinds []Mount

+ ExtraEnvvar map[string]string

+ func (s ServiceParams) Equal(o ServiceParams) bool

+ type ServiceStatus struct

+ BuiltInParams ServiceParams

+ ExtraParams ServiceParams

+ Image string

+ Running bool

+ type Storage struct

+ func (s Storage) DeleteSabakanURL(ctx context.Context) error

+ func (s Storage) GetCACertificate(ctx context.Context, name string) (string, error)

+ func (s Storage) GetCluster(ctx context.Context) (*Cluster, error)

+ func (s Storage) GetClusterWithRevision(ctx context.Context) (*Cluster, int64, error)

+ func (s Storage) GetConstraints(ctx context.Context) (*Constraints, error)

+ func (s Storage) GetLeaderHostname(ctx context.Context) (string, error)

+ func (s Storage) GetRecords(ctx context.Context, count int64) ([]*Record, error)

+ func (s Storage) GetSabakanQueryVariables(ctx context.Context) ([]byte, error)

+ func (s Storage) GetSabakanTemplate(ctx context.Context) (*Cluster, int64, error)

+ func (s Storage) GetSabakanURL(ctx context.Context) (string, error)

+ func (s Storage) GetServiceAccountCert(ctx context.Context) (string, error)

+ func (s Storage) GetServiceAccountKey(ctx context.Context) (string, error)

+ func (s Storage) GetVaultConfig(ctx context.Context) (*VaultConfig, error)

+ func (s Storage) NextRecordID(ctx context.Context) (int64, error)

+ func (s Storage) PutCACertificate(ctx context.Context, name, pem string) error

+ func (s Storage) PutCluster(ctx context.Context, c *Cluster) error

+ func (s Storage) PutClusterWithTemplateRevision(ctx context.Context, c *Cluster, rev int64, leaderKey string) error

+ func (s Storage) PutConstraints(ctx context.Context, c *Constraints) error

+ func (s Storage) PutServiceAccountData(ctx context.Context, leaderKey, cert, key string) error

+ func (s Storage) PutVaultConfig(ctx context.Context, c *VaultConfig) error

+ func (s Storage) RegisterRecord(ctx context.Context, leaderKey string, r *Record) error

+ func (s Storage) SetSabakanQueryVariables(ctx context.Context, vars string) error

+ func (s Storage) SetSabakanTemplate(ctx context.Context, tmpl *Cluster) error

+ func (s Storage) SetSabakanURL(ctx context.Context, url string) error

+ func (s Storage) UpdateRecord(ctx context.Context, leaderKey string, r *Record) error

+ type VaultConfig struct

+ CACert string

+ Endpoint string

+ RoleID string

+ SecretID string

+ func (c *VaultConfig) Validate() error