k8s

package
v0.13.0-beta.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 8, 2021 License: MPL-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package k8s provides resources which interface with Kubernetes.

Index

Constants

View Source 
const ControlPlaneEndpointsID = resource.ID("controlplane")

ControlPlaneEndpointsID is resource ID for controlplane Endpoint.

View Source 
const ControlPlaneNamespaceName resource.Namespace = "controlplane"

ControlPlaneNamespaceName contains resources supporting Kubernetes control plane.

View Source 
const EndpointType = resource.Type("Endpoints.kubernetes.talos.dev")

EndpointType is type of Endpoint resource.

View Source 
const ManifestStatusID = resource.ID("manifests")

ManifestStatusID is a singleton resource ID.

View Source 
const ManifestStatusType = resource.Type("ManifestStatuses.kubernetes.talos.dev")

ManifestStatusType is type of ManifestStatus resource.

View Source 
const ManifestType = resource.Type("Manifests.kubernetes.talos.dev")

ManifestType is type of Manifest resource.

View Source 
const NodeAddressFilterNoK8s = "no-k8s"

NodeAddressFilterNoK8s is the ID for the node address filter which removes any Kubernetes IPs.

View Source 
const NodeAddressFilterOnlyK8s = "only-k8s"

NodeAddressFilterOnlyK8s is the ID for the node address filter which leaves only Kubernetes IPs.

View Source 
const NodenameID = resource.ID("nodename")

NodenameID is a singleton resource ID for Nodename.

View Source 
const NodenameType = resource.Type("Nodenames.kubernetes.talos.dev")

NodenameType is type of Nodename resource.

View Source 
const SecretsStatusType = resource.Type("SecretStatuses.kubernetes.talos.dev")

SecretsStatusType is type of SecretsStatus resource.

View Source 
const StaticPodSecretsStaticPodID = resource.ID("static-pods")

StaticPodSecretsStaticPodID is resource ID for SecretStatus resource for static pods.

View Source 
const StaticPodStatusType = resource.Type("StaticPodStatuses.kubernetes.talos.dev")

StaticPodStatusType is type of StaticPodStatus resource.

View Source 
const StaticPodType = resource.Type("StaticPods.kubernetes.talos.dev")

StaticPodType is type of StaticPod resource.

Variables

This section is empty.

Functions

This section is empty.

Types

type Endpoint added in v0.11.0 

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

Endpoint resource holds definition of rendered secrets.

func NewEndpoint added in v0.11.0 

func NewEndpoint(namespace resource.Namespace, id resource.ID) *Endpoint

NewEndpoint initializes a Endpoint resource.

func (*Endpoint) DeepCopy added in v0.11.0 

func (r *Endpoint) DeepCopy() resource.Resource

DeepCopy implements resource.Resource.

func (*Endpoint) Metadata added in v0.11.0 

func (r *Endpoint) Metadata() *resource.Metadata

Metadata implements resource.Resource.

func (*Endpoint) ResourceDefinition added in v0.11.0 

func (r *Endpoint) ResourceDefinition() meta.ResourceDefinitionSpec

ResourceDefinition implements meta.ResourceDefinitionProvider interface.

func (*Endpoint) Spec added in v0.11.0 

func (r *Endpoint) Spec() interface{}

Spec implements resource.Resource.

func (*Endpoint) String added in v0.11.0 

func (r *Endpoint) String() string

func (*Endpoint) TypedSpec added in v0.11.0 

func (r *Endpoint) TypedSpec() *EndpointSpec

TypedSpec allows to access the Spec with the proper type.

type EndpointSpec added in v0.11.0 

type EndpointSpec struct {
	Addresses []netaddr.IP `yaml:"addresses"`
}

EndpointSpec describes status of rendered secrets.

type Manifest 

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

Manifest resource holds definition of kubelet static pod.

func NewManifest 

func NewManifest(namespace resource.Namespace, id resource.ID) *Manifest

NewManifest initializes an empty Manifest resource.

func (*Manifest) DeepCopy 

func (r *Manifest) DeepCopy() resource.Resource

