v1alpha1

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: May 8, 2018 License: Apache-2.0 Imports: 14 Imported by: 70

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API. +groupName=navigator.jetstack.io

Index

Constants

View Source 
const (
	ElasticsearchClusterNameLabel          = "navigator.jetstack.io/elasticsearch-cluster-name"
	ElasticsearchNodePoolNameLabel         = "navigator.jetstack.io/elasticsearch-node-pool-name"
	ElasticsearchNodePoolVersionAnnotation = "navigator.jetstack.io/elasticsearch-version"
	ElasticsearchRoleLabelPrefix           = "navigator.jetstack.io/elasticsearch-role-"

	CassandraClusterNameLabel  = "navigator.jetstack.io/cassandra-cluster-name"
	CassandraNodePoolNameLabel = "navigator.jetstack.io/cassandra-node-pool-name"
)

Variables

View Source 
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: navigator.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Convert_navigator_CassandraClusterList_To_v1alpha1_CassandraClusterList 

func Convert_navigator_CassandraClusterList_To_v1alpha1_CassandraClusterList(in *navigator.CassandraClusterList, out *CassandraClusterList, s conversion.Scope) error

Convert_navigator_CassandraClusterList_To_v1alpha1_CassandraClusterList is an autogenerated conversion function.

func Convert_navigator_CassandraClusterNodePoolStatus_To_v1alpha1_CassandraClusterNodePoolStatus 

func Convert_navigator_CassandraClusterNodePoolStatus_To_v1alpha1_CassandraClusterNodePoolStatus(in *navigator.CassandraClusterNodePoolStatus, out *CassandraClusterNodePoolStatus, s conversion.Scope) error

Convert_navigator_CassandraClusterNodePoolStatus_To_v1alpha1_CassandraClusterNodePoolStatus is an autogenerated conversion function.

func Convert_navigator_CassandraClusterNodePool_To_v1alpha1_CassandraClusterNodePool 

func Convert_navigator_CassandraClusterNodePool_To_v1alpha1_CassandraClusterNodePool(in *navigator.CassandraClusterNodePool, out *CassandraClusterNodePool, s conversion.Scope) error

Convert_navigator_CassandraClusterNodePool_To_v1alpha1_CassandraClusterNodePool is an autogenerated conversion function.

func Convert_navigator_CassandraClusterSpec_To_v1alpha1_CassandraClusterSpec 

func Convert_navigator_CassandraClusterSpec_To_v1alpha1_CassandraClusterSpec(in *navigator.CassandraClusterSpec, out *CassandraClusterSpec, s conversion.Scope) error

Convert_navigator_CassandraClusterSpec_To_v1alpha1_CassandraClusterSpec is an autogenerated conversion function.

func Convert_navigator_CassandraClusterStatus_To_v1alpha1_CassandraClusterStatus 

func Convert_navigator_CassandraClusterStatus_To_v1alpha1_CassandraClusterStatus(in *navigator.CassandraClusterStatus, out *CassandraClusterStatus, s conversion.Scope) error

Convert_navigator_CassandraClusterStatus_To_v1alpha1_CassandraClusterStatus is an autogenerated conversion function.

func Convert_navigator_CassandraCluster_To_v1alpha1_CassandraCluster 

func Convert_navigator_CassandraCluster_To_v1alpha1_CassandraCluster(in *navigator.CassandraCluster, out *CassandraCluster, s conversion.Scope) error

Convert_navigator_CassandraCluster_To_v1alpha1_CassandraCluster is an autogenerated conversion function.

func Convert_navigator_CassandraPilotStatus_To_v1alpha1_CassandraPilotStatus 

func Convert_navigator_CassandraPilotStatus_To_v1alpha1_CassandraPilotStatus(in *navigator.CassandraPilotStatus, out *CassandraPilotStatus, s conversion.Scope) error

Convert_navigator_CassandraPilotStatus_To_v1alpha1_CassandraPilotStatus is an autogenerated conversion function.

func Convert_navigator_ElasticsearchClusterList_To_v1alpha1_ElasticsearchClusterList 

func Convert_navigator_ElasticsearchClusterList_To_v1alpha1_ElasticsearchClusterList(in *navigator.ElasticsearchClusterList, out *ElasticsearchClusterList, s conversion.Scope) error

Convert_navigator_ElasticsearchClusterList_To_v1alpha1_ElasticsearchClusterList is an autogenerated conversion function.

func Convert_navigator_ElasticsearchClusterNodePoolStatus_To_v1alpha1_ElasticsearchClusterNodePoolStatus 

func Convert_navigator_ElasticsearchClusterNodePoolStatus_To_v1alpha1_ElasticsearchClusterNodePoolStatus(in *navigator.ElasticsearchClusterNodePoolStatus, out *ElasticsearchClusterNodePoolStatus, s conversion.Scope) error

Convert_navigator_ElasticsearchClusterNodePoolStatus_To_v1alpha1_ElasticsearchClusterNodePoolStatus is an autogenerated conversion function.

func Convert_navigator_ElasticsearchClusterNodePool_To_v1alpha1_ElasticsearchClusterNodePool 

func Convert_navigator_ElasticsearchClusterNodePool_To_v1alpha1_ElasticsearchClusterNodePool(in *navigator.ElasticsearchClusterNodePool, out *ElasticsearchClusterNodePool, s conversion.Scope) error

