federation

package
v1.5.5 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2017 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const GroupName = "federation"

GroupName is the group name use in this package

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = unversioned.GroupVersion{Group: GroupName, Version: runtime.APIVersionInternal}

SchemeGroupVersion is group version used to register these objects

Functions

func DeepCopy_federation_Cluster 

func DeepCopy_federation_Cluster(in interface{}, out interface{}, c *conversion.Cloner) error

func DeepCopy_federation_ClusterCondition 

func DeepCopy_federation_ClusterCondition(in interface{}, out interface{}, c *conversion.Cloner) error

func DeepCopy_federation_ClusterList 

func DeepCopy_federation_ClusterList(in interface{}, out interface{}, c *conversion.Cloner) error

func DeepCopy_federation_ClusterReplicaSetPreferences 

func DeepCopy_federation_ClusterReplicaSetPreferences(in interface{}, out interface{}, c *conversion.Cloner) error

func DeepCopy_federation_ClusterSpec 

func DeepCopy_federation_ClusterSpec(in interface{}, out interface{}, c *conversion.Cloner) error

func DeepCopy_federation_ClusterStatus 

func DeepCopy_federation_ClusterStatus(in interface{}, out interface{}, c *conversion.Cloner) error

func DeepCopy_federation_FederatedReplicaSetPreferences 

func DeepCopy_federation_FederatedReplicaSetPreferences(in interface{}, out interface{}, c *conversion.Cloner) error

func DeepCopy_federation_ServerAddressByClientCIDR 

func DeepCopy_federation_ServerAddressByClientCIDR(in interface{}, out interface{}, c *conversion.Cloner) error

func Kind 

func Kind(kind string) unversioned.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func RegisterDeepCopies 

func RegisterDeepCopies(scheme *runtime.Scheme) error

RegisterDeepCopies adds deep-copy functions to the given scheme. Public to allow building arbitrary schemes.

func Resource 

func Resource(resource string) unversioned.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type Cluster 

type Cluster struct {
	unversioned.TypeMeta `json:",inline"`
	// Standard object's metadata.
	// More info: http://releases.k8s.io/HEAD/docs/devel/api-conventions.md#metadata
	// +optional
	api.ObjectMeta `json:"metadata,omitempty"`

	// Spec defines the behavior of the Cluster.
	// +optional
	Spec ClusterSpec `json:"spec,omitempty"`
	// Status describes the current status of a Cluster
	// +optional
	Status ClusterStatus `json:"status,omitempty"`
}

Information about a registered cluster in a federated kubernetes setup. Clusters are not namespaced and have unique names in the federation.

func (*Cluster) CodecDecodeSelf 

func (x *Cluster) CodecDecodeSelf(d *codec1978.Decoder)

func (*Cluster) CodecEncodeSelf 

func (x *Cluster) CodecEncodeSelf(e *codec1978.Encoder)

func (*Cluster) GetObjectKind 

func (obj *Cluster) GetObjectKind() unversioned.ObjectKind

type ClusterCondition 

type ClusterCondition struct {
	// Type of cluster condition, Complete or Failed.
	Type ClusterConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status api.ConditionStatus `json:"status"`
	// Last time the condition was checked.
	// +optional
	LastProbeTime unversioned.Time `json:"lastProbeTime,omitempty"`
	// Last time the condition transit from one status to another.
	// +optional
	LastTransitionTime unversioned.Time `json:"lastTransitionTime,omitempty"`
	// (brief) reason for the condition's last transition.
	// +optional
	Reason string `json:"reason,omitempty"`
	// Human readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty"`
}

ClusterCondition describes current state of a cluster.

func (*ClusterCondition) CodecDecodeSelf 

func (x *ClusterCondition) CodecDecodeSelf(d *codec1978.Decoder)

func (*ClusterCondition) CodecEncodeSelf 

func (x *ClusterCondition) CodecEncodeSelf(e *codec1978.Encoder)

type ClusterConditionType 

type ClusterConditionType string
const (
	// ClusterReady means the cluster is ready to accept workloads.
	ClusterReady ClusterConditionType = "Ready"
	// ClusterOffline means the cluster is temporarily down or not reachable
	ClusterOffline ClusterConditionType = "Offline"
)

These are valid conditions of a cluster.

func (*ClusterConditionType) CodecDecodeSelf 

func (x *ClusterConditionType) CodecDecodeSelf(d *codec1978.Decoder)

func (ClusterConditionType) CodecEncodeSelf 

func (x ClusterConditionType) CodecEncodeSelf(e *codec1978.Encoder)

type ClusterList 

type ClusterList struct {
	unversioned.TypeMeta `json:",inline"`
	// Standard list metadata.
	// More info: http://releases.k8s.io/HEAD/docs/devel/api-conventions.md#types-kinds
	// +optional
	unversioned.ListMeta `json:"metadata,omitempty"`

	// List of Cluster objects.
	Items []Cluster `json:"items"`
}

A list of all the kubernetes clusters registered to the federation

func (*ClusterList) CodecDecodeSelf 

func (x *ClusterList) CodecDecodeSelf(d *codec1978.Decoder)

func (*ClusterList) CodecEncodeSelf 

func (x *ClusterList) CodecEncodeSelf(e *codec1978.Encoder)

func (*ClusterList) GetObjectKind 

func (obj *ClusterList) GetObjectKind() unversioned.ObjectKind

type ClusterReplicaSetPreferences 

type ClusterReplicaSetPreferences struct {
	// Minimum number of replicas that should be assigned to this Local ReplicaSet. 0 by default.
	// +optional
	MinReplicas int64 `json:"minReplicas,omitempty"`

	// Maximum number of replicas that should be assigned to this Local ReplicaSet. Unbounded if no value provided (default).
	// +optional
	MaxReplicas *int64 `json:"maxReplicas,omitempty"`

	// A number expressing the preference to put an additional replica to this LocalReplicaSet. 0 by default.
	Weight int64
}