DeepCopy implements resource.Resource.

func (*Manifest) Metadata 

func (r *Manifest) Metadata() *resource.Metadata

Metadata implements resource.Resource.

func (*Manifest) Objects 

func (r *Manifest) Objects() []*unstructured.Unstructured

Objects returns list of unstrustured object.

func (*Manifest) ResourceDefinition 

func (r *Manifest) ResourceDefinition() meta.ResourceDefinitionSpec

ResourceDefinition implements meta.ResourceDefinitionProvider interface.

func (*Manifest) SetYAML 

func (r *Manifest) SetYAML(yamlBytes []byte) error

SetYAML parses manifest from YAML.

func (*Manifest) Spec 

func (r *Manifest) Spec() interface{}

Spec implements resource.Resource.

func (*Manifest) String 

func (r *Manifest) String() string

type ManifestStatus 

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

ManifestStatus resource holds definition of kubelet static pod.

func NewManifestStatus 

func NewManifestStatus(namespace resource.Namespace) *ManifestStatus

NewManifestStatus initializes an empty ManifestStatus resource.

func (*ManifestStatus) DeepCopy 

func (r *ManifestStatus) DeepCopy() resource.Resource

DeepCopy implements resource.Resource.

func (*ManifestStatus) Metadata 

func (r *ManifestStatus) Metadata() *resource.Metadata

Metadata implements resource.Resource.

func (*ManifestStatus) ResourceDefinition 

func (r *ManifestStatus) ResourceDefinition() meta.ResourceDefinitionSpec

ResourceDefinition implements meta.ResourceDefinitionProvider interface.

func (*ManifestStatus) Spec 

func (r *ManifestStatus) Spec() interface{}

Spec implements resource.Resource.

func (*ManifestStatus) String 

func (r *ManifestStatus) String() string

func (*ManifestStatus) TypedSpec added in v0.11.0 

func (r *ManifestStatus) TypedSpec() *ManifestStatusSpec

TypedSpec returns ManifestStatusSpec.

type ManifestStatusSpec 

type ManifestStatusSpec struct {
	ManifestsApplied []string `yaml:"manifestsApplied"`
}

ManifestStatusSpec describes manifest application status.

type Nodename added in v0.11.0 

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

Nodename resource holds Kubernetes nodename.

func NewNodename added in v0.11.0 

func NewNodename(namespace resource.Namespace, id resource.ID) *Nodename

NewNodename initializes a Nodename resource.

func (*Nodename) DeepCopy added in v0.11.0 

func (r *Nodename) DeepCopy() resource.Resource

DeepCopy implements resource.Resource.

func (*Nodename) Metadata added in v0.11.0 

func (r *Nodename) Metadata() *resource.Metadata

Metadata implements resource.Resource.

func (*Nodename) ResourceDefinition added in v0.11.0 

func (r *Nodename) ResourceDefinition() meta.ResourceDefinitionSpec

ResourceDefinition implements meta.ResourceDefinitionProvider interface.

func (*Nodename) Spec added in v0.11.0 

func (r *Nodename) Spec() interface{}

Spec implements resource.Resource.

func (*Nodename) String added in v0.11.0 

func (r *Nodename) String() string

func (*Nodename) TypedSpec added in v0.11.0 

func (r *Nodename) TypedSpec() *NodenameSpec

TypedSpec allows to access the Spec with the proper type.

type NodenameReadyCondition added in v0.11.0 

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

NodenameReadyCondition implements condition which waits for the nodename to be ready.

func NewNodenameReadyCondition added in v0.11.0 

func NewNodenameReadyCondition(state state.State) *NodenameReadyCondition

NewNodenameReadyCondition builds a coondition which waits for the network to be ready.

func (*NodenameReadyCondition) String added in v0.11.0 

func (condition *NodenameReadyCondition) String() string

func (*NodenameReadyCondition) Wait added in v0.11.0 

func (condition *NodenameReadyCondition) Wait(ctx context.Context) error

Wait implements condition interface.

type NodenameSpec added in v0.11.0 