Convert_navigator_ElasticsearchClusterNodePool_To_v1alpha1_ElasticsearchClusterNodePool is an autogenerated conversion function.

func Convert_navigator_ElasticsearchClusterSpec_To_v1alpha1_ElasticsearchClusterSpec 

func Convert_navigator_ElasticsearchClusterSpec_To_v1alpha1_ElasticsearchClusterSpec(in *navigator.ElasticsearchClusterSpec, out *ElasticsearchClusterSpec, s conversion.Scope) error

Convert_navigator_ElasticsearchClusterSpec_To_v1alpha1_ElasticsearchClusterSpec is an autogenerated conversion function.

func Convert_navigator_ElasticsearchClusterStatus_To_v1alpha1_ElasticsearchClusterStatus 

func Convert_navigator_ElasticsearchClusterStatus_To_v1alpha1_ElasticsearchClusterStatus(in *navigator.ElasticsearchClusterStatus, out *ElasticsearchClusterStatus, s conversion.Scope) error

Convert_navigator_ElasticsearchClusterStatus_To_v1alpha1_ElasticsearchClusterStatus is an autogenerated conversion function.

func Convert_navigator_ElasticsearchCluster_To_v1alpha1_ElasticsearchCluster 

func Convert_navigator_ElasticsearchCluster_To_v1alpha1_ElasticsearchCluster(in *navigator.ElasticsearchCluster, out *ElasticsearchCluster, s conversion.Scope) error

Convert_navigator_ElasticsearchCluster_To_v1alpha1_ElasticsearchCluster is an autogenerated conversion function.

func Convert_navigator_ElasticsearchPilotStatus_To_v1alpha1_ElasticsearchPilotStatus 

func Convert_navigator_ElasticsearchPilotStatus_To_v1alpha1_ElasticsearchPilotStatus(in *navigator.ElasticsearchPilotStatus, out *ElasticsearchPilotStatus, s conversion.Scope) error

Convert_navigator_ElasticsearchPilotStatus_To_v1alpha1_ElasticsearchPilotStatus is an autogenerated conversion function.

func Convert_navigator_ImageSpec_To_v1alpha1_ImageSpec 

func Convert_navigator_ImageSpec_To_v1alpha1_ImageSpec(in *navigator.ImageSpec, out *ImageSpec, s conversion.Scope) error

Convert_navigator_ImageSpec_To_v1alpha1_ImageSpec is an autogenerated conversion function.

func Convert_navigator_NavigatorClusterConfig_To_v1alpha1_NavigatorClusterConfig 

func Convert_navigator_NavigatorClusterConfig_To_v1alpha1_NavigatorClusterConfig(in *navigator.NavigatorClusterConfig, out *NavigatorClusterConfig, s conversion.Scope) error

Convert_navigator_NavigatorClusterConfig_To_v1alpha1_NavigatorClusterConfig is an autogenerated conversion function.

func Convert_navigator_NavigatorSecurityContext_To_v1alpha1_NavigatorSecurityContext 

func Convert_navigator_NavigatorSecurityContext_To_v1alpha1_NavigatorSecurityContext(in *navigator.NavigatorSecurityContext, out *NavigatorSecurityContext, s conversion.Scope) error

Convert_navigator_NavigatorSecurityContext_To_v1alpha1_NavigatorSecurityContext is an autogenerated conversion function.

func Convert_navigator_PersistenceConfig_To_v1alpha1_PersistenceConfig 

func Convert_navigator_PersistenceConfig_To_v1alpha1_PersistenceConfig(in *navigator.PersistenceConfig, out *PersistenceConfig, s conversion.Scope) error

Convert_navigator_PersistenceConfig_To_v1alpha1_PersistenceConfig is an autogenerated conversion function.

func Convert_navigator_PilotCondition_To_v1alpha1_PilotCondition 

func Convert_navigator_PilotCondition_To_v1alpha1_PilotCondition(in *navigator.PilotCondition, out *PilotCondition, s conversion.Scope) error

Convert_navigator_PilotCondition_To_v1alpha1_PilotCondition is an autogenerated conversion function.

func Convert_navigator_PilotList_To_v1alpha1_PilotList 

func Convert_navigator_PilotList_To_v1alpha1_PilotList(in *navigator.PilotList, out *PilotList, s conversion.Scope) error

Convert_navigator_PilotList_To_v1alpha1_PilotList is an autogenerated conversion function.

func Convert_navigator_PilotSpec_To_v1alpha1_PilotSpec 

func Convert_navigator_PilotSpec_To_v1alpha1_PilotSpec(in *navigator.PilotSpec, out *PilotSpec, s conversion.Scope) error

Convert_navigator_PilotSpec_To_v1alpha1_PilotSpec is an autogenerated conversion function.

func Convert_navigator_PilotStatus_To_v1alpha1_PilotStatus 

func Convert_navigator_PilotStatus_To_v1alpha1_PilotStatus(in *navigator.PilotStatus, out *PilotStatus, s conversion.Scope) error

Convert_navigator_PilotStatus_To_v1alpha1_PilotStatus is an autogenerated conversion function.

func Convert_navigator_Pilot_To_v1alpha1_Pilot 

func Convert_navigator_Pilot_To_v1alpha1_Pilot(in *navigator.Pilot, out *Pilot, s conversion.Scope) error

Convert_navigator_Pilot_To_v1alpha1_Pilot is an autogenerated conversion function.

