v1alpha1

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the thelastpickle v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=thelastpickle.com

Package v1alpha1 contains API Schema definitions for the thelastpickle v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=thelastpickle.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "thelastpickle.com", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)

Functions

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

Types

type CassandraCluster 

type CassandraCluster struct {
	Namespace string `json:"namespace,omitempty"`
	Name      string `json:"name,omitempty"`
}

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.

type CassandraClusterTemplate 

type CassandraClusterTemplate struct {
	metav1.TypeMeta `json:"typeMeta,omitempty"`

	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec casskop.CassandraClusterSpec `json:"spec,omitempty"`
}

func (*CassandraClusterTemplate) DeepCopy 

func (in *CassandraClusterTemplate) DeepCopy() *CassandraClusterTemplate

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

func (*CassandraClusterTemplate) DeepCopyInto 

func (in *CassandraClusterTemplate) DeepCopyInto(out *CassandraClusterTemplate)

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

type CassandraConfig 

type CassandraConfig struct {
	// The headless service for the Cassandra cluster to which tlp-stress will connect.
	// Note that this will only be used when neither CassandraCluster nor
	// CassandraClusterTemplate is specified.
	CassandraService string `json:"cassandraService,omitempty"`

	// The name of a casskop-generated Cassandra cluster to which tlp-stress will connect.
	// Note that will only be used when CassandraClusterTemplate is not specified.
	CassandraCluster *CassandraCluster `json:"cassandraCluster,omitempty"`

	// Describes a casskop CassandraCluster that will be created and to which tlp-stress
	// will connect.
	CassandraClusterTemplate *CassandraClusterTemplate `json:"cassandraClusterTemplate,omitempty"`
}

Provides connection details about the cluster to which tlp-stress will run against.

func (*CassandraConfig) DeepCopy 

func (in *CassandraConfig) DeepCopy() *CassandraConfig

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

func (*CassandraConfig) DeepCopyInto 

func (in *CassandraConfig) DeepCopyInto(out *CassandraConfig)

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

type ConsistencyLevel 

type ConsistencyLevel string
const (
	CL_ANY          ConsistencyLevel = "ANY"
	CL_ONE          ConsistencyLevel = "ONE"
	CL_TWO          ConsistencyLevel = "TWO"
	CL_THREE        ConsistencyLevel = "THREE"
	CL_QUORUM       ConsistencyLevel = "QUORUM"
	CL_ALL          ConsistencyLevel = "ALL"
	CL_LOCAL_QUORUM ConsistencyLevel = "LOCAL_QUORUM"
	CL_EACH_QUORUM  ConsistencyLevel = "EACH_QUORUM"
	CL_LOCAL_ONE    ConsistencyLevel = "LOCAL_ONE"
	CL_SERIAL       ConsistencyLevel = "SERIAL"
	CL_LOCAL_SERIAL ConsistencyLevel = "LOCAL_SERIAL"
)

type JobConfig 

type JobConfig struct {
	// Specifies the number of retries before marking this job failed.
	// Defaults to 6
	// +optional
	BackoffLimit *int32 `json:"backoffLimit,omitempty" protobuf:"varint,7,opt,name=backoffLimit"`

	// Specifies the maximum desired number of pods the job should
	// run at any given time. The actual number of pods running in steady state will
	// be less than this number when ((.spec.completions - .status.successful) < .spec.parallelism),
	// i.e. when the work left to do is less than max parallelism.
	// More info: https://kubernetes.io/docs/concepts/workloads/controllers/jobs-run-to-completion/
	// +optional
	Parallelism *int32 `json:"parallelism,omitempty" protobuf:"varint,1,opt,name=parallelism"`
}

Describes the data the the job should have

func (*JobConfig) DeepCopy 

func (in *JobConfig) DeepCopy() *JobConfig

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

func (*JobConfig) DeepCopyInto 

func (in *JobConfig) DeepCopyInto(out *JobConfig)

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

type ReplicationConfig 

type ReplicationConfig struct {
	SimpleStrategy *int32 `json:"simpleStrategy,omitempty"`

	NetworkTopologyStrategy *map[string]int32 `json:"networkTopologyStrategy,omitempty"`
}

func (*ReplicationConfig) DeepCopy 

func (in *ReplicationConfig) DeepCopy() *ReplicationConfig

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

func (*ReplicationConfig) DeepCopyInto 

func (in *ReplicationConfig) DeepCopyInto(out *ReplicationConfig)

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

type Stress 

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

	Spec   StressSpec   `json:"spec,omitempty"`
	Status StressStatus `json:"status,omitempty"`
}

Stress is the Schema for the Stresses API +k8s:openapi-gen=true +kubebuilder:subresource:status

func (*Stress) CreateOwnerReference 

func (s *Stress) CreateOwnerReference() metav1.OwnerReference

func (*Stress) DeepCopy 

func (in *Stress) DeepCopy() *Stress

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

func (*Stress) DeepCopyInto 

func (in *Stress) DeepCopyInto(out *Stress)

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

func (*Stress) DeepCopyObject 

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

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

type StressConfig 