type NodenameSpec struct {
	Nodename        string `yaml:"nodename"`
	HostnameVersion string `yaml:"hostnameVersion"`
}

NodenameSpec describes Kubernetes nodename.

type SecretsStatus 

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

SecretsStatus resource holds definition of rendered secrets.

func NewSecretsStatus 

func NewSecretsStatus(namespace resource.Namespace, id resource.ID) *SecretsStatus

NewSecretsStatus initializes a SecretsStatus resource.

func (*SecretsStatus) DeepCopy 

func (r *SecretsStatus) DeepCopy() resource.Resource

DeepCopy implements resource.Resource.

func (*SecretsStatus) Metadata 

func (r *SecretsStatus) Metadata() *resource.Metadata

Metadata implements resource.Resource.

func (*SecretsStatus) ResourceDefinition 

func (r *SecretsStatus) ResourceDefinition() meta.ResourceDefinitionSpec

ResourceDefinition implements meta.ResourceDefinitionProvider interface.

func (*SecretsStatus) Spec 

func (r *SecretsStatus) Spec() interface{}

Spec implements resource.Resource.

func (*SecretsStatus) String 

func (r *SecretsStatus) String() string

func (*SecretsStatus) TypedSpec added in v0.11.0 

func (r *SecretsStatus) TypedSpec() *SecretsStatusSpec

TypedSpec allows to access the Spec with the proper type.

type SecretsStatusSpec 

type SecretsStatusSpec struct {
	Ready   bool   `yaml:"ready"`
	Version string `yaml:"version"`
}

SecretsStatusSpec describes status of rendered secrets.

type StaticPod 

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

StaticPod resource holds definition of kubelet static pod.

func NewStaticPod 

func NewStaticPod(namespace resource.Namespace, id resource.ID, spec *v1.Pod) *StaticPod

NewStaticPod initializes a StaticPod resource.

func (*StaticPod) DeepCopy 

func (r *StaticPod) DeepCopy() resource.Resource

DeepCopy implements resource.Resource.

func (*StaticPod) Metadata 

func (r *StaticPod) Metadata() *resource.Metadata

Metadata implements resource.Resource.

func (*StaticPod) Pod 

func (r *StaticPod) Pod() *v1.Pod

Pod returns pod definition.

func (*StaticPod) ResourceDefinition 

func (r *StaticPod) ResourceDefinition() meta.ResourceDefinitionSpec

ResourceDefinition implements meta.ResourceDefinitionProvider interface.

func (*StaticPod) SetPod 

func (r *StaticPod) SetPod(podSpec *v1.Pod)

SetPod sets pod definition.

func (*StaticPod) Spec 

func (r *StaticPod) Spec() interface{}

Spec implements resource.Resource.

func (*StaticPod) String 

func (r *StaticPod) String() string

type StaticPodStatus 

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

StaticPodStatus resource holds definition of kubelet static pod.

func NewStaticPodStatus 

func NewStaticPodStatus(namespace resource.Namespace, id resource.ID) *StaticPodStatus

NewStaticPodStatus initializes a StaticPodStatus resource.

func (*StaticPodStatus) DeepCopy 

func (r *StaticPodStatus) DeepCopy() resource.Resource

DeepCopy implements resource.Resource.

func (*StaticPodStatus) Metadata 

func (r *StaticPodStatus) Metadata() *resource.Metadata

Metadata implements resource.Resource.

func (*StaticPodStatus) ResourceDefinition 

func (r *StaticPodStatus) ResourceDefinition() meta.ResourceDefinitionSpec

ResourceDefinition implements meta.ResourceDefinitionProvider interface.

func (*StaticPodStatus) SetStatus 

func (r *StaticPodStatus) SetStatus(status *v1.PodStatus)

SetStatus sets pod status.

func (*StaticPodStatus) Spec 

func (r *StaticPodStatus) Spec() interface{}

Spec implements resource.Resource.

func (*StaticPodStatus) Status added in v0.11.0 

func (r *StaticPodStatus) Status() *v1.PodStatus

Status gets pod status.

func (*StaticPodStatus) String 

func (r *StaticPodStatus) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.