func Convert_v1alpha1_CassandraClusterList_To_navigator_CassandraClusterList 

func Convert_v1alpha1_CassandraClusterList_To_navigator_CassandraClusterList(in *CassandraClusterList, out *navigator.CassandraClusterList, s conversion.Scope) error

Convert_v1alpha1_CassandraClusterList_To_navigator_CassandraClusterList is an autogenerated conversion function.

func Convert_v1alpha1_CassandraClusterNodePoolStatus_To_navigator_CassandraClusterNodePoolStatus 

func Convert_v1alpha1_CassandraClusterNodePoolStatus_To_navigator_CassandraClusterNodePoolStatus(in *CassandraClusterNodePoolStatus, out *navigator.CassandraClusterNodePoolStatus, s conversion.Scope) error

Convert_v1alpha1_CassandraClusterNodePoolStatus_To_navigator_CassandraClusterNodePoolStatus is an autogenerated conversion function.

func Convert_v1alpha1_CassandraClusterNodePool_To_navigator_CassandraClusterNodePool 

func Convert_v1alpha1_CassandraClusterNodePool_To_navigator_CassandraClusterNodePool(in *CassandraClusterNodePool, out *navigator.CassandraClusterNodePool, s conversion.Scope) error

Convert_v1alpha1_CassandraClusterNodePool_To_navigator_CassandraClusterNodePool is an autogenerated conversion function.

func Convert_v1alpha1_CassandraClusterSpec_To_navigator_CassandraClusterSpec 

func Convert_v1alpha1_CassandraClusterSpec_To_navigator_CassandraClusterSpec(in *CassandraClusterSpec, out *navigator.CassandraClusterSpec, s conversion.Scope) error

Convert_v1alpha1_CassandraClusterSpec_To_navigator_CassandraClusterSpec is an autogenerated conversion function.

func Convert_v1alpha1_CassandraClusterStatus_To_navigator_CassandraClusterStatus 

func Convert_v1alpha1_CassandraClusterStatus_To_navigator_CassandraClusterStatus(in *CassandraClusterStatus, out *navigator.CassandraClusterStatus, s conversion.Scope) error

Convert_v1alpha1_CassandraClusterStatus_To_navigator_CassandraClusterStatus is an autogenerated conversion function.

func Convert_v1alpha1_CassandraCluster_To_navigator_CassandraCluster 

func Convert_v1alpha1_CassandraCluster_To_navigator_CassandraCluster(in *CassandraCluster, out *navigator.CassandraCluster, s conversion.Scope) error

Convert_v1alpha1_CassandraCluster_To_navigator_CassandraCluster is an autogenerated conversion function.

func Convert_v1alpha1_CassandraPilotStatus_To_navigator_CassandraPilotStatus 

func Convert_v1alpha1_CassandraPilotStatus_To_navigator_CassandraPilotStatus(in *CassandraPilotStatus, out *navigator.CassandraPilotStatus, s conversion.Scope) error

Convert_v1alpha1_CassandraPilotStatus_To_navigator_CassandraPilotStatus is an autogenerated conversion function.

func Convert_v1alpha1_ElasticsearchClusterList_To_navigator_ElasticsearchClusterList 

func Convert_v1alpha1_ElasticsearchClusterList_To_navigator_ElasticsearchClusterList(in *ElasticsearchClusterList, out *navigator.ElasticsearchClusterList, s conversion.Scope) error

Convert_v1alpha1_ElasticsearchClusterList_To_navigator_ElasticsearchClusterList is an autogenerated conversion function.

func Convert_v1alpha1_ElasticsearchClusterNodePoolStatus_To_navigator_ElasticsearchClusterNodePoolStatus 

func Convert_v1alpha1_ElasticsearchClusterNodePoolStatus_To_navigator_ElasticsearchClusterNodePoolStatus(in *ElasticsearchClusterNodePoolStatus, out *navigator.ElasticsearchClusterNodePoolStatus, s conversion.Scope) error

Convert_v1alpha1_ElasticsearchClusterNodePoolStatus_To_navigator_ElasticsearchClusterNodePoolStatus is an autogenerated conversion function.

func Convert_v1alpha1_ElasticsearchClusterNodePool_To_navigator_ElasticsearchClusterNodePool 

func Convert_v1alpha1_ElasticsearchClusterNodePool_To_navigator_ElasticsearchClusterNodePool(in *ElasticsearchClusterNodePool, out *navigator.ElasticsearchClusterNodePool, s conversion.Scope) error

Convert_v1alpha1_ElasticsearchClusterNodePool_To_navigator_ElasticsearchClusterNodePool is an autogenerated conversion function.

func Convert_v1alpha1_ElasticsearchClusterSpec_To_navigator_ElasticsearchClusterSpec 

func Convert_v1alpha1_ElasticsearchClusterSpec_To_navigator_ElasticsearchClusterSpec(in *ElasticsearchClusterSpec, out *navigator.ElasticsearchClusterSpec, s conversion.Scope) error

Convert_v1alpha1_ElasticsearchClusterSpec_To_navigator_ElasticsearchClusterSpec is an autogenerated conversion function.

func Convert_v1alpha1_ElasticsearchClusterStatus_To_navigator_ElasticsearchClusterStatus 

func Convert_v1alpha1_ElasticsearchClusterStatus_To_navigator_ElasticsearchClusterStatus(in *ElasticsearchClusterStatus, out *navigator.ElasticsearchClusterStatus, s conversion.Scope) error