Preferences regarding number of replicas assigned to a cluster replicaset within a federated replicaset.

func (*ClusterReplicaSetPreferences) CodecDecodeSelf 

func (x *ClusterReplicaSetPreferences) CodecDecodeSelf(d *codec1978.Decoder)

func (*ClusterReplicaSetPreferences) CodecEncodeSelf 

func (x *ClusterReplicaSetPreferences) CodecEncodeSelf(e *codec1978.Encoder)

type ClusterSpec 

type ClusterSpec struct {
	// A map of client CIDR to server address.
	// This is to help clients reach servers in the most network-efficient way possible.
	// Clients can use the appropriate server address as per the CIDR that they match.
	// In case of multiple matches, clients should use the longest matching CIDR.
	ServerAddressByClientCIDRs []ServerAddressByClientCIDR `json:"serverAddressByClientCIDRs" patchStrategy:"merge" patchMergeKey:"clientCIDR"`
	// Name of the secret containing kubeconfig to access this cluster.
	// The secret is read from the kubernetes cluster that is hosting federation control plane.
	// Admin needs to ensure that the required secret exists. Secret should be in the same namespace where federation control plane is hosted and it should have kubeconfig in its data with key "kubeconfig".
	// This will later be changed to a reference to secret in federation control plane when the federation control plane supports secrets.
	// This can be left empty if the cluster allows insecure access.
	// +optional
	SecretRef *api.LocalObjectReference `json:"secretRef,omitempty"`
}

ClusterSpec describes the attributes of a kubernetes cluster.

func (*ClusterSpec) CodecDecodeSelf 

func (x *ClusterSpec) CodecDecodeSelf(d *codec1978.Decoder)

func (*ClusterSpec) CodecEncodeSelf 

func (x *ClusterSpec) CodecEncodeSelf(e *codec1978.Encoder)

type ClusterStatus 

type ClusterStatus struct {
	// Conditions is an array of current cluster conditions.
	// +optional
	Conditions []ClusterCondition `json:"conditions,omitempty"`
	// Zones is the list of availability zones in which the nodes of the cluster exist, e.g. 'us-east1-a'.
	// These will always be in the same region.
	// +optional
	Zones []string `json:"zones,omitempty"`
	// Region is the name of the region in which all of the nodes in the cluster exist.  e.g. 'us-east1'.
	// +optional
	Region string `json:"region,omitempty"`
}

ClusterStatus is information about the current status of a cluster updated by cluster controller peridocally.

func (*ClusterStatus) CodecDecodeSelf 

func (x *ClusterStatus) CodecDecodeSelf(d *codec1978.Decoder)

func (*ClusterStatus) CodecEncodeSelf 

func (x *ClusterStatus) CodecEncodeSelf(e *codec1978.Encoder)

type FederatedReplicaSetPreferences 

type FederatedReplicaSetPreferences struct {
	// If set to true then already scheduled and running replicas may be moved to other clusters to
	// in order to bring cluster replicasets towards a desired state. Otherwise, if set to false,
	// up and running replicas will not be moved.
	// +optional
	Rebalance bool `json:"rebalance,omitempty"`

	// A mapping between cluster names and preferences regarding local ReplicaSet in these clusters.
	// "*" (if provided) applies to all clusters if an explicit mapping is not provided. If there is no
	// "*" that clusters without explicit preferences should not have any replicas scheduled.
	// +optional
	Clusters map[string]ClusterReplicaSetPreferences `json:"clusters,omitempty"`
}

A set of preferences that can be added to federated version of ReplicaSet as a json-serialized annotation. The preferences allow the user to express in which culsters he wants to put his replicas within the mentiond FederatedReplicaSet.

func (*FederatedReplicaSetPreferences) CodecDecodeSelf 

func (x *FederatedReplicaSetPreferences) CodecDecodeSelf(d *codec1978.Decoder)

func (*FederatedReplicaSetPreferences) CodecEncodeSelf 

func (x *FederatedReplicaSetPreferences) CodecEncodeSelf(e *codec1978.Encoder)

type ServerAddressByClientCIDR 

type ServerAddressByClientCIDR struct {
	// The CIDR with which clients can match their IP to figure out the server address that they should use.
	ClientCIDR string `json:"clientCIDR" protobuf:"bytes,1,opt,name=clientCIDR"`
	// Address of this server, suitable for a client that matches the above CIDR.
	// This can be a hostname, hostname:port, IP or IP:port.
	ServerAddress string `json:"serverAddress" protobuf:"bytes,2,opt,name=serverAddress"`
}

ServerAddressByClientCIDR helps the client to determine the server address that they should use, depending on the clientCIDR that they match.

func (*ServerAddressByClientCIDR) CodecDecodeSelf 

func (x *ServerAddressByClientCIDR) CodecDecodeSelf(d *codec1978.Decoder)

func (*ServerAddressByClientCIDR) CodecEncodeSelf 

func (x *ServerAddressByClientCIDR) CodecEncodeSelf(e *codec1978.Encoder)

Source Files

View all Source files

Directories

Path Synopsis
+k8s:deepcopy-gen=package,register +k8s:conversion-gen=k8s.io/kubernetes/federation/apis/federation +k8s:openapi-gen=true +k8s:defaulter-gen=TypeMeta Package v1beta1 is a generated protocol buffer package.
 +k8s:deepcopy-gen=package,register +k8s:conversion-gen=k8s.io/kubernetes/federation/apis/federation +k8s:openapi-gen=true +k8s:defaulter-gen=TypeMeta Package v1beta1 is a generated protocol buffer package.

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.