Documentation
¶
Index ¶
- type KubeWrapper
- func (k *KubeWrapper) GetKubeconfig() ([]byte, error)
- func (k *KubeWrapper) InitCluster(ctx context.Context, cloudServiceAccountURI, versionString string, ...) ([]byte, error)
- func (k *KubeWrapper) JoinCluster(ctx context.Context, args *kubeadm.BootstrapTokenDiscovery, peerRole role.Role, ...) error
- func (k *KubeWrapper) StartKubelet(log *logger.Logger) error
- type KubeconfigReader
- type ProviderMetadata
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KubeWrapper ¶
type KubeWrapper struct {
// contains filtered or unexported fields
}
KubeWrapper implements Cluster interface.
func New ¶
func New(cloudProvider string, clusterUtil clusterUtil, configProvider configurationProvider, client k8sapi.Client, providerMetadata ProviderMetadata, measurements measurements.M, helmClient helmClient, kubeAPIWaiter kubeAPIWaiter, ) *KubeWrapper
New creates a new KubeWrapper with real values.
func (*KubeWrapper) GetKubeconfig ¶
func (k *KubeWrapper) GetKubeconfig() ([]byte, error)
GetKubeconfig returns the current nodes kubeconfig of stored on disk.
func (*KubeWrapper) InitCluster ¶
func (k *KubeWrapper) InitCluster( ctx context.Context, cloudServiceAccountURI, versionString string, measurementSalt []byte, enforcedPCRs []uint32, enforceIDKeyDigest bool, idKeyDigest []byte, azureCVM bool, helmReleasesRaw []byte, conformanceMode bool, kubernetesComponents versions.ComponentVersions, log *logger.Logger, ) ([]byte, error)
InitCluster initializes a new Kubernetes cluster and applies pod network provider.
func (*KubeWrapper) JoinCluster ¶
func (k *KubeWrapper) JoinCluster(ctx context.Context, args *kubeadm.BootstrapTokenDiscovery, peerRole role.Role, versionString string, k8sComponents versions.ComponentVersions, log *logger.Logger) error
JoinCluster joins existing Kubernetes cluster.
func (*KubeWrapper) StartKubelet ¶
func (k *KubeWrapper) StartKubelet(log *logger.Logger) error
StartKubelet starts the kubelet service.
type KubeconfigReader ¶
type KubeconfigReader struct {
// contains filtered or unexported fields
}
KubeconfigReader implements ConfigReader.
func (KubeconfigReader) ReadKubeconfig ¶
func (r KubeconfigReader) ReadKubeconfig() ([]byte, error)
ReadKubeconfig reads the Kubeconfig from disk.
type ProviderMetadata ¶
type ProviderMetadata interface {
// UID returns the unique identifier for the constellation.
UID(ctx context.Context) (string, error)
// Self retrieves the current instance.
Self(ctx context.Context) (metadata.InstanceMetadata, error)
// GetLoadBalancerEndpoint retrieves the load balancer endpoint.
GetLoadBalancerEndpoint(ctx context.Context) (string, error)
}
ProviderMetadata implementers read/write cloud provider metadata.
Click to show internal directories.
Click to hide internal directories.