Convert_v1alpha1_ElasticsearchClusterStatus_To_navigator_ElasticsearchClusterStatus is an autogenerated conversion function.

func Convert_v1alpha1_ElasticsearchCluster_To_navigator_ElasticsearchCluster 

func Convert_v1alpha1_ElasticsearchCluster_To_navigator_ElasticsearchCluster(in *ElasticsearchCluster, out *navigator.ElasticsearchCluster, s conversion.Scope) error

Convert_v1alpha1_ElasticsearchCluster_To_navigator_ElasticsearchCluster is an autogenerated conversion function.

func Convert_v1alpha1_ElasticsearchPilotStatus_To_navigator_ElasticsearchPilotStatus 

func Convert_v1alpha1_ElasticsearchPilotStatus_To_navigator_ElasticsearchPilotStatus(in *ElasticsearchPilotStatus, out *navigator.ElasticsearchPilotStatus, s conversion.Scope) error

Convert_v1alpha1_ElasticsearchPilotStatus_To_navigator_ElasticsearchPilotStatus is an autogenerated conversion function.

func Convert_v1alpha1_ImageSpec_To_navigator_ImageSpec 

func Convert_v1alpha1_ImageSpec_To_navigator_ImageSpec(in *ImageSpec, out *navigator.ImageSpec, s conversion.Scope) error

Convert_v1alpha1_ImageSpec_To_navigator_ImageSpec is an autogenerated conversion function.

func Convert_v1alpha1_NavigatorClusterConfig_To_navigator_NavigatorClusterConfig 

func Convert_v1alpha1_NavigatorClusterConfig_To_navigator_NavigatorClusterConfig(in *NavigatorClusterConfig, out *navigator.NavigatorClusterConfig, s conversion.Scope) error

Convert_v1alpha1_NavigatorClusterConfig_To_navigator_NavigatorClusterConfig is an autogenerated conversion function.

func Convert_v1alpha1_NavigatorSecurityContext_To_navigator_NavigatorSecurityContext 

func Convert_v1alpha1_NavigatorSecurityContext_To_navigator_NavigatorSecurityContext(in *NavigatorSecurityContext, out *navigator.NavigatorSecurityContext, s conversion.Scope) error

Convert_v1alpha1_NavigatorSecurityContext_To_navigator_NavigatorSecurityContext is an autogenerated conversion function.

func Convert_v1alpha1_PersistenceConfig_To_navigator_PersistenceConfig 

func Convert_v1alpha1_PersistenceConfig_To_navigator_PersistenceConfig(in *PersistenceConfig, out *navigator.PersistenceConfig, s conversion.Scope) error

Convert_v1alpha1_PersistenceConfig_To_navigator_PersistenceConfig is an autogenerated conversion function.

func Convert_v1alpha1_PilotCondition_To_navigator_PilotCondition 

func Convert_v1alpha1_PilotCondition_To_navigator_PilotCondition(in *PilotCondition, out *navigator.PilotCondition, s conversion.Scope) error

Convert_v1alpha1_PilotCondition_To_navigator_PilotCondition is an autogenerated conversion function.

func Convert_v1alpha1_PilotList_To_navigator_PilotList 

func Convert_v1alpha1_PilotList_To_navigator_PilotList(in *PilotList, out *navigator.PilotList, s conversion.Scope) error

Convert_v1alpha1_PilotList_To_navigator_PilotList is an autogenerated conversion function.

func Convert_v1alpha1_PilotSpec_To_navigator_PilotSpec 

func Convert_v1alpha1_PilotSpec_To_navigator_PilotSpec(in *PilotSpec, out *navigator.PilotSpec, s conversion.Scope) error

Convert_v1alpha1_PilotSpec_To_navigator_PilotSpec is an autogenerated conversion function.

func Convert_v1alpha1_PilotStatus_To_navigator_PilotStatus 

func Convert_v1alpha1_PilotStatus_To_navigator_PilotStatus(in *PilotStatus, out *navigator.PilotStatus, s conversion.Scope) error

Convert_v1alpha1_PilotStatus_To_navigator_PilotStatus is an autogenerated conversion function.

func Convert_v1alpha1_Pilot_To_navigator_Pilot 

func Convert_v1alpha1_Pilot_To_navigator_Pilot(in *Pilot, out *navigator.Pilot, s conversion.Scope) error

Convert_v1alpha1_Pilot_To_navigator_Pilot is an autogenerated conversion function.

func RegisterConversions 

func RegisterConversions(scheme *runtime.Scheme) error

RegisterConversions adds conversion functions to the given scheme. Public to allow building arbitrary schemes.

func RegisterDefaults 

func RegisterDefaults(scheme *runtime.Scheme) error

RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

func SetDefaults_CassandraClusterNodePool 

func SetDefaults_CassandraClusterNodePool(np *CassandraClusterNodePool)

func SetDefaults_ElasticsearchClusterNodePool 

func SetDefaults_ElasticsearchClusterNodePool(np *ElasticsearchClusterNodePool)

func SetDefaults_ImageSpec 

func SetDefaults_ImageSpec(spec *ImageSpec)

func SetObjectDefaults_CassandraCluster 

func SetObjectDefaults_CassandraCluster(in *CassandraCluster)

func SetObjectDefaults_CassandraClusterList 

