Documentation
¶
Overview ¶
Package v1 contains API Schema definitions for the oldmonk v1 API group +k8s:deepcopy-gen=package,register +groupName=oldmonk.evalsocket.in
Package v1 contains API Schema definitions for the oldmonk v1 API group +k8s:deepcopy-gen=package,register +groupName=oldmonk.evalsocket.in
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: "oldmonk.evalsocket.in", Version: "v1"} // 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 ListOptions ¶
type ListOptions struct {
// Uri (Don't use it's depricated). Use secrets
Uri string `json:"uri,omitempty"`
// Region is a optional parameter and used in case of SQS
Region string `json:"region,omitempty"`
// Type is a optional parameter and used in case of Rabbitmq(exchange type)
Type string `json:"type,omitempty"`
// Queue is a optional parameter and used in case of Rabbitmq and nats
Queue string `json:"queue,omitempty"`
// Exchange is a optional parameter and used in case of Rabbitmq
Exchange string `json:"exchange,omitempty"`
// Tube is a optional parameter and used in case of Beanstalk
Tube string `json:"tube,omitempty"`
// Group is a optional parameter and used in case of Kafka
Group string `json:"group,omitempty"`
// Topic is a optional parameter and used in case of Kafka
Topic string `json:"topic,omitempty"`
}
ListOptions defines the desired state of Queue +k8s:openapi-gen=true
func (*ListOptions) DeepCopy ¶
func (in *ListOptions) DeepCopy() *ListOptions
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ListOptions.
func (*ListOptions) DeepCopyInto ¶
func (in *ListOptions) DeepCopyInto(out *ListOptions)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueAutoScaler ¶
type QueueAutoScaler struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec QueueAutoScalerSpec `json:"spec,omitempty"`
Status QueueAutoScalerStatus `json:"status,omitempty"`
}
QueueAutoScaler is the Schema for the queueautoscalers API +kubebuilder:subresource:status +kubebuilder:resource:path=queueautoscalers,scope=Namespaced
func (*QueueAutoScaler) DeepCopy ¶
func (in *QueueAutoScaler) DeepCopy() *QueueAutoScaler
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueAutoScaler.
func (*QueueAutoScaler) DeepCopyInto ¶
func (in *QueueAutoScaler) DeepCopyInto(out *QueueAutoScaler)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*QueueAutoScaler) DeepCopyObject ¶
func (in *QueueAutoScaler) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type QueueAutoScalerList ¶
type QueueAutoScalerList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []QueueAutoScaler `json:"items"`
}
QueueAutoScalerList contains a list of QueueAutoScaler
func (*QueueAutoScalerList) DeepCopy ¶
func (in *QueueAutoScalerList) DeepCopy() *QueueAutoScalerList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueAutoScalerList.
func (*QueueAutoScalerList) DeepCopyInto ¶
func (in *QueueAutoScalerList) DeepCopyInto(out *QueueAutoScalerList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*QueueAutoScalerList) DeepCopyObject ¶
func (in *QueueAutoScalerList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type QueueAutoScalerSpec ¶
type QueueAutoScalerSpec struct {
// Type contains the user-specified Queue type
// Type can be RABITMQ/BEANSTALK/NATS/SQS
Type string `json:"type"`
// Option contains Queue Details
Option ListOptions `json:"option"`
// MinPods for deployment
MinPods int32 `json:"minPods"`
// MaxPods for deployment
MaxPods int32 `json:"maxPods"`
// targetMessagesPerWorker is the number used to find number of pod needed. It's a optional parameter and used in case of policy TARGET
TargetMessagesPerWorker int32 `json:"targetMessagesPerWorker,omitempty"`
// ScaleUp contains scale up policy
ScaleUp ScaleSpec `json:"scaleUp,omitempty"`
// ScaleDown contains scale down policy
ScaleDown ScaleSpec `json:"scaleDown,omitempty"`
// Policy contains name of policy possible value is THRESOLD/TARGET
Policy string `json:"policy,omitempty"`
// Secrets contains secret name. Pass secure connection uri using secrets
Secrets string `json:"secrets"`
// Deployment contains deployment name which user want to scale
Deployment string `json:"deployment"`
// AppSpec contains deployment specification used same as deployment file (optional)
AppSpec corev1.Container `json:"appSpec,omitempty"`
// Labels contains key value pair for deployment (We are using these labels as selctor for selecting all pods)
Labels map[string]string `json:"labels"`
// Strategy contains deployment strategy (optional)
Strategy appsv1.DeploymentStrategy `json:"strategy,omitempty"`
// Volume cotains a list of volume (optional)
Volume []corev1.Volume `json:"volume,omitempty"`
// Autopilot is a bool value. false means it only auto scale deployment and true means it will manage the entire life cycle of deployment
Autopilot bool `json:"autopilot"`
}
AutoScalerSpec defines the desired state of QueueAutoScaler +k8s:openapi-gen=true
func (*QueueAutoScalerSpec) DeepCopy ¶
func (in *QueueAutoScalerSpec) DeepCopy() *QueueAutoScalerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueAutoScalerSpec.
func (*QueueAutoScalerSpec) DeepCopyInto ¶
func (in *QueueAutoScalerSpec) DeepCopyInto(out *QueueAutoScalerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueAutoScalerStatus ¶
type QueueAutoScalerStatus struct {
// Nodes are the names of the pods
// +listType=set
Nodes []string `json:"nodes"`
}
QueueAutoScalerStatus defines the observed state of QueueAutoScaler
func (*QueueAutoScalerStatus) DeepCopy ¶
func (in *QueueAutoScalerStatus) DeepCopy() *QueueAutoScalerStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueAutoScalerStatus.
func (*QueueAutoScalerStatus) DeepCopyInto ¶
func (in *QueueAutoScalerStatus) DeepCopyInto(out *QueueAutoScalerStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ScaleSpec ¶
type ScaleSpec struct {
// Threshold is the amount of messages in queue
Threshold int32 `json:"threshold"`
// Amount is the number by which you want to scale
Amount int32 `json:"amount"`
}
ScaleSpec defines the desired state of Autoscaler +k8s:openapi-gen=true
func (*ScaleSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScaleSpec.
func (*ScaleSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files