type StressConfig struct {
	Workload Workload `json:"workload,omitempty"`

	ConsistencyLevel ConsistencyLevel `json:"consistencyLevel,omitempty"`

	// +kubebuilder:validation:Pattern=^(\d+)([BbMmKk]?$)
	Partitions *string `json:"partitions,omitempty"`

	DataCenter string `json:"dataCenter,omitempty"`

	Duration string `json:"duration,omitempty"`

	DropKeyspace bool `json:"dropKeyspace,omitempty"`

	// Defaults to cassandra
	Username string `json:"username,omitempty"`

	// Defaults to cassandra
	Password string `json:"password,omitempty"`

	// Defaults to tlp_stress
	Keyspace string `json:"keyspace,omitempty"`

	// Table level TTL. Set to zero to disable.
	Ttl *int64 `json:"ttl,omitempty"`

	// Override the driver's default page size
	Paging *int32 `json:"paging,omitempty"`

	// +kubebuilder:validation:Pattern=^(\d+)([BbMmKk]?$)
	Iterations *string `json:"iterations,omitempty"`

	// TODO add validation to ensure value is numeric
	// Deletion Rate, 0-1.  Workloads may have their own defaults.  Default is dependent on workload.
	DeleteRate string `json:"deleterate,omitempty"`

	// TODO add validation to ensure value is numeric
	ReadRate string `json:"readRate,omitempty"`

	// +kubebuilder:validation:Pattern=^(\d+)([BbMmKk]?$)
	Populate *string `json:"populate,omitempty"`

	Concurrency *int32 `json:"concurrency,omitempty"`

	PartitionGenerator string `json:"partitionGenerator,omitempty"`

	Replication ReplicationConfig `json:"replication,omitempty"`
}

func (*StressConfig) DeepCopy 

func (in *StressConfig) DeepCopy() *StressConfig

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

func (*StressConfig) DeepCopyInto 

func (in *StressConfig) DeepCopyInto(out *StressConfig)

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

type StressContext 

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

	Spec   StressContextSpec   `json:"spec,omitempty"`
	Status StressContextStatus `json:"status,omitempty"`
}

StressContext is the Schema for the stresscontexts API +k8s:openapi-gen=true +kubebuilder:subresource:status

func (*StressContext) DeepCopy 

func (in *StressContext) DeepCopy() *StressContext

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

func (*StressContext) DeepCopyInto 

func (in *StressContext) DeepCopyInto(out *StressContext)

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

func (*StressContext) DeepCopyObject 

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

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

type StressContextList 

type StressContextList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []StressContext `json:"items"`
}

StressContextList contains a list of StressContext

func (*StressContextList) DeepCopy 

func (in *StressContextList) DeepCopy() *StressContextList

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

func (*StressContextList) DeepCopyInto 

func (in *StressContextList) DeepCopyInto(out *StressContextList)

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

func (*StressContextList) DeepCopyObject 

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

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

type StressContextSpec 

type StressContextSpec struct {
	InstallPrometheus bool `json:"installPrometheus,omitempty"`

	InstallGrafana bool `json:"installGrafana,omitempty"`
}

StressContextSpec defines the desired state of StressContext +k8s:openapi-gen=true

func (*StressContextSpec) DeepCopy 

func (in *StressContextSpec) DeepCopy() *StressContextSpec

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

func (*StressContextSpec) DeepCopyInto 

func (in *StressContextSpec) DeepCopyInto(out *StressContextSpec)

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

type StressContextStatus 

type StressContextStatus struct {
}

StressContextStatus defines the observed state of StressContext +k8s:openapi-gen=true

func (*StressContextStatus) DeepCopy 

func (in *StressContextStatus) DeepCopy() *StressContextStatus

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

func (*StressContextStatus) DeepCopyInto 

func (in *StressContextStatus) DeepCopyInto(out *StressContextStatus)

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

type StressList 

type StressList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Stress `json:"items"`
}

StressList contains a list of Stress

func (*StressList) DeepCopy 

func (in *StressList) DeepCopy() *StressList

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

func (*StressList) DeepCopyInto 

func (in *StressList) DeepCopyInto(out *StressList)

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

func (*StressList) DeepCopyObject 

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

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

type StressSpec 

type StressSpec struct {
	CassandraConfig CassandraConfig `json:"cassandraConfig,omitempty"`

	Image string `json:"image,omitempty"`

	ImagePullPolicy v1.PullPolicy `json:"imagePullPolicy,omitempty"`

	StressConfig StressConfig `json:"stressConfig,omitempty"`

	JobConfig JobConfig `json:"jobConfig,omitempty"`
}

StressSpec defines the desired state of Stress +k8s:openapi-gen=true

func (*StressSpec) DeepCopy 

func (in *StressSpec) DeepCopy() *StressSpec

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

func (*StressSpec) DeepCopyInto 

func (in *StressSpec) DeepCopyInto(out *StressSpec)

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

type StressStatus 

type StressStatus struct {
	JobStatus *batchv1.JobStatus `json:"jobStatus,omitempty"`
}

StressStatus defines the observed state of Stress +k8s:openapi-gen=true

func (*StressStatus) DeepCopy 

func (in *StressStatus) DeepCopy() *StressStatus

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

func (*StressStatus) DeepCopyInto 

func (in *StressStatus) DeepCopyInto(out *StressStatus)

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

type Workload 

type Workload string
const (
	KeyValueWorkload             Workload = "KeyValue"
	BasicTimeSeriesWorkload      Workload = "BasicTimeSeries"
	CountersWideWorkload         Workload = "CountersWide"
	LWTWorkload                  Workload = "LWT"
	LockingWorkload              Workload = "Locking"
	MapsWorkload                 Workload = "Maps"
	MaterializedViewsWorkload    Workload = "MaterializedViews"
	RandomParitionAccessWorkload Workload = "RandomPartitionAccess"
	UdtTimeSeriesWorkload        Workload = "UdtTimeSeries"
)

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.