func SetObjectDefaults_CassandraClusterList(in *CassandraClusterList)

func SetObjectDefaults_ElasticsearchCluster 

func SetObjectDefaults_ElasticsearchCluster(in *ElasticsearchCluster)

func SetObjectDefaults_ElasticsearchClusterList 

func SetObjectDefaults_ElasticsearchClusterList(in *ElasticsearchClusterList)

Types

type CassandraCluster 

type CassandraCluster struct {
	// we embed these types so the CassandraCluster implements runtime.Object
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`

	Spec   CassandraClusterSpec   `json:"spec"`
	Status CassandraClusterStatus `json:"status"`
}

CassandraCluster describes a specification for an Cassandra cluster

func (*CassandraCluster) DeepCopy 

func (in *CassandraCluster) DeepCopy() *CassandraCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraCluster.

func (*CassandraCluster) DeepCopyInto 

func (in *CassandraCluster) DeepCopyInto(out *CassandraCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CassandraCluster) DeepCopyObject 

func (in *CassandraCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CassandraClusterList 

type CassandraClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []CassandraCluster `json:"items"`
}

CassandraClusterList defines a List type for our custom CassandraCluster type. This is needed in order to make List operations work.

func (*CassandraClusterList) DeepCopy 

func (in *CassandraClusterList) DeepCopy() *CassandraClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraClusterList.

func (*CassandraClusterList) DeepCopyInto 

func (in *CassandraClusterList) DeepCopyInto(out *CassandraClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CassandraClusterList) DeepCopyObject 

func (in *CassandraClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CassandraClusterNodePool 

type CassandraClusterNodePool struct {
	// Name of the node pool specified as a DNS_LABEL.
	// Each node pool must specify a name.
	Name string `json:"name"`

	// The number of desired replicas in this node pool.
	// This value will correspond to the number of replicas in the created
	// StatefulSet.
	// If not set, a default of 1 will be used.
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`

	// Persistence specifies the persistent volume configuration for this node.
	// Disabling persistence can cause issues when a node restarts.
	// Cannot be updated.
	// +optional
	Persistence *PersistenceConfig `json:"persistence,omitempty"`

	// NodeSelector should be specified to force nodes in this pool to run on
	// nodes matching the given selector.
	// In future this may be superceded by an 'affinity' field.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// Rack specifies the cassandra rack with which to label nodes in this
	// nodepool.
	// If this is not set, the name of the node pool will be used.
	// +optional
	Rack *string `json:"rack,omitempty"`

	// Datacenter specifies the cassandra datacenter with which to label nodes
	// in this nodepool. If this is not set, a default will be selected.
	// If this is not set, the default of 'navigator-default-datacenter' will
	// be used.
	// +optional
	Datacenter *string `json:"datacenter,omitempty"`

	// Resources specifies the resource requirements to be used for nodes that
	// are part of the pool.
	// +optional
	Resources v1.ResourceRequirements `json:"resources,omitempty"`

	// If specified, the pod will be dispatched by specified scheduler.
	// If not specified, the pod will be dispatched by default scheduler.
	// +optional
	SchedulerName string `json:"schedulerName,omitempty"`
}

CassandraClusterNodePool describes a node pool within a CassandraCluster.

func (*CassandraClusterNodePool) DeepCopy 

func (in *CassandraClusterNodePool) DeepCopy() *CassandraClusterNodePool

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraClusterNodePool.

func (*CassandraClusterNodePool) DeepCopyInto 

func (in *CassandraClusterNodePool) DeepCopyInto(out *CassandraClusterNodePool)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CassandraClusterNodePoolStatus 

type CassandraClusterNodePoolStatus struct {
	// The number of replicas in the node pool that are currently 'Ready'.
	ReadyReplicas int32 `json:"readyReplicas"`
}

func (*CassandraClusterNodePoolStatus) DeepCopy 

func (in *CassandraClusterNodePoolStatus) DeepCopy() *CassandraClusterNodePoolStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraClusterNodePoolStatus.

func (*CassandraClusterNodePoolStatus) DeepCopyInto 

func (in *CassandraClusterNodePoolStatus) DeepCopyInto(out *CassandraClusterNodePoolStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CassandraClusterSpec 

type CassandraClusterSpec struct {
	NavigatorClusterConfig `json:",inline"`

	// List of node pools belonging to this CassandraCluster.
	// NodePools cannot currently be removed.
	// A cluster with 0 node pools will not function correctly.
	// +optional
	NodePools []CassandraClusterNodePool `json:"nodePools,omitempty"`

	// Image describes the Cassandra database image to use.
	// This should only be set if version auto-detection is not desired.
	// If set, the image tag used must correspond to the version specified
	// in 'spec.version'.
	// This is an advanced feature and should be used with caution. It is
	// the end user's repsonsibility to ensure the 'Image' here matches with
	// the Version specified below.
	// +optional
	Image *ImageSpec `json:"image,omitempty"`

	// The version of the database to be used for nodes in the cluster.
	// This field must be a valid Cassandra version, e.g. '3.11.2'.
	Version version.Version `json:"version"`
}

func (*CassandraClusterSpec) DeepCopy 

func (in *CassandraClusterSpec) DeepCopy() *CassandraClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraClusterSpec.

func (*CassandraClusterSpec) DeepCopyInto 

func (in *CassandraClusterSpec) DeepCopyInto(out *CassandraClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CassandraClusterStatus 

type CassandraClusterStatus struct {
	// The status of each node pool in the CassandraCluster.
	// This will be periodically updated by Navigator.
	NodePools map[string]CassandraClusterNodePoolStatus `json:"nodePools,omitempty"`
}

func (*CassandraClusterStatus) DeepCopy 

func (in *CassandraClusterStatus) DeepCopy() *CassandraClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraClusterStatus.

func (*CassandraClusterStatus) DeepCopyInto 

func (in *CassandraClusterStatus) DeepCopyInto(out *CassandraClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CassandraPilotStatus 

type CassandraPilotStatus struct {
	// Version as reported by the Elasticsearch process
	// This field may be nil if the version number is not currently known.
	// +optional
	Version *version.Version `json:"version,omitempty"`
}

func (*CassandraPilotStatus) DeepCopy 

func (in *CassandraPilotStatus) DeepCopy() *CassandraPilotStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CassandraPilotStatus.

func (*CassandraPilotStatus) DeepCopyInto 

func (in *CassandraPilotStatus) DeepCopyInto(out *CassandraPilotStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConditionStatus 

type ConditionStatus string

ConditionStatus represents a condition's status. 

const (
	// ConditionTrue represents the fact that a given condition is true
	ConditionTrue ConditionStatus = "True"

	// ConditionFalse represents the fact that a given condition is false
	ConditionFalse ConditionStatus = "False"

	// ConditionUnknown represents the fact that a given condition is unknown
	ConditionUnknown ConditionStatus = "Unknown"
)

These are valid condition statuses. "ConditionTrue" means a resource is in the condition; "ConditionFalse" means a resource is not in the condition; "ConditionUnknown" means kubernetes can't decide if a resource is in the condition or not. In the future, we could add other intermediate conditions, e.g. ConditionDegraded.

type ElasticsearchCluster 

type ElasticsearchCluster struct {
	// we embed these types so the ElasticsearchCluster implements runtime.Object
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`

	Spec   ElasticsearchClusterSpec   `json:"spec"`
	Status ElasticsearchClusterStatus `json:"status"`
}

ElasticsearchCluster describes a specification for an Elasticsearch cluster

func (*ElasticsearchCluster) DeepCopy 

func (in *ElasticsearchCluster) DeepCopy() *ElasticsearchCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchCluster.

func (*ElasticsearchCluster) DeepCopyInto 

func (in *ElasticsearchCluster) DeepCopyInto(out *ElasticsearchCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ElasticsearchCluster) DeepCopyObject 

func (in *ElasticsearchCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ElasticsearchClusterHealth 

type ElasticsearchClusterHealth string
const (
	ElasticsearchClusterHealthRed    ElasticsearchClusterHealth = "Red"
	ElasticsearchClusterHealthYellow ElasticsearchClusterHealth = "Yellow"
	ElasticsearchClusterHealthGreen  ElasticsearchClusterHealth = "Green"
)

type ElasticsearchClusterList 

type ElasticsearchClusterList struct {
	// we embed these types so that ElasticsearchClusterList implements runtime.Object and List interfaces
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []ElasticsearchCluster `json:"items"`
}

ElasticsearchClusterList defines a List type for our custom ElasticsearchCluster type. This is needed in order to make List operations work.

func (*ElasticsearchClusterList) DeepCopy 

func (in *ElasticsearchClusterList) DeepCopy() *ElasticsearchClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchClusterList.

func (*ElasticsearchClusterList) DeepCopyInto 

func (in *ElasticsearchClusterList) DeepCopyInto(out *ElasticsearchClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ElasticsearchClusterList) DeepCopyObject 

func (in *ElasticsearchClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ElasticsearchClusterNodePool 

type ElasticsearchClusterNodePool struct {
	// Name of the node pool specified as a DNS_LABEL.
	// Each node pool must specify a name.
	Name string `json:"name"`

	// The number of desired replicas in this node pool.
	// This value will correspond to the number of replicas in the created
	// StatefulSet.
	// If not set, a default of 1 will be used.
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`

	// Roles that nodes in this pool should perform within the cluster.
	// At least one role must be specified.
	Roles []ElasticsearchClusterRole `json:"roles,omitempty"`

	// NodeSelector should be specified to force nodes in this pool to run on
	// nodes matching the given selector.
	// In future this may be superceded by an 'affinity' field.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// Resources specifies the resource requirements to be used for nodes that
	// are part of the pool.
	// +optional
	Resources v1.ResourceRequirements `json:"resources,omitempty"`

	// Persistence specifies the persistent volume configuration for this node.
	// Disabling persistence can cause issues when a node restarts.
	// Cannot be updated.
	// +optional
	Persistence *PersistenceConfig `json:"persistence,omitempty"`

	// If specified, the pod will be dispatched by specified scheduler.
	// If not specified, the pod will be dispatched by default scheduler.
	// +optional
	SchedulerName string `json:"schedulerName,omitempty"`
}

ElasticsearchClusterNodePool describes a node pool within an ElasticsearchCluster. The nodes in this pool will be configured to be of the specified roles

func (*ElasticsearchClusterNodePool) DeepCopy 

func (in *ElasticsearchClusterNodePool) DeepCopy() *ElasticsearchClusterNodePool

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchClusterNodePool.

func (*ElasticsearchClusterNodePool) DeepCopyInto 

func (in *ElasticsearchClusterNodePool) DeepCopyInto(out *ElasticsearchClusterNodePool)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ElasticsearchClusterNodePoolStatus 

type ElasticsearchClusterNodePoolStatus struct {
	// ReadyReplicas is the total number of ready pods in this cluster.
	ReadyReplicas int32 `json:"readyReplicas"`
}

ElasticsearchClusterNodePoolStatus specifies the status of a single node pool in an ElasticsearchCluster

func (*ElasticsearchClusterNodePoolStatus) DeepCopy 

func (in *ElasticsearchClusterNodePoolStatus) DeepCopy() *ElasticsearchClusterNodePoolStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchClusterNodePoolStatus.

func (*ElasticsearchClusterNodePoolStatus) DeepCopyInto 

func (in *ElasticsearchClusterNodePoolStatus) DeepCopyInto(out *ElasticsearchClusterNodePoolStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ElasticsearchClusterRole 

type ElasticsearchClusterRole string

ElasticsearchClusterRole is a node role in an ElasticsearchCluster. 

const (
	ElasticsearchRoleData   ElasticsearchClusterRole = "data"
	ElasticsearchRoleMaster ElasticsearchClusterRole = "master"
	ElasticsearchRoleIngest ElasticsearchClusterRole = "ingest"
)

type ElasticsearchClusterSpec 

type ElasticsearchClusterSpec struct {
	NavigatorClusterConfig `json:",inline"`

	// The version of the database to be used for nodes in the cluster.
	// This field must be a valid Elasticsearch version, e.g. '6.1.1'.
	Version semver.Version `json:"version"`

	// List of plugins to install on nodes in the cluster.
	// pilot-elasticsearch will install these plugins when each node is started.
	// +optional
	Plugins []string `json:"plugins,omitempty"`

	// List of node pools belonging to this ElasticsearchCluster.
	// NodePools cannot currently be removed.
	// There must be at least one master node to form a valid cluster.
	// +optional
	NodePools []ElasticsearchClusterNodePool `json:"nodePools,omitempty"`

	// Image describes the Elasticsearch database image to use.
	// This should only be set if version auto-detection is not desired.
	// If set, the image tag used must correspond to the version specified
	// in 'spec.version'.
	// +optional
	Image *ImageSpec `json:"image,omitempty"`

	// The minimum number of masters required to form a quorum in the cluster.
	// If omitted, this will be set to a quorum of the master nodes in the
	// cluster.
	// If set, the value *must* be greater than or equal to a quorum of master
	// nodes.
	// +optional
	MinimumMasters *int32 `json:"minimumMasters,omitempty"`
}

ElasticsearchClusterSpec describes a specification for an ElasticsearchCluster

func (*ElasticsearchClusterSpec) DeepCopy 

func (in *ElasticsearchClusterSpec) DeepCopy() *ElasticsearchClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchClusterSpec.

func (*ElasticsearchClusterSpec) DeepCopyInto 

func (in *ElasticsearchClusterSpec) DeepCopyInto(out *ElasticsearchClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ElasticsearchClusterStatus 

type ElasticsearchClusterStatus struct {
	// The status of each node pool in the ElasticsearchCluster.
	// This will be periodically updated by Navigator.
	NodePools map[string]ElasticsearchClusterNodePoolStatus `json:"nodePools,omitempty"`
	// The health of the ElasticsearchCluster.
	// This will be one of Red, Yellow or Green.
	// +optional
	Health *ElasticsearchClusterHealth `json:"health,omitempty"`
}

ElasticsearchClusterStatus specifies the overall status of an ElasticsearchCluster.

func (*ElasticsearchClusterStatus) DeepCopy 

func (in *ElasticsearchClusterStatus) DeepCopy() *ElasticsearchClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchClusterStatus.

func (*ElasticsearchClusterStatus) DeepCopyInto 

func (in *ElasticsearchClusterStatus) DeepCopyInto(out *ElasticsearchClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ElasticsearchPilotStatus 

type ElasticsearchPilotStatus struct {
	// Documents is the current number of documents on this node.
	// A nil value indicates an unknown number of documents.
	// Zero documents indicates the node is empty.
	// +optional
	Documents *int64 `json:"documents,omitempty"`

	// Version as reported by the Elasticsearch process
	// This field may be nil if the version number is not currently known.
	// +optional
	Version *semver.Version `json:"version,omitempty"`
}

func (*ElasticsearchPilotStatus) DeepCopy 

func (in *ElasticsearchPilotStatus) DeepCopy() *ElasticsearchPilotStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchPilotStatus.

func (*ElasticsearchPilotStatus) DeepCopyInto 

func (in *ElasticsearchPilotStatus) DeepCopyInto(out *ElasticsearchPilotStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ImageSpec 

type ImageSpec struct {
	// Repository is the repository of a docker image (e.g. 'alpine').
	Repository string `json:"repository"`

	// Tag is the tag of a docker image (e.g. 'latest').
	Tag string `json:"tag"`

	// PullPolicy is the policy for pulling docker images. If not set, the
	// cluster default will be used.
	// +optional
	PullPolicy v1.PullPolicy `json:"pullPolicy,omitempty"`
}

ImageSpec specifies a docker image to be used.

func (*ImageSpec) DeepCopy 

func (in *ImageSpec) DeepCopy() *ImageSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ImageSpec.

func (*ImageSpec) DeepCopyInto 

func (in *ImageSpec) DeepCopyInto(out *ImageSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. 

type NavigatorClusterConfig struct {
	// Pilot describes the pilot image to use.
	// This field is currently required.
	PilotImage ImageSpec `json:"pilotImage"`

	// Security related options to be applied to the cluster pods.
	SecurityContext NavigatorSecurityContext `json:"securityContext"`
}
func (in *NavigatorClusterConfig) DeepCopy() *NavigatorClusterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NavigatorClusterConfig. 

func (in *NavigatorClusterConfig) DeepCopyInto(out *NavigatorClusterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. 

type NavigatorSecurityContext struct {
	// Optional user to run the pilot process as.
	// This will also be used as the FSGroup parameter for created pods.
	// Should correspond to the value set as part of the Dockerfile when
	// a manual image override has been specified.
	// +optional
	RunAsUser *int64 `json:"runAsUser,omitempty"`
}
func (in *NavigatorSecurityContext) DeepCopy() *NavigatorSecurityContext

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NavigatorSecurityContext. 

func (in *NavigatorSecurityContext) DeepCopyInto(out *NavigatorSecurityContext)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PersistenceConfig 

type PersistenceConfig struct {
	// Size of the persistent volume to provision (required if persistence is
	// enabled).
	Size resource.Quantity `json:"size"`

	// StorageClass to use for the persistent volume claim. If not set, the
	// default cluster storage class will be used.
	// +optional
	StorageClass *string `json:"storageClass,omitempty"`
}

PersistenceConfig contains persistent volume configuration.

func (*PersistenceConfig) DeepCopy 

func (in *PersistenceConfig) DeepCopy() *PersistenceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PersistenceConfig.

func (*PersistenceConfig) DeepCopyInto 

func (in *PersistenceConfig) DeepCopyInto(out *PersistenceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Pilot 

type Pilot struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`

	Spec   PilotSpec   `json:"spec"`
	Status PilotStatus `json:"status"`
}

func (*Pilot) DeepCopy 

func (in *Pilot) DeepCopy() *Pilot

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pilot.

func (*Pilot) DeepCopyInto 

func (in *Pilot) DeepCopyInto(out *Pilot)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Pilot) DeepCopyObject 

func (in *Pilot) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Pilot) HasCondition 

func (p *Pilot) HasCondition(condition PilotCondition) bool

func (*Pilot) UpdateStatusCondition 

func (p *Pilot) UpdateStatusCondition(conditionType PilotConditionType, status ConditionStatus, reason, message string, format ...string)

type PilotCondition 

type PilotCondition struct {
	// Type of the condition, currently ('Ready').
	Type PilotConditionType `json:"type"`

	// Status of the condition, one of ('True', 'False', 'Unknown').
	Status ConditionStatus `json:"status"`

	// LastTransitionTime is the timestamp corresponding to the last status
	// change of this condition.
	LastTransitionTime metav1.Time `json:"lastTransitionTime"`

	// Reason is a brief machine readable explanation for the condition's last
	// transition.
	Reason string `json:"reason"`

	// Message is a human readable description of the details of the last
	// transition, complementing reason.
	Message string `json:"message"`
}

PilotCondition contains condition information for a Pilot.

func (*PilotCondition) DeepCopy 

func (in *PilotCondition) DeepCopy() *PilotCondition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PilotCondition.

func (*PilotCondition) DeepCopyInto 

func (in *PilotCondition) DeepCopyInto(out *PilotCondition)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PilotConditionType 

type PilotConditionType string

PilotConditionType represents a Pilot condition value. 

const (
	// PilotConditionReady represents the fact that a given Pilot condition
	// is in ready state.
	PilotConditionReady PilotConditionType = "Ready"
	// PilotConditionStarted represents the fact that a given Pilot condition
	// is in started state.
	PilotConditionStarted PilotConditionType = "Started"
	// PilotConditionStopped represents the fact that a given Pilot
	// condition is in a stopped state.
	PilotConditionStopped PilotConditionType = "Stopped"
)

type PilotList 

type PilotList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []Pilot `json:"items"`
}

func (*PilotList) DeepCopy 

func (in *PilotList) DeepCopy() *PilotList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PilotList.

func (*PilotList) DeepCopyInto 

func (in *PilotList) DeepCopyInto(out *PilotList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PilotList) DeepCopyObject 

func (in *PilotList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type PilotSpec 

type PilotSpec struct {
}

func (*PilotSpec) DeepCopy 

func (in *PilotSpec) DeepCopy() *PilotSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PilotSpec.

func (*PilotSpec) DeepCopyInto 

func (in *PilotSpec) DeepCopyInto(out *PilotSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PilotStatus 

type PilotStatus struct {
	// Conditions representing the current state of the Pilot.
	// +optional
	Conditions []PilotCondition `json:"conditions,omitempty"`

	// Status information specific to Elasticsearch Pilots.
	// +optional
	Elasticsearch *ElasticsearchPilotStatus `json:"elasticsearch,omitempty"`

	// Status information specific to Cassandra Pilots.
	// +optional
	Cassandra *CassandraPilotStatus `json:"cassandra,omitempty"`
}

func (*PilotStatus) DeepCopy 

func (in *PilotStatus) DeepCopy() *PilotStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PilotStatus.

func (*PilotStatus) DeepCopyInto 

func (in *PilotStatus) DeepCopyInto(out *PilotStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

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.