v1alpha1

package
v1.0.5 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2021 License: Apache-2.0 Imports: 21 Imported by: 44

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API.

Index

Constants

View Source 
const (
	ExperimentNameAnnotationKey         = "experiment.argoproj.io/name"
	ExperimentTemplateNameAnnotationKey = "experiment.argoproj.io/template-name"
)

Annotations that are labeled into the ReplicaSets that are part of an experiment

View Source 
const (
	// DefaultRolloutUniqueLabelKey is the default key of the selector that is added
	// to existing ReplicaSets (and label key that is added to its pods) to prevent the existing ReplicaSets
	// to select new pods (and old pods being select by new ReplicaSet).
	DefaultRolloutUniqueLabelKey string = "rollouts-pod-template-hash"
	// DefaultReplicaSetScaleDownDeadlineAnnotationKey is the default key attached to an old stable ReplicaSet after
	// the rollout transitioned to a new version. It contains the time when the controller can scale down the RS.
	DefaultReplicaSetScaleDownDeadlineAnnotationKey = "scale-down-deadline"
	// ManagedByRolloutKey is the key used to indicate which rollout(s) manage a resource but doesn't own it.
	ManagedByRolloutsKey = "argo-rollouts.argoproj.io/managed-by-rollouts"
	// DefaultReplicaSetRestartAnnotationKey indicates that the ReplicaSet with this annotation was restarted at the
	// time listed in the value
	DefaultReplicaSetRestartAnnotationKey = "argo-rollouts.argoproj.io/restarted-after"
	// LabelKeyControllerInstanceID is the label the controller uses for the rollout, experiment, analysis segregation
	// between controllers. Controllers will only operate on objects with the same instanceID as the controller.
	LabelKeyControllerInstanceID = "argo-rollouts.argoproj.io/controller-instance-id"
)
View Source 
const (
	// RolloutTypeLabel indicates how the rollout created the analysisRun
	RolloutTypeLabel = "rollout-type"
	// RolloutTypeStepLabel indicates that the analysisRun was created as a canary step
	RolloutTypeStepLabel = "Step"
	// RolloutTypeBackgroundRunLabel indicates that the analysisRun was created in Background to an execution
	RolloutTypeBackgroundRunLabel = "Background"
	// RolloutTypePrePromotionLabel indicates that the analysisRun was created before the active service promotion
	RolloutTypePrePromotionLabel = "PrePromotion"
	// RolloutTypePostPromotionLabel indicates that the analysisRun was created after the active service promotion
	RolloutTypePostPromotionLabel = "PostPromotion"
	// RolloutCanaryStepIndexLabel indicates which step created this analysisRun
	RolloutCanaryStepIndexLabel = "step-index"
)

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// GroupVersionResource for all rollout types
	RolloutGVR                 = SchemeGroupVersion.WithResource("rollouts")
	AnalysisRunGVR             = SchemeGroupVersion.WithResource("analysisruns")
	AnalysisTemplateGVR        = SchemeGroupVersion.WithResource("analysistemplates")
	ClusterAnalysisTemplateGVR = SchemeGroupVersion.WithResource("clusteranalysistemplates")
	ExperimentGVR              = SchemeGroupVersion.WithResource("experiments")
)
View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: rollouts.Group, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func DurationFromInt added in v0.8.0 

func DurationFromInt(i int) *intstr.IntOrString

DurationFromInt creates duration in seconds from int value

func DurationFromString added in v0.8.0 

func DurationFromString(s string) *intstr.IntOrString

DurationFromString creates duration from string value must be a string representation of an int with optional time unit (see time.ParseDuration)

func GetOpenAPIDefinitions 

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

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type ALBTrafficRouting added in v0.8.0 

type ALBTrafficRouting struct {
	// Ingress refers to the name of an `Ingress` resource in the same namespace as the `Rollout`
	Ingress string `json:"ingress" protobuf:"bytes,1,opt,name=ingress"`
	// ServicePort refers to the port that the Ingress action should route traffic to
	ServicePort int32 `json:"servicePort" protobuf:"varint,2,opt,name=servicePort"`
	// RootService references the service in the ingress to the controller should add the action to
	RootService string `json:"rootService,omitempty" protobuf:"bytes,3,opt,name=rootService"`
	// AnnotationPrefix has to match the configured annotation prefix on the alb ingress controller
	// +optional
	AnnotationPrefix string `json:"annotationPrefix,omitempty" protobuf:"bytes,4,opt,name=annotationPrefix"`
}

ALBTrafficRouting configuration for ALB ingress controller to control traffic routing

func (*ALBTrafficRouting) DeepCopy added in v0.8.0 

func (in *ALBTrafficRouting) DeepCopy() *ALBTrafficRouting

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

func (*ALBTrafficRouting) DeepCopyInto added in v0.8.0 

func (in *ALBTrafficRouting) DeepCopyInto(out *ALBTrafficRouting)

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

func (*ALBTrafficRouting) Descriptor added in v1.0.0 

func (*ALBTrafficRouting) Descriptor() ([]byte, []int)

func (*ALBTrafficRouting) Marshal added in v1.0.0 

func (m *ALBTrafficRouting) Marshal() (dAtA []byte, err error)

func (*ALBTrafficRouting) MarshalTo added in v1.0.0 

func (m *ALBTrafficRouting) MarshalTo(dAtA []byte) (int, error)

func (*ALBTrafficRouting) MarshalToSizedBuffer added in v1.0.0 

func (m *ALBTrafficRouting) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ALBTrafficRouting) ProtoMessage added in v1.0.0 

func (*ALBTrafficRouting) ProtoMessage()

func (*ALBTrafficRouting) Reset added in v1.0.0 

func (m *ALBTrafficRouting) Reset()

func (*ALBTrafficRouting) Size added in v1.0.0 

func (m *ALBTrafficRouting) Size() (n int)

func (*ALBTrafficRouting) String added in v1.0.0 

func (this *ALBTrafficRouting) String() string

func (*ALBTrafficRouting) Unmarshal added in v1.0.0 

func (m *ALBTrafficRouting) Unmarshal(dAtA []byte) error

func (*ALBTrafficRouting) XXX_DiscardUnknown added in v1.0.0 

func (m *ALBTrafficRouting) XXX_DiscardUnknown()

func (*ALBTrafficRouting) XXX_Marshal added in v1.0.0 

func (m *ALBTrafficRouting) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ALBTrafficRouting) XXX_Merge added in v1.0.0 

func (m *ALBTrafficRouting) XXX_Merge(src proto.Message)

func (*ALBTrafficRouting) XXX_Size added in v1.0.0 

func (m *ALBTrafficRouting) XXX_Size() int

func (*ALBTrafficRouting) XXX_Unmarshal added in v1.0.0 

func (m *ALBTrafficRouting) XXX_Unmarshal(b []byte) error

type AmbassadorTrafficRouting added in v1.0.0 

type AmbassadorTrafficRouting struct {
	// Mappings refer to the name of the Ambassador Mappings used to route traffic to the
	// service
	Mappings []string `json:"mappings" protobuf:"bytes,1,rep,name=mappings"`
}

AmbassadorTrafficRouting defines the configuration required to use Ambassador as traffic router

func (*AmbassadorTrafficRouting) DeepCopy added in v1.0.0 

func (in *AmbassadorTrafficRouting) DeepCopy() *AmbassadorTrafficRouting

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

func (*AmbassadorTrafficRouting) DeepCopyInto added in v1.0.0 

func (in *AmbassadorTrafficRouting) DeepCopyInto(out *AmbassadorTrafficRouting)

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

func (*AmbassadorTrafficRouting) Descriptor added in v1.0.0 

func (*AmbassadorTrafficRouting) Descriptor() ([]byte, []int)

func (*AmbassadorTrafficRouting) Marshal added in v1.0.0 

func (m *AmbassadorTrafficRouting) Marshal() (dAtA []byte, err error)

func (*AmbassadorTrafficRouting) MarshalTo added in v1.0.0 

func (m *AmbassadorTrafficRouting) MarshalTo(dAtA []byte) (int, error)

func (*AmbassadorTrafficRouting) MarshalToSizedBuffer added in v1.0.0 

func (m *AmbassadorTrafficRouting) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AmbassadorTrafficRouting) ProtoMessage added in v1.0.0 

func (*AmbassadorTrafficRouting) ProtoMessage()

func (*AmbassadorTrafficRouting) Reset added in v1.0.0 

func (m *AmbassadorTrafficRouting) Reset()

func (*AmbassadorTrafficRouting) Size added in v1.0.0 

func (m *AmbassadorTrafficRouting) Size() (n int)

func (*AmbassadorTrafficRouting) String added in v1.0.0 

func (this *AmbassadorTrafficRouting) String() string

func (*AmbassadorTrafficRouting) Unmarshal added in v1.0.0 

func (m *AmbassadorTrafficRouting) Unmarshal(dAtA []byte) error

func (*AmbassadorTrafficRouting) XXX_DiscardUnknown added in v1.0.0 

func (m *AmbassadorTrafficRouting) XXX_DiscardUnknown()

func (*AmbassadorTrafficRouting) XXX_Marshal added in v1.0.0 

func (m *AmbassadorTrafficRouting) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AmbassadorTrafficRouting) XXX_Merge added in v1.0.0 

func (m *AmbassadorTrafficRouting) XXX_Merge(src proto.Message)

func (*AmbassadorTrafficRouting) XXX_Size added in v1.0.0 

func (m *AmbassadorTrafficRouting) XXX_Size() int

func (*AmbassadorTrafficRouting) XXX_Unmarshal added in v1.0.0 

func (m *AmbassadorTrafficRouting) XXX_Unmarshal(b []byte) error

type AnalysisPhase added in v0.6.0 

type AnalysisPhase string

AnalysisPhase is the overall phase of an AnalysisRun, MetricResult, or Measurement 

const (
	AnalysisPhasePending      AnalysisPhase = "Pending"
	AnalysisPhaseRunning      AnalysisPhase = "Running"
	AnalysisPhaseSuccessful   AnalysisPhase = "Successful"
	AnalysisPhaseFailed       AnalysisPhase = "Failed"
	AnalysisPhaseError        AnalysisPhase = "Error"
	AnalysisPhaseInconclusive AnalysisPhase = "Inconclusive"
)

Possible AnalysisPhase values

func (AnalysisPhase) Completed added in v0.6.0 

func (as AnalysisPhase) Completed() bool

Completed returns whether or not the analysis status is considered completed

type AnalysisRun added in v0.6.0 

type AnalysisRun struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              AnalysisRunSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	Status            AnalysisRunStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

AnalysisRun is an instantiation of an AnalysisTemplate +genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +kubebuilder:resource:path=analysisruns, shortName=ar +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase",description="AnalysisRun status"

func (*AnalysisRun) DeepCopy added in v0.6.0 

func (in *AnalysisRun) DeepCopy() *AnalysisRun

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

func (*AnalysisRun) DeepCopyInto added in v0.6.0 

func (in *AnalysisRun) DeepCopyInto(out *AnalysisRun)

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

func (*AnalysisRun) DeepCopyObject added in v0.6.0 

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

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

func (*AnalysisRun) Descriptor added in v1.0.0 

func (*AnalysisRun) Descriptor() ([]byte, []int)

func (*AnalysisRun) Marshal added in v1.0.0 

func (m *AnalysisRun) Marshal() (dAtA []byte, err error)

func (*AnalysisRun) MarshalTo added in v1.0.0 

func (m *AnalysisRun) MarshalTo(dAtA []byte) (int, error)

func (*AnalysisRun) MarshalToSizedBuffer added in v1.0.0 

func (m *AnalysisRun) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AnalysisRun) ProtoMessage added in v1.0.0 

func (*AnalysisRun) ProtoMessage()

func (*AnalysisRun) Reset added in v1.0.0 

func (m *AnalysisRun) Reset()

func (*AnalysisRun) Size added in v1.0.0 

func (m *AnalysisRun) Size() (n int)

func (*AnalysisRun) String added in v1.0.0 

func (this *AnalysisRun) String() string

func (*AnalysisRun) Unmarshal added in v1.0.0 

func (m *AnalysisRun) Unmarshal(dAtA []byte) error

func (*AnalysisRun) XXX_DiscardUnknown added in v1.0.0 

func (m *AnalysisRun) XXX_DiscardUnknown()

func (*AnalysisRun) XXX_Marshal added in v1.0.0 

func (m *AnalysisRun) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalysisRun) XXX_Merge added in v1.0.0 

func (m *AnalysisRun) XXX_Merge(src proto.Message)

func (*AnalysisRun) XXX_Size added in v1.0.0 

func (m *AnalysisRun) XXX_Size() int

func (*AnalysisRun) XXX_Unmarshal added in v1.0.0 

func (m *AnalysisRun) XXX_Unmarshal(b []byte) error

type AnalysisRunArgument added in v0.6.0 

type AnalysisRunArgument struct {
	// Name argument name
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Value a hardcoded value for the argument. This field is a one of field with valueFrom
	Value string `json:"value,omitempty" protobuf:"bytes,2,opt,name=value"`
	// ValueFrom A reference to where the value is stored. This field is a one of field with valueFrom
	ValueFrom *ArgumentValueFrom `json:"valueFrom,omitempty" protobuf:"bytes,3,opt,name=valueFrom"`
}

AnalysisRunArgument argument to add to analysisRun

func (*AnalysisRunArgument) DeepCopy added in v0.6.0 

func (in *AnalysisRunArgument) DeepCopy() *AnalysisRunArgument

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

func (*AnalysisRunArgument) DeepCopyInto added in v0.6.0 

func (in *AnalysisRunArgument) DeepCopyInto(out *AnalysisRunArgument)

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

func (*AnalysisRunArgument) Descriptor added in v1.0.0 

func (*AnalysisRunArgument) Descriptor() ([]byte, []int)

func (*AnalysisRunArgument) Marshal added in v1.0.0 

func (m *AnalysisRunArgument) Marshal() (dAtA []byte, err error)

func (*AnalysisRunArgument) MarshalTo added in v1.0.0 

func (m *AnalysisRunArgument) MarshalTo(dAtA []byte) (int, error)

func (*AnalysisRunArgument) MarshalToSizedBuffer added in v1.0.0 

func (m *AnalysisRunArgument) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AnalysisRunArgument) ProtoMessage added in v1.0.0 

func (*AnalysisRunArgument) ProtoMessage()

func (*AnalysisRunArgument) Reset added in v1.0.0 

func (m *AnalysisRunArgument) Reset()

func (*AnalysisRunArgument) Size added in v1.0.0 

func (m *AnalysisRunArgument) Size() (n int)

func (*AnalysisRunArgument) String added in v1.0.0 

func (this *AnalysisRunArgument) String() string

func (*AnalysisRunArgument) Unmarshal added in v1.0.0 

func (m *AnalysisRunArgument) Unmarshal(dAtA []byte) error

func (*AnalysisRunArgument) XXX_DiscardUnknown added in v1.0.0 

func (m *AnalysisRunArgument) XXX_DiscardUnknown()

func (*AnalysisRunArgument) XXX_Marshal added in v1.0.0 

func (m *AnalysisRunArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalysisRunArgument) XXX_Merge added in v1.0.0 

func (m *AnalysisRunArgument) XXX_Merge(src proto.Message)

func (*AnalysisRunArgument) XXX_Size added in v1.0.0 

func (m *AnalysisRunArgument) XXX_Size() int

func (*AnalysisRunArgument) XXX_Unmarshal added in v1.0.0 

func (m *AnalysisRunArgument) XXX_Unmarshal(b []byte) error

type AnalysisRunList added in v0.6.0 

type AnalysisRunList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           []AnalysisRun `json:"items" protobuf:"bytes,2,rep,name=items"`
}

AnalysisRunList is a list of AnalysisTemplate resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AnalysisRunList) DeepCopy added in v0.6.0 

func (in *AnalysisRunList) DeepCopy() *AnalysisRunList

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

func (*AnalysisRunList) DeepCopyInto added in v0.6.0 

func (in *AnalysisRunList) DeepCopyInto(out *AnalysisRunList)

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

func (*AnalysisRunList) DeepCopyObject added in v0.6.0 

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

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

func (*AnalysisRunList) Descriptor added in v1.0.0 

func (*AnalysisRunList) Descriptor() ([]byte, []int)

func (*AnalysisRunList) Marshal added in v1.0.0 

func (m *AnalysisRunList) Marshal() (dAtA []byte, err error)

func (*AnalysisRunList) MarshalTo added in v1.0.0 

func (m *AnalysisRunList) MarshalTo(dAtA []byte) (int, error)

func (*AnalysisRunList) MarshalToSizedBuffer added in v1.0.0 

func (m *AnalysisRunList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AnalysisRunList) ProtoMessage added in v1.0.0 

func (*AnalysisRunList) ProtoMessage()

func (*AnalysisRunList) Reset added in v1.0.0 

func (m *AnalysisRunList) Reset()

func (*AnalysisRunList) Size added in v1.0.0 

func (m *AnalysisRunList) Size() (n int)

func (*AnalysisRunList) String added in v1.0.0 

func (this *AnalysisRunList) String() string

func (*AnalysisRunList) Unmarshal added in v1.0.0 

func (m *AnalysisRunList) Unmarshal(dAtA []byte) error

func (*AnalysisRunList) XXX_DiscardUnknown added in v1.0.0 

func (m *AnalysisRunList) XXX_DiscardUnknown()

func (*AnalysisRunList) XXX_Marshal added in v1.0.0 

func (m *AnalysisRunList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalysisRunList) XXX_Merge added in v1.0.0 

func (m *AnalysisRunList) XXX_Merge(src proto.Message)

func (*AnalysisRunList) XXX_Size added in v1.0.0 

func (m *AnalysisRunList) XXX_Size() int

func (*AnalysisRunList) XXX_Unmarshal added in v1.0.0 

func (m *AnalysisRunList) XXX_Unmarshal(b []byte) error

type AnalysisRunSpec added in v0.6.0 

type AnalysisRunSpec struct {
	// Metrics contains the list of metrics to query as part of an analysis run
	// +patchMergeKey=name
	// +patchStrategy=merge
	Metrics []Metric `json:"metrics" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=metrics"`
	// Args are the list of arguments used in this run
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	Args []Argument `json:"args,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=args"`
	// Terminate is used to prematurely stop the run (e.g. rollout completed and analysis is no longer desired)
	Terminate bool `json:"terminate,omitempty" protobuf:"varint,3,opt,name=terminate"`
}

AnalysisRunSpec is the spec for a AnalysisRun resource

func (*AnalysisRunSpec) DeepCopy added in v0.6.0 

func (in *AnalysisRunSpec) DeepCopy() *AnalysisRunSpec

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

func (*AnalysisRunSpec) DeepCopyInto added in v0.6.0 

func (in *AnalysisRunSpec) DeepCopyInto(out *AnalysisRunSpec)

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

func (*AnalysisRunSpec) Descriptor added in v1.0.0 

func (*AnalysisRunSpec) Descriptor() ([]byte, []int)

func (*AnalysisRunSpec) Marshal added in v1.0.0 

func (m *AnalysisRunSpec) Marshal() (dAtA []byte, err error)

func (*AnalysisRunSpec) MarshalTo added in v1.0.0 

func (m *AnalysisRunSpec) MarshalTo(dAtA []byte) (int, error)

func (*AnalysisRunSpec) MarshalToSizedBuffer added in v1.0.0 

func (m *AnalysisRunSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AnalysisRunSpec) ProtoMessage added in v1.0.0 

func (*AnalysisRunSpec) ProtoMessage()

func (*AnalysisRunSpec) Reset added in v1.0.0 

func (m *AnalysisRunSpec) Reset()

func (*AnalysisRunSpec) Size added in v1.0.0 

func (m *AnalysisRunSpec) Size() (n int)

func (*AnalysisRunSpec) String added in v1.0.0 

func (this *AnalysisRunSpec) String() string

func (*AnalysisRunSpec) Unmarshal added in v1.0.0 

func (m *AnalysisRunSpec) Unmarshal(dAtA []byte) error

func (*AnalysisRunSpec) XXX_DiscardUnknown added in v1.0.0 

func (m *AnalysisRunSpec) XXX_DiscardUnknown()

func (*AnalysisRunSpec) XXX_Marshal added in v1.0.0 

func (m *AnalysisRunSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalysisRunSpec) XXX_Merge added in v1.0.0 

func (m *AnalysisRunSpec) XXX_Merge(src proto.Message)

func (*AnalysisRunSpec) XXX_Size added in v1.0.0 

func (m *AnalysisRunSpec) XXX_Size() int

func (*AnalysisRunSpec) XXX_Unmarshal added in v1.0.0 

func (m *AnalysisRunSpec) XXX_Unmarshal(b []byte) error

type AnalysisRunStatus added in v0.6.0 

type AnalysisRunStatus struct {
	// Phase is the status of the analysis run
	Phase AnalysisPhase `json:"phase" protobuf:"bytes,1,opt,name=phase,casttype=AnalysisPhase"`
	// Message is a message explaining current status
	Message string `json:"message,omitempty" protobuf:"bytes,2,opt,name=message"`
	// MetricResults contains the metrics collected during the run
	MetricResults []MetricResult `json:"metricResults,omitempty" protobuf:"bytes,3,rep,name=metricResults"`
	// StartedAt indicates when the analysisRun first started
	StartedAt *metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,4,opt,name=startedAt"`
}

AnalysisRunStatus is the status for a AnalysisRun resource

func (*AnalysisRunStatus) DeepCopy added in v0.6.0 

func (in *AnalysisRunStatus) DeepCopy() *AnalysisRunStatus

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

func (*AnalysisRunStatus) DeepCopyInto added in v0.6.0 

func (in *AnalysisRunStatus) DeepCopyInto(out *AnalysisRunStatus)

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

func (*AnalysisRunStatus) Descriptor added in v1.0.0 

func (*AnalysisRunStatus) Descriptor() ([]byte, []int)

func (*AnalysisRunStatus) Marshal added in v1.0.0 

func (m *AnalysisRunStatus) Marshal() (dAtA []byte, err error)

func (*AnalysisRunStatus) MarshalTo added in v1.0.0 

func (m *AnalysisRunStatus) MarshalTo(dAtA []byte) (int, error)

func (*AnalysisRunStatus) MarshalToSizedBuffer added in v1.0.0 

func (m *AnalysisRunStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AnalysisRunStatus) ProtoMessage added in v1.0.0 

func (*AnalysisRunStatus) ProtoMessage()

func (*AnalysisRunStatus) Reset added in v1.0.0 

func (m *AnalysisRunStatus) Reset()

func (*AnalysisRunStatus) Size added in v1.0.0 

func (m *AnalysisRunStatus) Size() (n int)

func (*AnalysisRunStatus) String added in v1.0.0 

func (this *AnalysisRunStatus) String() string

func (*AnalysisRunStatus) Unmarshal added in v1.0.0 

func (m *AnalysisRunStatus) Unmarshal(dAtA []byte) error

func (*AnalysisRunStatus) XXX_DiscardUnknown added in v1.0.0 

func (m *AnalysisRunStatus) XXX_DiscardUnknown()

func (*AnalysisRunStatus) XXX_Marshal added in v1.0.0 

func (m *AnalysisRunStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalysisRunStatus) XXX_Merge added in v1.0.0 

func (m *AnalysisRunStatus) XXX_Merge(src proto.Message)

func (*AnalysisRunStatus) XXX_Size added in v1.0.0 

func (m *AnalysisRunStatus) XXX_Size() int

func (*AnalysisRunStatus) XXX_Unmarshal added in v1.0.0 

func (m *AnalysisRunStatus) XXX_Unmarshal(b []byte) error

type AnalysisTemplate added in v0.6.0 

type AnalysisTemplate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec AnalysisTemplateSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

AnalysisTemplate holds the template for performing canary analysis +genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +kubebuilder:resource:path=analysistemplates,shortName=at

func (*AnalysisTemplate) DeepCopy added in v0.6.0 

func (in *AnalysisTemplate) DeepCopy() *AnalysisTemplate

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

func (*AnalysisTemplate) DeepCopyInto added in v0.6.0 

func (in *AnalysisTemplate) DeepCopyInto(out *AnalysisTemplate)

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

func (*AnalysisTemplate) DeepCopyObject added in v0.6.0 

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

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

func (*AnalysisTemplate) Descriptor added in v1.0.0 

func (*AnalysisTemplate) Descriptor() ([]byte, []int)

func (*AnalysisTemplate) Marshal added in v1.0.0 

func (m *AnalysisTemplate) Marshal() (dAtA []byte, err error)

func (*AnalysisTemplate) MarshalTo added in v1.0.0 

func (m *AnalysisTemplate) MarshalTo(dAtA []byte) (int, error)

func (*AnalysisTemplate) MarshalToSizedBuffer added in v1.0.0 

func (m *AnalysisTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AnalysisTemplate) ProtoMessage added in v1.0.0 

func (*AnalysisTemplate) ProtoMessage()

func (*AnalysisTemplate) Reset added in v1.0.0 

func (m *AnalysisTemplate) Reset()

func (*AnalysisTemplate) Size added in v1.0.0 

func (m *AnalysisTemplate) Size() (n int)

func (*AnalysisTemplate) String added in v1.0.0 

func (this *AnalysisTemplate) String() string

func (*AnalysisTemplate) Unmarshal added in v1.0.0 

func (m *AnalysisTemplate) Unmarshal(dAtA []byte) error

func (*AnalysisTemplate) XXX_DiscardUnknown added in v1.0.0 

func (m *AnalysisTemplate) XXX_DiscardUnknown()

func (*AnalysisTemplate) XXX_Marshal added in v1.0.0 

func (m *AnalysisTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalysisTemplate) XXX_Merge added in v1.0.0 

func (m *AnalysisTemplate) XXX_Merge(src proto.Message)

func (*AnalysisTemplate) XXX_Size added in v1.0.0 

func (m *AnalysisTemplate) XXX_Size() int

func (*AnalysisTemplate) XXX_Unmarshal added in v1.0.0 

func (m *AnalysisTemplate) XXX_Unmarshal(b []byte) error

type AnalysisTemplateList added in v0.6.0 

type AnalysisTemplateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           []AnalysisTemplate `json:"items" protobuf:"bytes,2,rep,name=items"`
}

AnalysisTemplateList is a list of AnalysisTemplate resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AnalysisTemplateList) DeepCopy added in v0.6.0 

func (in *AnalysisTemplateList) DeepCopy() *AnalysisTemplateList

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

func (*AnalysisTemplateList) DeepCopyInto added in v0.6.0 

func (in *AnalysisTemplateList) DeepCopyInto(out *AnalysisTemplateList)

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

func (*AnalysisTemplateList) DeepCopyObject added in v0.6.0 

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

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

func (*AnalysisTemplateList) Descriptor added in v1.0.0 

func (*AnalysisTemplateList) Descriptor() ([]byte, []int)

func (*AnalysisTemplateList) Marshal added in v1.0.0 

func (m *AnalysisTemplateList) Marshal() (dAtA []byte, err error)

func (*AnalysisTemplateList) MarshalTo added in v1.0.0 

func (m *AnalysisTemplateList) MarshalTo(dAtA []byte) (int, error)

func (*AnalysisTemplateList) MarshalToSizedBuffer added in v1.0.0 

func (m *AnalysisTemplateList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AnalysisTemplateList) ProtoMessage added in v1.0.0 

func (*AnalysisTemplateList) ProtoMessage()

func (*AnalysisTemplateList) Reset added in v1.0.0 

func (m *AnalysisTemplateList) Reset()

func (*AnalysisTemplateList) Size added in v1.0.0 

func (m *AnalysisTemplateList) Size() (n int)

func (*AnalysisTemplateList) String added in v1.0.0 

func (this *AnalysisTemplateList) String() string

func (*AnalysisTemplateList) Unmarshal added in v1.0.0 

func (m *AnalysisTemplateList) Unmarshal(dAtA []byte) error

func (*AnalysisTemplateList) XXX_DiscardUnknown added in v1.0.0 

func (m *AnalysisTemplateList) XXX_DiscardUnknown()

func (*AnalysisTemplateList) XXX_Marshal added in v1.0.0 

func (m *AnalysisTemplateList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalysisTemplateList) XXX_Merge added in v1.0.0 

func (m *AnalysisTemplateList) XXX_Merge(src proto.Message)

func (*AnalysisTemplateList) XXX_Size added in v1.0.0 

func (m *AnalysisTemplateList) XXX_Size() int

func (*AnalysisTemplateList) XXX_Unmarshal added in v1.0.0 

func (m *AnalysisTemplateList) XXX_Unmarshal(b []byte) error

type AnalysisTemplateSpec added in v0.6.0 

type AnalysisTemplateSpec struct {
	// Metrics contains the list of metrics to query as part of an analysis run
	// +patchMergeKey=name
	// +patchStrategy=merge
	Metrics []Metric `json:"metrics" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=metrics"`
	// Args are the list of arguments to the template
	// +patchMergeKey=name
	// +patchStrategy=merge
	// +optional
	Args []Argument `json:"args,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=args"`
}

AnalysisTemplateSpec is the specification for a AnalysisTemplate resource

func (*AnalysisTemplateSpec) DeepCopy added in v0.6.0 

func (in *AnalysisTemplateSpec) DeepCopy() *AnalysisTemplateSpec

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

func (*AnalysisTemplateSpec) DeepCopyInto added in v0.6.0 

func (in *AnalysisTemplateSpec) DeepCopyInto(out *AnalysisTemplateSpec)

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

func (*AnalysisTemplateSpec) Descriptor added in v1.0.0 

func (*AnalysisTemplateSpec) Descriptor() ([]byte, []int)

func (*AnalysisTemplateSpec) Marshal added in v1.0.0 

func (m *AnalysisTemplateSpec) Marshal() (dAtA []byte, err error)

func (*AnalysisTemplateSpec) MarshalTo added in v1.0.0 

func (m *AnalysisTemplateSpec) MarshalTo(dAtA []byte) (int, error)

func (*AnalysisTemplateSpec) MarshalToSizedBuffer added in v1.0.0 

func (m *AnalysisTemplateSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AnalysisTemplateSpec) ProtoMessage added in v1.0.0 

func (*AnalysisTemplateSpec) ProtoMessage()

func (*AnalysisTemplateSpec) Reset added in v1.0.0 

func (m *AnalysisTemplateSpec) Reset()

func (*AnalysisTemplateSpec) Size added in v1.0.0 

func (m *AnalysisTemplateSpec) Size() (n int)

func (*AnalysisTemplateSpec) String added in v1.0.0 

func (this *AnalysisTemplateSpec) String() string

func (*AnalysisTemplateSpec) Unmarshal added in v1.0.0 

func (m *AnalysisTemplateSpec) Unmarshal(dAtA []byte) error

func (*AnalysisTemplateSpec) XXX_DiscardUnknown added in v1.0.0 

func (m *AnalysisTemplateSpec) XXX_DiscardUnknown()

func (*AnalysisTemplateSpec) XXX_Marshal added in v1.0.0 

func (m *AnalysisTemplateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AnalysisTemplateSpec) XXX_Merge added in v1.0.0 

func (m *AnalysisTemplateSpec) XXX_Merge(src proto.Message)

func (*AnalysisTemplateSpec) XXX_Size added in v1.0.0 

func (m *AnalysisTemplateSpec) XXX_Size() int

func (*AnalysisTemplateSpec) XXX_Unmarshal added in v1.0.0 

func (m *AnalysisTemplateSpec) XXX_Unmarshal(b []byte) error

type AntiAffinity added in v0.8.0 

type AntiAffinity struct {
	// +optional
	PreferredDuringSchedulingIgnoredDuringExecution *PreferredDuringSchedulingIgnoredDuringExecution `` /* 140-byte string literal not displayed */
	// +optional
	RequiredDuringSchedulingIgnoredDuringExecution *RequiredDuringSchedulingIgnoredDuringExecution `` /* 138-byte string literal not displayed */
}

AntiAffinity defines which inter-pod scheduling rule to use for anti-affinity injection

func (*AntiAffinity) DeepCopy added in v0.8.0 

func (in *AntiAffinity) DeepCopy() *AntiAffinity

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

func (*AntiAffinity) DeepCopyInto added in v0.8.0 

func (in *AntiAffinity) DeepCopyInto(out *AntiAffinity)

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

func (*AntiAffinity) Descriptor added in v1.0.0 

func (*AntiAffinity) Descriptor() ([]byte, []int)

func (*AntiAffinity) Marshal added in v1.0.0 

func (m *AntiAffinity) Marshal() (dAtA []byte, err error)

func (*AntiAffinity) MarshalTo added in v1.0.0 

func (m *AntiAffinity) MarshalTo(dAtA []byte) (int, error)

func (*AntiAffinity) MarshalToSizedBuffer added in v1.0.0 

func (m *AntiAffinity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AntiAffinity) ProtoMessage added in v1.0.0 

func (*AntiAffinity) ProtoMessage()

func (*AntiAffinity) Reset added in v1.0.0 

func (m *AntiAffinity) Reset()

func (*AntiAffinity) Size added in v1.0.0 

func (m *AntiAffinity) Size() (n int)

func (*AntiAffinity) String added in v1.0.0 

func (this *AntiAffinity) String() string

func (*AntiAffinity) Unmarshal added in v1.0.0 

func (m *AntiAffinity) Unmarshal(dAtA []byte) error

func (*AntiAffinity) XXX_DiscardUnknown added in v1.0.0 

func (m *AntiAffinity) XXX_DiscardUnknown()

func (*AntiAffinity) XXX_Marshal added in v1.0.0 

func (m *AntiAffinity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AntiAffinity) XXX_Merge added in v1.0.0 

func (m *AntiAffinity) XXX_Merge(src proto.Message)

func (*AntiAffinity) XXX_Size added in v1.0.0 

func (m *AntiAffinity) XXX_Size() int

func (*AntiAffinity) XXX_Unmarshal added in v1.0.0 

func (m *AntiAffinity) XXX_Unmarshal(b []byte) error

type Argument added in v0.6.0 

type Argument struct {
	// Name is the name of the argument
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Value is the value of the argument
	// +optional
	Value *string `json:"value,omitempty" protobuf:"bytes,2,opt,name=value"`
	// ValueFrom is a reference to where a secret is stored. This field is one of the fields with valueFrom
	// +optional
	ValueFrom *ValueFrom `json:"valueFrom,omitempty" protobuf:"bytes,3,opt,name=valueFrom"`
}

Argument is an argument to an AnalysisRun

func (*Argument) DeepCopy added in v0.6.0 

func (in *Argument) DeepCopy() *Argument

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

func (*Argument) DeepCopyInto added in v0.6.0 

func (in *Argument) DeepCopyInto(out *Argument)

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

func (*Argument) Descriptor added in v1.0.0 

func (*Argument) Descriptor() ([]byte, []int)

func (*Argument) Marshal added in v1.0.0 

func (m *Argument) Marshal() (dAtA []byte, err error)

func (*Argument) MarshalTo added in v1.0.0 

func (m *Argument) MarshalTo(dAtA []byte) (int, error)

func (*Argument) MarshalToSizedBuffer added in v1.0.0 

func (m *Argument) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Argument) ProtoMessage added in v1.0.0 

func (*Argument) ProtoMessage()

func (*Argument) Reset added in v1.0.0 

func (m *Argument) Reset()

func (*Argument) Size added in v1.0.0 

func (m *Argument) Size() (n int)

func (*Argument) String added in v1.0.0 

func (this *Argument) String() string

func (*Argument) Unmarshal added in v1.0.0 

func (m *Argument) Unmarshal(dAtA []byte) error

func (*Argument) XXX_DiscardUnknown added in v1.0.0 

func (m *Argument) XXX_DiscardUnknown()

func (*Argument) XXX_Marshal added in v1.0.0 

func (m *Argument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Argument) XXX_Merge added in v1.0.0 

func (m *Argument) XXX_Merge(src proto.Message)

func (*Argument) XXX_Size added in v1.0.0 

func (m *Argument) XXX_Size() int

func (*Argument) XXX_Unmarshal added in v1.0.0 

func (m *Argument) XXX_Unmarshal(b []byte) error

type ArgumentValueFrom added in v0.6.0 

type ArgumentValueFrom struct {
	// PodTemplateHashValue gets the value from one of the children ReplicaSet's Pod Template Hash
	PodTemplateHashValue *ValueFromPodTemplateHash `json:"podTemplateHashValue,omitempty" protobuf:"bytes,1,opt,name=podTemplateHashValue,casttype=ValueFromPodTemplateHash"`
	//FieldRef
	FieldRef *FieldRef `json:"fieldRef,omitempty" protobuf:"bytes,2,opt,name=fieldRef"`
}

ArgumentValueFrom defines references to fields within resources to grab for the value (i.e. Pod Template Hash)

func (*ArgumentValueFrom) DeepCopy added in v0.6.0 

func (in *ArgumentValueFrom) DeepCopy() *ArgumentValueFrom

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

func (*ArgumentValueFrom) DeepCopyInto added in v0.6.0 

func (in *ArgumentValueFrom) DeepCopyInto(out *ArgumentValueFrom)

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

func (*ArgumentValueFrom) Descriptor added in v1.0.0 

func (*ArgumentValueFrom) Descriptor() ([]byte, []int)

func (*ArgumentValueFrom) Marshal added in v1.0.0 

func (m *ArgumentValueFrom) Marshal() (dAtA []byte, err error)

func (*ArgumentValueFrom) MarshalTo added in v1.0.0 

func (m *ArgumentValueFrom) MarshalTo(dAtA []byte) (int, error)

func (*ArgumentValueFrom) MarshalToSizedBuffer added in v1.0.0 

func (m *ArgumentValueFrom) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ArgumentValueFrom) ProtoMessage added in v1.0.0 

func (*ArgumentValueFrom) ProtoMessage()

func (*ArgumentValueFrom) Reset added in v1.0.0 

func (m *ArgumentValueFrom) Reset()

func (*ArgumentValueFrom) Size added in v1.0.0 

func (m *ArgumentValueFrom) Size() (n int)

func (*ArgumentValueFrom) String added in v1.0.0 

func (this *ArgumentValueFrom) String() string

func (*ArgumentValueFrom) Unmarshal added in v1.0.0 

func (m *ArgumentValueFrom) Unmarshal(dAtA []byte) error

func (*ArgumentValueFrom) XXX_DiscardUnknown added in v1.0.0 

func (m *ArgumentValueFrom) XXX_DiscardUnknown()

func (*ArgumentValueFrom) XXX_Marshal added in v1.0.0 

func (m *ArgumentValueFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArgumentValueFrom) XXX_Merge added in v1.0.0 

func (m *ArgumentValueFrom) XXX_Merge(src proto.Message)

func (*ArgumentValueFrom) XXX_Size added in v1.0.0 

func (m *ArgumentValueFrom) XXX_Size() int

func (*ArgumentValueFrom) XXX_Unmarshal added in v1.0.0 

func (m *ArgumentValueFrom) XXX_Unmarshal(b []byte) error

type BlueGreenStatus added in v0.2.0 

type BlueGreenStatus struct {
	// PreviewSelector indicates which replicas set the preview service is serving traffic to
	// +optional
	PreviewSelector string `json:"previewSelector,omitempty" protobuf:"bytes,1,opt,name=previewSelector"`
	// ActiveSelector indicates which replicas set the active service is serving traffic to
	// +optional
	ActiveSelector string `json:"activeSelector,omitempty" protobuf:"bytes,2,opt,name=activeSelector"`
	// ScaleUpPreviewCheckPoint indicates that the Replicaset receiving traffic from the preview service is ready to be scaled up after the rollout is unpaused
	// +optional
	ScaleUpPreviewCheckPoint bool `json:"scaleUpPreviewCheckPoint,omitempty" protobuf:"varint,3,opt,name=scaleUpPreviewCheckPoint"`
	// PrePromotionAnalysisRunStatus indicates the status of the current prepromotion analysis run
	PrePromotionAnalysisRunStatus *RolloutAnalysisRunStatus `json:"prePromotionAnalysisRunStatus,omitempty" protobuf:"bytes,4,opt,name=prePromotionAnalysisRunStatus"`
	// PostPromotionAnalysisRunStatus indicates the status of the current post promotion analysis run
	PostPromotionAnalysisRunStatus *RolloutAnalysisRunStatus `json:"postPromotionAnalysisRunStatus,omitempty" protobuf:"bytes,5,opt,name=postPromotionAnalysisRunStatus"`
}

BlueGreenStatus status fields that only pertain to the blueGreen rollout

func (*BlueGreenStatus) DeepCopy added in v0.2.0 

func (in *BlueGreenStatus) DeepCopy() *BlueGreenStatus

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

func (*BlueGreenStatus) DeepCopyInto added in v0.2.0 

func (in *BlueGreenStatus) DeepCopyInto(out *BlueGreenStatus)

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

func (*BlueGreenStatus) Descriptor added in v1.0.0 

func (*BlueGreenStatus) Descriptor() ([]byte, []int)

func (*BlueGreenStatus) Marshal added in v1.0.0 

func (m *BlueGreenStatus) Marshal() (dAtA []byte, err error)

func (*BlueGreenStatus) MarshalTo added in v1.0.0 

func (m *BlueGreenStatus) MarshalTo(dAtA []byte) (int, error)

func (*BlueGreenStatus) MarshalToSizedBuffer added in v1.0.0 

func (m *BlueGreenStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlueGreenStatus) ProtoMessage added in v1.0.0 

func (*BlueGreenStatus) ProtoMessage()

func (*BlueGreenStatus) Reset added in v1.0.0 

func (m *BlueGreenStatus) Reset()

func (*BlueGreenStatus) Size added in v1.0.0 

func (m *BlueGreenStatus) Size() (n int)

func (*BlueGreenStatus) String added in v1.0.0 

func (this *BlueGreenStatus) String() string

func (*BlueGreenStatus) Unmarshal added in v1.0.0 

func (m *BlueGreenStatus) Unmarshal(dAtA []byte) error

func (*BlueGreenStatus) XXX_DiscardUnknown added in v1.0.0 

func (m *BlueGreenStatus) XXX_DiscardUnknown()

func (*BlueGreenStatus) XXX_Marshal added in v1.0.0 

func (m *BlueGreenStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlueGreenStatus) XXX_Merge added in v1.0.0 

func (m *BlueGreenStatus) XXX_Merge(src proto.Message)

func (*BlueGreenStatus) XXX_Size added in v1.0.0 

func (m *BlueGreenStatus) XXX_Size() int

func (*BlueGreenStatus) XXX_Unmarshal added in v1.0.0 

func (m *BlueGreenStatus) XXX_Unmarshal(b []byte) error

type BlueGreenStrategy 

type BlueGreenStrategy struct {
	// Name of the service that the rollout modifies as the active service.
	ActiveService string `json:"activeService" protobuf:"bytes,1,opt,name=activeService"`
	// Name of the service that the rollout modifies as the preview service.
	// +optional
	PreviewService string `json:"previewService,omitempty" protobuf:"bytes,2,opt,name=previewService"`
	// PreviewReplicaCount is the number of replicas to run for the preview stack before the
	// switchover. Once the rollout is resumed the desired replicaset will be full scaled up before the switch occurs
	// +optional
	PreviewReplicaCount *int32 `json:"previewReplicaCount,omitempty" protobuf:"varint,3,opt,name=previewReplicaCount"`
	// AutoPromotionEnabled indicates if the rollout should automatically promote the new ReplicaSet
	// to the active service or enter a paused state. If not specified, the default value is true.
	// +optional
	AutoPromotionEnabled *bool `json:"autoPromotionEnabled,omitempty" protobuf:"varint,4,opt,name=autoPromotionEnabled"`
	// AutoPromotionSeconds is a duration in seconds in which to delay auto-promotion (default: 0).
	// The countdown begins after the preview ReplicaSet have reached full availability.
	// This option is ignored if autoPromotionEnabled is set to false.
	// +optional
	AutoPromotionSeconds int32 `json:"autoPromotionSeconds,omitempty" protobuf:"varint,5,opt,name=autoPromotionSeconds"`
	// MaxUnavailable The maximum number of pods that can be unavailable during a restart operation.
	// Defaults to 25% of total replicas.
	// +optional
	MaxUnavailable *intstr.IntOrString `json:"maxUnavailable,omitempty" protobuf:"bytes,6,opt,name=maxUnavailable"`
	// ScaleDownDelaySeconds adds a delay before scaling down the previous replicaset.
	// If omitted, the Rollout waits 30 seconds before scaling down the previous ReplicaSet.
	// A minimum of 30 seconds is recommended to ensure IP table propagation across the nodes in
	// a cluster. See https://github.com/argoproj/argo-rollouts/issues/19#issuecomment-476329960 for
	// more information
	// +optional
	ScaleDownDelaySeconds *int32 `json:"scaleDownDelaySeconds,omitempty" protobuf:"varint,7,opt,name=scaleDownDelaySeconds"`
	// ScaleDownDelayRevisionLimit limits the number of old RS that can run at one time before getting scaled down
	// +optional
	ScaleDownDelayRevisionLimit *int32 `json:"scaleDownDelayRevisionLimit,omitempty" protobuf:"varint,8,opt,name=scaleDownDelayRevisionLimit"`
	// PrePromotionAnalysis configuration to run analysis before a selector switch
	PrePromotionAnalysis *RolloutAnalysis `json:"prePromotionAnalysis,omitempty" protobuf:"bytes,9,opt,name=prePromotionAnalysis"`
	// AntiAffinity enables anti-affinity rules for Blue Green deployment
	// +optional
	AntiAffinity *AntiAffinity `json:"antiAffinity,omitempty" protobuf:"bytes,10,opt,name=antiAffinity"`
	// PostPromotionAnalysis configuration to run analysis after a selector switch
	PostPromotionAnalysis *RolloutAnalysis `json:"postPromotionAnalysis,omitempty" protobuf:"bytes,11,opt,name=postPromotionAnalysis"`
	// PreviewMetadata specify labels and annotations which will be attached to the preview pods for
	// the duration which they act as a preview pod, and will be removed after
	PreviewMetadata *PodTemplateMetadata `json:"previewMetadata,omitempty" protobuf:"bytes,12,opt,name=previewMetadata"`
	// ActiveMetadata specify labels and annotations which will be attached to the active pods for
	// the duration which they act as a active pod, and will be removed after
	ActiveMetadata *PodTemplateMetadata `json:"activeMetadata,omitempty" protobuf:"bytes,13,opt,name=activeMetadata"`
}

BlueGreenStrategy defines parameters for Blue Green deployment

func (*BlueGreenStrategy) DeepCopy 

func (in *BlueGreenStrategy) DeepCopy() *BlueGreenStrategy

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

func (*BlueGreenStrategy) DeepCopyInto 

func (in *BlueGreenStrategy) DeepCopyInto(out *BlueGreenStrategy)

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

func (*BlueGreenStrategy) Descriptor added in v1.0.0 

func (*BlueGreenStrategy) Descriptor() ([]byte, []int)

func (*BlueGreenStrategy) Marshal added in v1.0.0 

func (m *BlueGreenStrategy) Marshal() (dAtA []byte, err error)

func (*BlueGreenStrategy) MarshalTo added in v1.0.0 

func (m *BlueGreenStrategy) MarshalTo(dAtA []byte) (int, error)

func (*BlueGreenStrategy) MarshalToSizedBuffer added in v1.0.0 

func (m *BlueGreenStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlueGreenStrategy) ProtoMessage added in v1.0.0 

func (*BlueGreenStrategy) ProtoMessage()

func (*BlueGreenStrategy) Reset added in v1.0.0 

func (m *BlueGreenStrategy) Reset()

func (*BlueGreenStrategy) Size added in v1.0.0 

func (m *BlueGreenStrategy) Size() (n int)

func (*BlueGreenStrategy) String added in v1.0.0 

func (this *BlueGreenStrategy) String() string

func (*BlueGreenStrategy) Unmarshal added in v1.0.0 

func (m *BlueGreenStrategy) Unmarshal(dAtA []byte) error

func (*BlueGreenStrategy) XXX_DiscardUnknown added in v1.0.0 

func (m *BlueGreenStrategy) XXX_DiscardUnknown()

func (*BlueGreenStrategy) XXX_Marshal added in v1.0.0 

func (m *BlueGreenStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlueGreenStrategy) XXX_Merge added in v1.0.0 

func (m *BlueGreenStrategy) XXX_Merge(src proto.Message)

func (*BlueGreenStrategy) XXX_Size added in v1.0.0 

func (m *BlueGreenStrategy) XXX_Size() int

func (*BlueGreenStrategy) XXX_Unmarshal added in v1.0.0 

func (m *BlueGreenStrategy) XXX_Unmarshal(b []byte) error

type CanaryStatus added in v0.2.0 

type CanaryStatus struct {
	// CurrentStepAnalysisRunStatus indicates the status of the current step analysis run
	CurrentStepAnalysisRunStatus *RolloutAnalysisRunStatus `json:"currentStepAnalysisRunStatus,omitempty" protobuf:"bytes,1,opt,name=currentStepAnalysisRunStatus"`
	// CurrentBackgroundAnalysisRunStatus indicates the status of the current background analysis run
	CurrentBackgroundAnalysisRunStatus *RolloutAnalysisRunStatus `json:"currentBackgroundAnalysisRunStatus,omitempty" protobuf:"bytes,2,opt,name=currentBackgroundAnalysisRunStatus"`
	// CurrentExperiment indicates the running experiment
	CurrentExperiment string `json:"currentExperiment,omitempty" protobuf:"bytes,3,opt,name=currentExperiment"`
}

CanaryStatus status fields that only pertain to the canary rollout

func (*CanaryStatus) DeepCopy added in v0.2.0 

func (in *CanaryStatus) DeepCopy() *CanaryStatus

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

func (*CanaryStatus) DeepCopyInto added in v0.2.0 

func (in *CanaryStatus) DeepCopyInto(out *CanaryStatus)

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

func (*CanaryStatus) Descriptor added in v1.0.0 

func (*CanaryStatus) Descriptor() ([]byte, []int)

func (*CanaryStatus) Marshal added in v1.0.0 

func (m *CanaryStatus) Marshal() (dAtA []byte, err error)

func (*CanaryStatus) MarshalTo added in v1.0.0 

func (m *CanaryStatus) MarshalTo(dAtA []byte) (int, error)

func (*CanaryStatus) MarshalToSizedBuffer added in v1.0.0 

func (m *CanaryStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CanaryStatus) ProtoMessage added in v1.0.0 

func (*CanaryStatus) ProtoMessage()

func (*CanaryStatus) Reset added in v1.0.0 

func (m *CanaryStatus) Reset()

func (*CanaryStatus) Size added in v1.0.0 

func (m *CanaryStatus) Size() (n int)

func (*CanaryStatus) String added in v1.0.0 

func (this *CanaryStatus) String() string

func (*CanaryStatus) Unmarshal added in v1.0.0 

func (m *CanaryStatus) Unmarshal(dAtA []byte) error

func (*CanaryStatus) XXX_DiscardUnknown added in v1.0.0 

func (m *CanaryStatus) XXX_DiscardUnknown()

func (*CanaryStatus) XXX_Marshal added in v1.0.0 

func (m *CanaryStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CanaryStatus) XXX_Merge added in v1.0.0 

func (m *CanaryStatus) XXX_Merge(src proto.Message)

func (*CanaryStatus) XXX_Size added in v1.0.0 

func (m *CanaryStatus) XXX_Size() int

func (*CanaryStatus) XXX_Unmarshal added in v1.0.0 

func (m *CanaryStatus) XXX_Unmarshal(b []byte) error

type CanaryStep added in v0.2.0 

type CanaryStep struct {
	// SetWeight sets what percentage of the newRS should receive
	SetWeight *int32 `json:"setWeight,omitempty" protobuf:"varint,1,opt,name=setWeight"`
	// Pause freezes the rollout by setting spec.Paused to true.
	// A Rollout will resume when spec.Paused is reset to false.
	// +optional
	Pause *RolloutPause `json:"pause,omitempty" protobuf:"bytes,2,opt,name=pause"`
	// Experiment defines the experiment object that should be created
	Experiment *RolloutExperimentStep `json:"experiment,omitempty" protobuf:"bytes,3,opt,name=experiment"`
	// Analysis defines the AnalysisRun that will run for a step
	Analysis *RolloutAnalysis `json:"analysis,omitempty" protobuf:"bytes,4,opt,name=analysis"`
	// SetCanaryScale defines how to scale the newRS without changing traffic weight
	// +optional
	SetCanaryScale *SetCanaryScale `json:"setCanaryScale,omitempty" protobuf:"bytes,5,opt,name=setCanaryScale"`
}

CanaryStep defines a step of a canary deployment.

func (*CanaryStep) DeepCopy added in v0.2.0 

func (in *CanaryStep) DeepCopy() *CanaryStep

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

func (*CanaryStep) DeepCopyInto added in v0.2.0 

func (in *CanaryStep) DeepCopyInto(out *CanaryStep)

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

func (*CanaryStep) Descriptor added in v1.0.0 

func (*CanaryStep) Descriptor() ([]byte, []int)

func (*CanaryStep) Marshal added in v1.0.0 

func (m *CanaryStep) Marshal() (dAtA []byte, err error)

func (*CanaryStep) MarshalTo added in v1.0.0 

func (m *CanaryStep) MarshalTo(dAtA []byte) (int, error)

func (*CanaryStep) MarshalToSizedBuffer added in v1.0.0 

func (m *CanaryStep) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CanaryStep) ProtoMessage added in v1.0.0 

func (*CanaryStep) ProtoMessage()

func (*CanaryStep) Reset added in v1.0.0 

func (m *CanaryStep) Reset()

func (*CanaryStep) Size added in v1.0.0 

func (m *CanaryStep) Size() (n int)

func (*CanaryStep) String added in v1.0.0 

func (this *CanaryStep) String() string

func (*CanaryStep) Unmarshal added in v1.0.0 

func (m *CanaryStep) Unmarshal(dAtA []byte) error

func (*CanaryStep) XXX_DiscardUnknown added in v1.0.0 

func (m *CanaryStep) XXX_DiscardUnknown()

func (*CanaryStep) XXX_Marshal added in v1.0.0 

func (m *CanaryStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CanaryStep) XXX_Merge added in v1.0.0 

func (m *CanaryStep) XXX_Merge(src proto.Message)

func (*CanaryStep) XXX_Size added in v1.0.0 

func (m *CanaryStep) XXX_Size() int

func (*CanaryStep) XXX_Unmarshal added in v1.0.0 

func (m *CanaryStep) XXX_Unmarshal(b []byte) error

type CanaryStrategy added in v0.2.0 

type CanaryStrategy struct {
	// CanaryService holds the name of a service which selects pods with canary version and don't select any pods with stable version.
	// +optional
	CanaryService string `json:"canaryService,omitempty" protobuf:"bytes,1,opt,name=canaryService"`
	// StableService holds the name of a service which selects pods with stable version and don't select any pods with canary version.
	// +optional
	StableService string `json:"stableService,omitempty" protobuf:"bytes,2,opt,name=stableService"`
	// Steps define the order of phases to execute the canary deployment
	// +optional
	Steps []CanaryStep `json:"steps,omitempty" protobuf:"bytes,3,rep,name=steps"`
	// TrafficRouting hosts all the supported service meshes supported to enable more fine-grained traffic routing
	TrafficRouting *RolloutTrafficRouting `json:"trafficRouting,omitempty" protobuf:"bytes,4,opt,name=trafficRouting"`

	// MaxUnavailable The maximum number of pods that can be unavailable during the update.
	// Value can be an absolute number (ex: 5) or a percentage of total pods at the start of update (ex: 10%).
	// Absolute number is calculated from percentage by rounding down.
	// This can not be 0 if MaxSurge is 0.
	// By default, a fixed value of 25% is used.
	// Example: when this is set to 30%, the old RC can be scaled down by 30%
	// immediately when the rolling update starts. Once new pods are ready, old RC
	// can be scaled down further, followed by scaling up the new RC, ensuring
	// that at least 70% of original number of pods are available at all times
	// during the update.
	// +optional
	MaxUnavailable *intstr.IntOrString `json:"maxUnavailable,omitempty" protobuf:"bytes,5,opt,name=maxUnavailable"`

	// MaxSurge The maximum number of pods that can be scheduled above the original number of
	// pods.
	// Value can be an absolute number (ex: 5) or a percentage of total pods at
	// the start of the update (ex: 10%). This can not be 0 if MaxUnavailable is 0.
	// Absolute number is calculated from percentage by rounding up.
	// By default, a value of 25% is used.
	// Example: when this is set to 30%, the new RC can be scaled up by 30%
	// immediately when the rolling update starts. Once old pods have been killed,
	// new RC can be scaled up further, ensuring that total number of pods running
	// at any time during the update is at most 130% of original pods.
	// +optional
	MaxSurge *intstr.IntOrString `json:"maxSurge,omitempty" protobuf:"bytes,6,opt,name=maxSurge"`
	// Analysis runs a separate analysisRun while all the steps execute. This is intended to be a continuous validation of the new ReplicaSet
	Analysis *RolloutAnalysisBackground `json:"analysis,omitempty" protobuf:"bytes,7,opt,name=analysis"`
	// AntiAffinity enables anti-affinity rules for Canary deployment
	// +optional
	AntiAffinity *AntiAffinity `json:"antiAffinity,omitempty" protobuf:"bytes,8,opt,name=antiAffinity"`
	// CanaryMetadata specify labels and annotations which will be attached to the canary pods for
	// the duration which they act as a canary, and will be removed after
	CanaryMetadata *PodTemplateMetadata `json:"canaryMetadata,omitempty" protobuf:"bytes,9,opt,name=canaryMetadata"`
	// StableMetadata specify labels and annotations which will be attached to the stable pods for
	// the duration which they act as a canary, and will be removed after
	StableMetadata *PodTemplateMetadata `json:"stableMetadata,omitempty" protobuf:"bytes,10,opt,name=stableMetadata"`

	// ScaleDownDelaySeconds adds a delay before scaling down the previous ReplicaSet when the
	// canary strategy is used with traffic routing (default 30 seconds). A delay in scaling down
	// the previous ReplicaSet is needed after switching the stable service selector to point to
	// the new ReplicaSet, in order to give time for traffic providers to re-target the new pods.
	// This value is ignored with basic, replica-weighted canary without traffic routing.
	// +optional
	ScaleDownDelaySeconds *int32 `json:"scaleDownDelaySeconds,omitempty" protobuf:"varint,11,opt,name=scaleDownDelaySeconds"`
	// ScaleDownDelayRevisionLimit limits the number of old RS that can run at one time before getting scaled down
	// +optional
	ScaleDownDelayRevisionLimit *int32 `json:"scaleDownDelayRevisionLimit,omitempty" protobuf:"varint,12,opt,name=scaleDownDelayRevisionLimit"`
}

CanaryStrategy defines parameters for a Replica Based Canary

func (*CanaryStrategy) DeepCopy added in v0.2.0 

func (in *CanaryStrategy) DeepCopy() *CanaryStrategy

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

func (*CanaryStrategy) DeepCopyInto added in v0.2.0 

func (in *CanaryStrategy) DeepCopyInto(out *CanaryStrategy)

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

func (*CanaryStrategy) Descriptor added in v1.0.0 

func (*CanaryStrategy) Descriptor() ([]byte, []int)

func (*CanaryStrategy) Marshal added in v1.0.0 

func (m *CanaryStrategy) Marshal() (dAtA []byte, err error)

func (*CanaryStrategy) MarshalTo added in v1.0.0 

func (m *CanaryStrategy) MarshalTo(dAtA []byte) (int, error)

func (*CanaryStrategy) MarshalToSizedBuffer added in v1.0.0 

func (m *CanaryStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CanaryStrategy) ProtoMessage added in v1.0.0 

func (*CanaryStrategy) ProtoMessage()

func (*CanaryStrategy) Reset added in v1.0.0 

func (m *CanaryStrategy) Reset()

func (*CanaryStrategy) Size added in v1.0.0 

func (m *CanaryStrategy) Size() (n int)

func (*CanaryStrategy) String added in v1.0.0 

func (this *CanaryStrategy) String() string

func (*CanaryStrategy) Unmarshal added in v1.0.0 

func (m *CanaryStrategy) Unmarshal(dAtA []byte) error

func (*CanaryStrategy) XXX_DiscardUnknown added in v1.0.0 

func (m *CanaryStrategy) XXX_DiscardUnknown()

func (*CanaryStrategy) XXX_Marshal added in v1.0.0 

func (m *CanaryStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CanaryStrategy) XXX_Merge added in v1.0.0 

func (m *CanaryStrategy) XXX_Merge(src proto.Message)

func (*CanaryStrategy) XXX_Size added in v1.0.0 

func (m *CanaryStrategy) XXX_Size() int

func (*CanaryStrategy) XXX_Unmarshal added in v1.0.0 

func (m *CanaryStrategy) XXX_Unmarshal(b []byte) error

type ClusterAnalysisTemplate added in v0.9.0 

type ClusterAnalysisTemplate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec AnalysisTemplateSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

ClusterAnalysisTemplate holds the template for performing canary analysis +genclient +genclient:nonNamespaced +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +kubebuilder:resource:path=clusteranalysistemplates,shortName=cat

func (*ClusterAnalysisTemplate) DeepCopy added in v0.9.0 

func (in *ClusterAnalysisTemplate) DeepCopy() *ClusterAnalysisTemplate

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

func (*ClusterAnalysisTemplate) DeepCopyInto added in v0.9.0 

func (in *ClusterAnalysisTemplate) DeepCopyInto(out *ClusterAnalysisTemplate)

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

func (*ClusterAnalysisTemplate) DeepCopyObject added in v0.9.0 

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

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

func (*ClusterAnalysisTemplate) Descriptor added in v1.0.0 

func (*ClusterAnalysisTemplate) Descriptor() ([]byte, []int)

func (*ClusterAnalysisTemplate) Marshal added in v1.0.0 

func (m *ClusterAnalysisTemplate) Marshal() (dAtA []byte, err error)

func (*ClusterAnalysisTemplate) MarshalTo added in v1.0.0 

func (m *ClusterAnalysisTemplate) MarshalTo(dAtA []byte) (int, error)

func (*ClusterAnalysisTemplate) MarshalToSizedBuffer added in v1.0.0 

func (m *ClusterAnalysisTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterAnalysisTemplate) ProtoMessage added in v1.0.0 

func (*ClusterAnalysisTemplate) ProtoMessage()

func (*ClusterAnalysisTemplate) Reset added in v1.0.0 

func (m *ClusterAnalysisTemplate) Reset()

func (*ClusterAnalysisTemplate) Size added in v1.0.0 

func (m *ClusterAnalysisTemplate) Size() (n int)

func (*ClusterAnalysisTemplate) String added in v1.0.0 

func (this *ClusterAnalysisTemplate) String() string

func (*ClusterAnalysisTemplate) Unmarshal added in v1.0.0 

func (m *ClusterAnalysisTemplate) Unmarshal(dAtA []byte) error

func (*ClusterAnalysisTemplate) XXX_DiscardUnknown added in v1.0.0 

func (m *ClusterAnalysisTemplate) XXX_DiscardUnknown()

func (*ClusterAnalysisTemplate) XXX_Marshal added in v1.0.0 

func (m *ClusterAnalysisTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterAnalysisTemplate) XXX_Merge added in v1.0.0 

func (m *ClusterAnalysisTemplate) XXX_Merge(src proto.Message)

func (*ClusterAnalysisTemplate) XXX_Size added in v1.0.0 

func (m *ClusterAnalysisTemplate) XXX_Size() int

func (*ClusterAnalysisTemplate) XXX_Unmarshal added in v1.0.0 

func (m *ClusterAnalysisTemplate) XXX_Unmarshal(b []byte) error

type ClusterAnalysisTemplateList added in v0.9.0 

type ClusterAnalysisTemplateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Items           []ClusterAnalysisTemplate `json:"items" protobuf:"bytes,2,rep,name=items"`
}

AnalysisTemplateList is a list of AnalysisTemplate resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*ClusterAnalysisTemplateList) DeepCopy added in v0.9.0 

func (in *ClusterAnalysisTemplateList) DeepCopy() *ClusterAnalysisTemplateList

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

func (*ClusterAnalysisTemplateList) DeepCopyInto added in v0.9.0 

func (in *ClusterAnalysisTemplateList) DeepCopyInto(out *ClusterAnalysisTemplateList)

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

func (*ClusterAnalysisTemplateList) DeepCopyObject added in v0.9.0 

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

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

func (*ClusterAnalysisTemplateList) Descriptor added in v1.0.0 

func (*ClusterAnalysisTemplateList) Descriptor() ([]byte, []int)

func (*ClusterAnalysisTemplateList) Marshal added in v1.0.0 

func (m *ClusterAnalysisTemplateList) Marshal() (dAtA []byte, err error)

func (*ClusterAnalysisTemplateList) MarshalTo added in v1.0.0 

func (m *ClusterAnalysisTemplateList) MarshalTo(dAtA []byte) (int, error)

func (*ClusterAnalysisTemplateList) MarshalToSizedBuffer added in v1.0.0 

func (m *ClusterAnalysisTemplateList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterAnalysisTemplateList) ProtoMessage added in v1.0.0 

func (*ClusterAnalysisTemplateList) ProtoMessage()

func (*ClusterAnalysisTemplateList) Reset added in v1.0.0 

func (m *ClusterAnalysisTemplateList) Reset()

func (*ClusterAnalysisTemplateList) Size added in v1.0.0 

func (m *ClusterAnalysisTemplateList) Size() (n int)

func (*ClusterAnalysisTemplateList) String added in v1.0.0 

func (this *ClusterAnalysisTemplateList) String() string

func (*ClusterAnalysisTemplateList) Unmarshal added in v1.0.0 

func (m *ClusterAnalysisTemplateList) Unmarshal(dAtA []byte) error

func (*ClusterAnalysisTemplateList) XXX_DiscardUnknown added in v1.0.0 

func (m *ClusterAnalysisTemplateList) XXX_DiscardUnknown()

func (*ClusterAnalysisTemplateList) XXX_Marshal added in v1.0.0 

func (m *ClusterAnalysisTemplateList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterAnalysisTemplateList) XXX_Merge added in v1.0.0 

func (m *ClusterAnalysisTemplateList) XXX_Merge(src proto.Message)

func (*ClusterAnalysisTemplateList) XXX_Size added in v1.0.0 

func (m *ClusterAnalysisTemplateList) XXX_Size() int

func (*ClusterAnalysisTemplateList) XXX_Unmarshal added in v1.0.0 

func (m *ClusterAnalysisTemplateList) XXX_Unmarshal(b []byte) error

type DatadogMetric added in v0.10.0 

type DatadogMetric struct {
	Interval DurationString `json:"interval,omitempty" protobuf:"bytes,1,opt,name=interval,casttype=DurationString"`
	Query    string         `json:"query" protobuf:"bytes,2,opt,name=query"`
}

func (*DatadogMetric) DeepCopy added in v0.10.0 

func (in *DatadogMetric) DeepCopy() *DatadogMetric

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

func (*DatadogMetric) DeepCopyInto added in v0.10.0 

func (in *DatadogMetric) DeepCopyInto(out *DatadogMetric)

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

func (*DatadogMetric) Descriptor added in v1.0.0 

func (*DatadogMetric) Descriptor() ([]byte, []int)

func (*DatadogMetric) Marshal added in v1.0.0 

func (m *DatadogMetric) Marshal() (dAtA []byte, err error)

func (*DatadogMetric) MarshalTo added in v1.0.0 

func (m *DatadogMetric) MarshalTo(dAtA []byte) (int, error)

func (*DatadogMetric) MarshalToSizedBuffer added in v1.0.0 

func (m *DatadogMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DatadogMetric) ProtoMessage added in v1.0.0 

func (*DatadogMetric) ProtoMessage()

func (*DatadogMetric) Reset added in v1.0.0 

func (m *DatadogMetric) Reset()

func (*DatadogMetric) Size added in v1.0.0 

func (m *DatadogMetric) Size() (n int)

func (*DatadogMetric) String added in v1.0.0 

func (this *DatadogMetric) String() string

func (*DatadogMetric) Unmarshal added in v1.0.0 

func (m *DatadogMetric) Unmarshal(dAtA []byte) error

func (*DatadogMetric) XXX_DiscardUnknown added in v1.0.0 

func (m *DatadogMetric) XXX_DiscardUnknown()

func (*DatadogMetric) XXX_Marshal added in v1.0.0 

func (m *DatadogMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatadogMetric) XXX_Merge added in v1.0.0 

func (m *DatadogMetric) XXX_Merge(src proto.Message)

func (*DatadogMetric) XXX_Size added in v1.0.0 

func (m *DatadogMetric) XXX_Size() int

func (*DatadogMetric) XXX_Unmarshal added in v1.0.0 

func (m *DatadogMetric) XXX_Unmarshal(b []byte) error

type DurationString added in v0.6.0 

type DurationString string

DurationString is a string representing a duration (e.g. 30s, 5m, 1h)

func (DurationString) Duration added in v0.6.0 

func (d DurationString) Duration() (time.Duration, error)

Duration converts DurationString into a time.Duration

type Experiment added in v0.5.0 

type Experiment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   ExperimentSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	Status ExperimentStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

Experiment is a specification for an Experiment resource +genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +kubebuilder:resource:path=experiments,shortName=exp +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase",description="Experiment status"

func (*Experiment) DeepCopy added in v0.5.0 

func (in *Experiment) DeepCopy() *Experiment

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

func (*Experiment) DeepCopyInto added in v0.5.0 

func (in *Experiment) DeepCopyInto(out *Experiment)

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

func (*Experiment) DeepCopyObject added in v0.5.0 

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

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

func (*Experiment) Descriptor added in v1.0.0 

func (*Experiment) Descriptor() ([]byte, []int)

func (*Experiment) Marshal added in v1.0.0 

func (m *Experiment) Marshal() (dAtA []byte, err error)

func (*Experiment) MarshalTo added in v1.0.0 

func (m *Experiment) MarshalTo(dAtA []byte) (int, error)

func (*Experiment) MarshalToSizedBuffer added in v1.0.0 

func (m *Experiment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Experiment) ProtoMessage added in v1.0.0 

func (*Experiment) ProtoMessage()

func (*Experiment) Reset added in v1.0.0 

func (m *Experiment) Reset()

func (*Experiment) Size added in v1.0.0 

func (m *Experiment) Size() (n int)

func (*Experiment) String added in v1.0.0 

func (this *Experiment) String() string

func (*Experiment) Unmarshal added in v1.0.0 

func (m *Experiment) Unmarshal(dAtA []byte) error

func (*Experiment) XXX_DiscardUnknown added in v1.0.0 

func (m *Experiment) XXX_DiscardUnknown()

func (*Experiment) XXX_Marshal added in v1.0.0 

func (m *Experiment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Experiment) XXX_Merge added in v1.0.0 

func (m *Experiment) XXX_Merge(src proto.Message)

func (*Experiment) XXX_Size added in v1.0.0 

func (m *Experiment) XXX_Size() int

func (*Experiment) XXX_Unmarshal added in v1.0.0 

func (m *Experiment) XXX_Unmarshal(b []byte) error

type ExperimentAnalysisRunStatus added in v0.6.0 

type ExperimentAnalysisRunStatus struct {
	// Name is the name of the analysis
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// AnalysisRun is the name of the AnalysisRun
	AnalysisRun string `json:"analysisRun" protobuf:"bytes,2,opt,name=analysisRun"`
	// Phase is the status of the AnalysisRun
	Phase AnalysisPhase `json:"phase" protobuf:"bytes,3,opt,name=phase,casttype=AnalysisPhase"`
	// Message is a message explaining the current status
	Message string `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"`
}

func (*ExperimentAnalysisRunStatus) DeepCopy added in v0.6.0 

func (in *ExperimentAnalysisRunStatus) DeepCopy() *ExperimentAnalysisRunStatus

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

func (*ExperimentAnalysisRunStatus) DeepCopyInto added in v0.6.0 

func (in *ExperimentAnalysisRunStatus) DeepCopyInto(out *ExperimentAnalysisRunStatus)

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

func (*ExperimentAnalysisRunStatus) Descriptor added in v1.0.0 

func (*ExperimentAnalysisRunStatus) Descriptor() ([]byte, []int)

func (*ExperimentAnalysisRunStatus) Marshal added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) Marshal() (dAtA []byte, err error)

func (*ExperimentAnalysisRunStatus) MarshalTo added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) MarshalTo(dAtA []byte) (int, error)

func (*ExperimentAnalysisRunStatus) MarshalToSizedBuffer added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExperimentAnalysisRunStatus) ProtoMessage added in v1.0.0 

func (*ExperimentAnalysisRunStatus) ProtoMessage()

func (*ExperimentAnalysisRunStatus) Reset added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) Reset()

func (*ExperimentAnalysisRunStatus) Size added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) Size() (n int)

func (*ExperimentAnalysisRunStatus) String added in v1.0.0 

func (this *ExperimentAnalysisRunStatus) String() string

func (*ExperimentAnalysisRunStatus) Unmarshal added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) Unmarshal(dAtA []byte) error

func (*ExperimentAnalysisRunStatus) XXX_DiscardUnknown added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) XXX_DiscardUnknown()

func (*ExperimentAnalysisRunStatus) XXX_Marshal added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExperimentAnalysisRunStatus) XXX_Merge added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) XXX_Merge(src proto.Message)

func (*ExperimentAnalysisRunStatus) XXX_Size added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) XXX_Size() int

func (*ExperimentAnalysisRunStatus) XXX_Unmarshal added in v1.0.0 

func (m *ExperimentAnalysisRunStatus) XXX_Unmarshal(b []byte) error

type ExperimentAnalysisTemplateRef added in v0.6.0 

type ExperimentAnalysisTemplateRef struct {
	// Name is the name of the analysis
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// TemplateName reference of the AnalysisTemplate name used by the Experiment to create the run
	TemplateName string `json:"templateName" protobuf:"bytes,2,opt,name=templateName"`
	// Whether to look for the templateName at cluster scope or namespace scope
	// +optional
	ClusterScope bool `json:"clusterScope,omitempty" protobuf:"varint,3,opt,name=clusterScope"`
	// Args are the arguments that will be added to the AnalysisRuns
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	Args []Argument `json:"args,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,4,rep,name=args"`
	// RequiredForCompletion blocks the Experiment from completing until the analysis has completed
	RequiredForCompletion bool `json:"requiredForCompletion,omitempty" protobuf:"varint,5,opt,name=requiredForCompletion"`
}

func (*ExperimentAnalysisTemplateRef) DeepCopy added in v0.6.0 

func (in *ExperimentAnalysisTemplateRef) DeepCopy() *ExperimentAnalysisTemplateRef

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

func (*ExperimentAnalysisTemplateRef) DeepCopyInto added in v0.6.0 

func (in *ExperimentAnalysisTemplateRef) DeepCopyInto(out *ExperimentAnalysisTemplateRef)

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

func (*ExperimentAnalysisTemplateRef) Descriptor added in v1.0.0 

func (*ExperimentAnalysisTemplateRef) Descriptor() ([]byte, []int)

func (*ExperimentAnalysisTemplateRef) Marshal added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) Marshal() (dAtA []byte, err error)

func (*ExperimentAnalysisTemplateRef) MarshalTo added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) MarshalTo(dAtA []byte) (int, error)

func (*ExperimentAnalysisTemplateRef) MarshalToSizedBuffer added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExperimentAnalysisTemplateRef) ProtoMessage added in v1.0.0 

func (*ExperimentAnalysisTemplateRef) ProtoMessage()

func (*ExperimentAnalysisTemplateRef) Reset added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) Reset()

func (*ExperimentAnalysisTemplateRef) Size added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) Size() (n int)

func (*ExperimentAnalysisTemplateRef) String added in v1.0.0 

func (this *ExperimentAnalysisTemplateRef) String() string

func (*ExperimentAnalysisTemplateRef) Unmarshal added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) Unmarshal(dAtA []byte) error

func (*ExperimentAnalysisTemplateRef) XXX_DiscardUnknown added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) XXX_DiscardUnknown()

func (*ExperimentAnalysisTemplateRef) XXX_Marshal added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExperimentAnalysisTemplateRef) XXX_Merge added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) XXX_Merge(src proto.Message)

func (*ExperimentAnalysisTemplateRef) XXX_Size added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) XXX_Size() int

func (*ExperimentAnalysisTemplateRef) XXX_Unmarshal added in v1.0.0 

func (m *ExperimentAnalysisTemplateRef) XXX_Unmarshal(b []byte) error

type ExperimentCondition added in v0.5.0 

type ExperimentCondition struct {
	// Type of deployment condition.
	Type ExperimentConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=ExperimentConditionType"`
	// Phase of the condition, one of True, False, Unknown.
	Status corev1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/api/core/v1.ConditionStatus"`
	// The last time this condition was updated.
	LastUpdateTime metav1.Time `json:"lastUpdateTime" protobuf:"bytes,3,opt,name=lastUpdateTime"`
	// Last time the condition transitioned from one status to another.
	LastTransitionTime metav1.Time `json:"lastTransitionTime" protobuf:"bytes,4,opt,name=lastTransitionTime"`
	// The reason for the condition's last transition.
	Reason string `json:"reason" protobuf:"bytes,5,opt,name=reason"`
	// A human readable message indicating details about the transition.
	Message string `json:"message" protobuf:"bytes,6,opt,name=message"`
}

ExperimentCondition describes the state of a experiment at a certain point.

func (*ExperimentCondition) DeepCopy added in v0.5.0 

func (in *ExperimentCondition) DeepCopy() *ExperimentCondition

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

func (*ExperimentCondition) DeepCopyInto added in v0.5.0 

func (in *ExperimentCondition) DeepCopyInto(out *ExperimentCondition)

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

func (*ExperimentCondition) Descriptor added in v1.0.0 

func (*ExperimentCondition) Descriptor() ([]byte, []int)

func (*ExperimentCondition) Marshal added in v1.0.0 

func (m *ExperimentCondition) Marshal() (dAtA []byte, err error)

func (*ExperimentCondition) MarshalTo added in v1.0.0 

func (m *ExperimentCondition) MarshalTo(dAtA []byte) (int, error)

func (*ExperimentCondition) MarshalToSizedBuffer added in v1.0.0 

func (m *ExperimentCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExperimentCondition) ProtoMessage added in v1.0.0 

func (*ExperimentCondition) ProtoMessage()

func (*ExperimentCondition) Reset added in v1.0.0 

func (m *ExperimentCondition) Reset()

func (*ExperimentCondition) Size added in v1.0.0 

func (m *ExperimentCondition) Size() (n int)

func (*ExperimentCondition) String added in v1.0.0 

func (this *ExperimentCondition) String() string

func (*ExperimentCondition) Unmarshal added in v1.0.0 

func (m *ExperimentCondition) Unmarshal(dAtA []byte) error

func (*ExperimentCondition) XXX_DiscardUnknown added in v1.0.0 

func (m *ExperimentCondition) XXX_DiscardUnknown()

func (*ExperimentCondition) XXX_Marshal added in v1.0.0 

func (m *ExperimentCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExperimentCondition) XXX_Merge added in v1.0.0 

func (m *ExperimentCondition) XXX_Merge(src proto.Message)

func (*ExperimentCondition) XXX_Size added in v1.0.0 

func (m *ExperimentCondition) XXX_Size() int

func (*ExperimentCondition) XXX_Unmarshal added in v1.0.0 

func (m *ExperimentCondition) XXX_Unmarshal(b []byte) error

type ExperimentConditionType added in v0.5.0 

type ExperimentConditionType string

ExperimentConditionType defines the conditions of Experiment 

const (
	// InvalidExperimentSpec means the experiment has an invalid spec and will not progress until
	// the spec is fixed.
	InvalidExperimentSpec ExperimentConditionType = "InvalidSpec"
	// ExperimentConcluded means the experiment is available, ie. the active service is pointing at a
	// replicaset with the required replicas up and running for at least minReadySeconds.
	ExperimentCompleted ExperimentConditionType = "Completed"
	// ExperimentProgressing means the experiment is progressing. Progress for a experiment is
	// considered when a new replica set is created or adopted, when pods scale
	// up or old pods scale down, or when the services are updated. Progress is not estimated
	// for paused experiment.
	ExperimentProgressing ExperimentConditionType = "Progressing"
	// ExperimentRunning means that an experiment has reached the desired state and is running for the duration
	// specified in the spec
	ExperimentRunning ExperimentConditionType = "Running"
	// ExperimentReplicaFailure ReplicaFailure is added in a experiment when one of its pods
	// fails to be created or deleted.
	ExperimentReplicaFailure ExperimentConditionType = "ReplicaFailure"
)

These are valid conditions of a experiment.

type ExperimentList added in v0.5.0 

type ExperimentList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`

	Items []Experiment `json:"items" protobuf:"bytes,2,rep,name=items"`
}

ExperimentList is a list of Experiment resources

func (*ExperimentList) DeepCopy added in v0.5.0 

func (in *ExperimentList) DeepCopy() *ExperimentList

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

func (*ExperimentList) DeepCopyInto added in v0.5.0 

func (in *ExperimentList) DeepCopyInto(out *ExperimentList)

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

func (*ExperimentList) DeepCopyObject added in v0.5.0 

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

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

func (*ExperimentList) Descriptor added in v1.0.0 

func (*ExperimentList) Descriptor() ([]byte, []int)

func (*ExperimentList) Marshal added in v1.0.0 

func (m *ExperimentList) Marshal() (dAtA []byte, err error)

func (*ExperimentList) MarshalTo added in v1.0.0 

func (m *ExperimentList) MarshalTo(dAtA []byte) (int, error)

func (*ExperimentList) MarshalToSizedBuffer added in v1.0.0 

func (m *ExperimentList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExperimentList) ProtoMessage added in v1.0.0 

func (*ExperimentList) ProtoMessage()

func (*ExperimentList) Reset added in v1.0.0 

func (m *ExperimentList) Reset()

func (*ExperimentList) Size added in v1.0.0 

func (m *ExperimentList) Size() (n int)

func (*ExperimentList) String added in v1.0.0 

func (this *ExperimentList) String() string

func (*ExperimentList) Unmarshal added in v1.0.0 

func (m *ExperimentList) Unmarshal(dAtA []byte) error

func (*ExperimentList) XXX_DiscardUnknown added in v1.0.0 

func (m *ExperimentList) XXX_DiscardUnknown()

func (*ExperimentList) XXX_Marshal added in v1.0.0 

func (m *ExperimentList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExperimentList) XXX_Merge added in v1.0.0 

func (m *ExperimentList) XXX_Merge(src proto.Message)

func (*ExperimentList) XXX_Size added in v1.0.0 

func (m *ExperimentList) XXX_Size() int

func (*ExperimentList) XXX_Unmarshal added in v1.0.0 

func (m *ExperimentList) XXX_Unmarshal(b []byte) error

type ExperimentSpec added in v0.5.0 

type ExperimentSpec struct {
	// Templates are a list of PodSpecs that define the ReplicaSets that should be run during an experiment.
	// +patchMergeKey=name
	// +patchStrategy=merge
	Templates []TemplateSpec `json:"templates" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=templates"`
	// Duration the amount of time for the experiment to run as a duration string (e.g. 30s, 5m, 1h).
	// If omitted, the experiment will run indefinitely, stopped either via termination, or a failed analysis run.
	// +optional
	Duration DurationString `json:"duration,omitempty" protobuf:"bytes,2,opt,name=duration,casttype=DurationString"`
	// ProgressDeadlineSeconds The maximum time in seconds for a experiment to
	// make progress before it is considered to be failed. Argo Rollouts will
	// continue to process failed experiments and a condition with a
	// ProgressDeadlineExceeded reason will be surfaced in the experiment status.
	// Defaults to 600s.
	// +optional
	ProgressDeadlineSeconds *int32 `json:"progressDeadlineSeconds,omitempty" protobuf:"varint,3,opt,name=progressDeadlineSeconds"`
	// Terminate is used to prematurely stop the experiment
	Terminate bool `json:"terminate,omitempty" protobuf:"varint,4,opt,name=terminate"`
	// Analyses references AnalysisTemplates to run during the experiment
	// +patchMergeKey=name
	// +patchStrategy=merge
	Analyses []ExperimentAnalysisTemplateRef `json:"analyses,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,5,rep,name=analyses"`
}

ExperimentSpec is the spec for a Experiment resource

func (*ExperimentSpec) DeepCopy added in v0.5.0 

func (in *ExperimentSpec) DeepCopy() *ExperimentSpec

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

func (*ExperimentSpec) DeepCopyInto added in v0.5.0 

func (in *ExperimentSpec) DeepCopyInto(out *ExperimentSpec)

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

func (*ExperimentSpec) Descriptor added in v1.0.0 

func (*ExperimentSpec) Descriptor() ([]byte, []int)

func (*ExperimentSpec) Marshal added in v1.0.0 

func (m *ExperimentSpec) Marshal() (dAtA []byte, err error)

func (*ExperimentSpec) MarshalTo added in v1.0.0 

func (m *ExperimentSpec) MarshalTo(dAtA []byte) (int, error)

func (*ExperimentSpec) MarshalToSizedBuffer added in v1.0.0 

func (m *ExperimentSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExperimentSpec) ProtoMessage added in v1.0.0 

func (*ExperimentSpec) ProtoMessage()

func (*ExperimentSpec) Reset added in v1.0.0 

func (m *ExperimentSpec) Reset()

func (*ExperimentSpec) Size added in v1.0.0 

func (m *ExperimentSpec) Size() (n int)

func (*ExperimentSpec) String added in v1.0.0 

func (this *ExperimentSpec) String() string

func (*ExperimentSpec) Unmarshal added in v1.0.0 

func (m *ExperimentSpec) Unmarshal(dAtA []byte) error

func (*ExperimentSpec) XXX_DiscardUnknown added in v1.0.0 

func (m *ExperimentSpec) XXX_DiscardUnknown()

func (*ExperimentSpec) XXX_Marshal added in v1.0.0 

func (m *ExperimentSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExperimentSpec) XXX_Merge added in v1.0.0 

func (m *ExperimentSpec) XXX_Merge(src proto.Message)

func (*ExperimentSpec) XXX_Size added in v1.0.0 

func (m *ExperimentSpec) XXX_Size() int

func (*ExperimentSpec) XXX_Unmarshal added in v1.0.0 

func (m *ExperimentSpec) XXX_Unmarshal(b []byte) error

type ExperimentStatus added in v0.5.0 

type ExperimentStatus struct {
	// Phase is the status of the experiment. Takes into consideration ReplicaSet degradations and
	// AnalysisRun statuses
	Phase AnalysisPhase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=AnalysisPhase"`
	// Message is an explanation for the current status
	// +optional
	Message string `json:"message,omitempty" protobuf:"bytes,2,opt,name=message"`
	// TemplateStatuses holds the ReplicaSet related statuses for individual templates
	// +optional
	TemplateStatuses []TemplateStatus `json:"templateStatuses,omitempty" protobuf:"bytes,3,rep,name=templateStatuses"`
	// AvailableAt the time when all the templates become healthy and the experiment should start tracking the time to
	// run for the duration of specificed in the spec.
	// +optional
	AvailableAt *metav1.Time `json:"availableAt,omitempty" protobuf:"bytes,4,opt,name=availableAt"`
	// Conditions a list of conditions a experiment can have.
	// +optional
	Conditions []ExperimentCondition `json:"conditions,omitempty" protobuf:"bytes,5,rep,name=conditions"`
	// AnalysisRuns tracks the status of AnalysisRuns associated with this Experiment
	// +optional
	AnalysisRuns []ExperimentAnalysisRunStatus `json:"analysisRuns,omitempty" protobuf:"bytes,6,rep,name=analysisRuns"`
}

ExperimentStatus is the status for a Experiment resource

func (*ExperimentStatus) DeepCopy added in v0.5.0 

func (in *ExperimentStatus) DeepCopy() *ExperimentStatus

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

func (*ExperimentStatus) DeepCopyInto added in v0.5.0 

func (in *ExperimentStatus) DeepCopyInto(out *ExperimentStatus)

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

func (*ExperimentStatus) Descriptor added in v1.0.0 

func (*ExperimentStatus) Descriptor() ([]byte, []int)

func (*ExperimentStatus) Marshal added in v1.0.0 

func (m *ExperimentStatus) Marshal() (dAtA []byte, err error)

func (*ExperimentStatus) MarshalTo added in v1.0.0 

func (m *ExperimentStatus) MarshalTo(dAtA []byte) (int, error)

func (*ExperimentStatus) MarshalToSizedBuffer added in v1.0.0 

func (m *ExperimentStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExperimentStatus) ProtoMessage added in v1.0.0 

func (*ExperimentStatus) ProtoMessage()

func (*ExperimentStatus) Reset added in v1.0.0 

func (m *ExperimentStatus) Reset()

func (*ExperimentStatus) Size added in v1.0.0 

func (m *ExperimentStatus) Size() (n int)

func (*ExperimentStatus) String added in v1.0.0 

func (this *ExperimentStatus) String() string

func (*ExperimentStatus) Unmarshal added in v1.0.0 

func (m *ExperimentStatus) Unmarshal(dAtA []byte) error

func (*ExperimentStatus) XXX_DiscardUnknown added in v1.0.0 

func (m *ExperimentStatus) XXX_DiscardUnknown()

func (*ExperimentStatus) XXX_Marshal added in v1.0.0 

func (m *ExperimentStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExperimentStatus) XXX_Merge added in v1.0.0 

func (m *ExperimentStatus) XXX_Merge(src proto.Message)

func (*ExperimentStatus) XXX_Size added in v1.0.0 

func (m *ExperimentStatus) XXX_Size() int

func (*ExperimentStatus) XXX_Unmarshal added in v1.0.0 

func (m *ExperimentStatus) XXX_Unmarshal(b []byte) error

type FieldRef added in v0.10.0 

type FieldRef struct {
	// Required: Path of the field to select in the specified API version
	FieldPath string `json:"fieldPath" protobuf:"bytes,1,opt,name=fieldPath"`
}

func (*FieldRef) DeepCopy added in v0.10.0 

func (in *FieldRef) DeepCopy() *FieldRef

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

func (*FieldRef) DeepCopyInto added in v0.10.0 

func (in *FieldRef) DeepCopyInto(out *FieldRef)

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

func (*FieldRef) Descriptor added in v1.0.0 

func (*FieldRef) Descriptor() ([]byte, []int)

func (*FieldRef) Marshal added in v1.0.0 

func (m *FieldRef) Marshal() (dAtA []byte, err error)

func (*FieldRef) MarshalTo added in v1.0.0 

func (m *FieldRef) MarshalTo(dAtA []byte) (int, error)

func (*FieldRef) MarshalToSizedBuffer added in v1.0.0 

func (m *FieldRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FieldRef) ProtoMessage added in v1.0.0 

func (*FieldRef) ProtoMessage()

func (*FieldRef) Reset added in v1.0.0 

func (m *FieldRef) Reset()

func (*FieldRef) Size added in v1.0.0 

func (m *FieldRef) Size() (n int)

func (*FieldRef) String added in v1.0.0 

func (this *FieldRef) String() string

func (*FieldRef) Unmarshal added in v1.0.0 

func (m *FieldRef) Unmarshal(dAtA []byte) error

func (*FieldRef) XXX_DiscardUnknown added in v1.0.0 

func (m *FieldRef) XXX_DiscardUnknown()

func (*FieldRef) XXX_Marshal added in v1.0.0 

func (m *FieldRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldRef) XXX_Merge added in v1.0.0 

func (m *FieldRef) XXX_Merge(src proto.Message)

func (*FieldRef) XXX_Size added in v1.0.0 

func (m *FieldRef) XXX_Size() int

func (*FieldRef) XXX_Unmarshal added in v1.0.0 

func (m *FieldRef) XXX_Unmarshal(b []byte) error

type IstioDestinationRule added in v1.0.0 

type IstioDestinationRule struct {
	// Name holds the name of the DestinationRule
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// CanarySubsetName is the subset name to modify labels with canary ReplicaSet pod template hash value
	CanarySubsetName string `json:"canarySubsetName" protobuf:"bytes,2,opt,name=canarySubsetName"`
	// StableSubsetName is the subset name to modify labels with stable ReplicaSet pod template hash value
	StableSubsetName string `json:"stableSubsetName" protobuf:"bytes,3,opt,name=stableSubsetName"`
}

IstioDestinationRule is a reference to an Istio DestinationRule to modify and shape traffic

func (*IstioDestinationRule) DeepCopy added in v1.0.0 

func (in *IstioDestinationRule) DeepCopy() *IstioDestinationRule

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

func (*IstioDestinationRule) DeepCopyInto added in v1.0.0 

func (in *IstioDestinationRule) DeepCopyInto(out *IstioDestinationRule)

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

func (*IstioDestinationRule) Descriptor added in v1.0.0 

func (*IstioDestinationRule) Descriptor() ([]byte, []int)

func (*IstioDestinationRule) Marshal added in v1.0.0 

func (m *IstioDestinationRule) Marshal() (dAtA []byte, err error)

func (*IstioDestinationRule) MarshalTo added in v1.0.0 

func (m *IstioDestinationRule) MarshalTo(dAtA []byte) (int, error)

func (*IstioDestinationRule) MarshalToSizedBuffer added in v1.0.0 

func (m *IstioDestinationRule) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IstioDestinationRule) ProtoMessage added in v1.0.0 

func (*IstioDestinationRule) ProtoMessage()

func (*IstioDestinationRule) Reset added in v1.0.0 

func (m *IstioDestinationRule) Reset()

func (*IstioDestinationRule) Size added in v1.0.0 

func (m *IstioDestinationRule) Size() (n int)

func (*IstioDestinationRule) String added in v1.0.0 

func (this *IstioDestinationRule) String() string

func (*IstioDestinationRule) Unmarshal added in v1.0.0 

func (m *IstioDestinationRule) Unmarshal(dAtA []byte) error

func (*IstioDestinationRule) XXX_DiscardUnknown added in v1.0.0 

func (m *IstioDestinationRule) XXX_DiscardUnknown()

func (*IstioDestinationRule) XXX_Marshal added in v1.0.0 

func (m *IstioDestinationRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IstioDestinationRule) XXX_Merge added in v1.0.0 

func (m *IstioDestinationRule) XXX_Merge(src proto.Message)

func (*IstioDestinationRule) XXX_Size added in v1.0.0 

func (m *IstioDestinationRule) XXX_Size() int

func (*IstioDestinationRule) XXX_Unmarshal added in v1.0.0 

func (m *IstioDestinationRule) XXX_Unmarshal(b []byte) error

type IstioTrafficRouting added in v0.7.0 

type IstioTrafficRouting struct {
	// VirtualService references an Istio VirtualService to modify to shape traffic
	VirtualService IstioVirtualService `json:"virtualService" protobuf:"bytes,1,opt,name=virtualService"`
	// DestinationRule references an Istio DestinationRule to modify to shape traffic
	DestinationRule *IstioDestinationRule `json:"destinationRule,omitempty" protobuf:"bytes,2,opt,name=destinationRule"`
}

IstioTrafficRouting configuration for Istio service mesh to enable fine grain configuration

func (*IstioTrafficRouting) DeepCopy added in v0.7.0 

func (in *IstioTrafficRouting) DeepCopy() *IstioTrafficRouting

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

func (*IstioTrafficRouting) DeepCopyInto added in v0.7.0 

func (in *IstioTrafficRouting) DeepCopyInto(out *IstioTrafficRouting)

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

func (*IstioTrafficRouting) Descriptor added in v1.0.0 

func (*IstioTrafficRouting) Descriptor() ([]byte, []int)

func (*IstioTrafficRouting) Marshal added in v1.0.0 

func (m *IstioTrafficRouting) Marshal() (dAtA []byte, err error)

func (*IstioTrafficRouting) MarshalTo added in v1.0.0 

func (m *IstioTrafficRouting) MarshalTo(dAtA []byte) (int, error)

func (*IstioTrafficRouting) MarshalToSizedBuffer added in v1.0.0 

func (m *IstioTrafficRouting) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IstioTrafficRouting) ProtoMessage added in v1.0.0 

func (*IstioTrafficRouting) ProtoMessage()

func (*IstioTrafficRouting) Reset added in v1.0.0 

func (m *IstioTrafficRouting) Reset()

func (*IstioTrafficRouting) Size added in v1.0.0 

func (m *IstioTrafficRouting) Size() (n int)

func (*IstioTrafficRouting) String added in v1.0.0 

func (this *IstioTrafficRouting) String() string

func (*IstioTrafficRouting) Unmarshal added in v1.0.0 

func (m *IstioTrafficRouting) Unmarshal(dAtA []byte) error

func (*IstioTrafficRouting) XXX_DiscardUnknown added in v1.0.0 

func (m *IstioTrafficRouting) XXX_DiscardUnknown()

func (*IstioTrafficRouting) XXX_Marshal added in v1.0.0 

func (m *IstioTrafficRouting) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IstioTrafficRouting) XXX_Merge added in v1.0.0 

func (m *IstioTrafficRouting) XXX_Merge(src proto.Message)

func (*IstioTrafficRouting) XXX_Size added in v1.0.0 

func (m *IstioTrafficRouting) XXX_Size() int

func (*IstioTrafficRouting) XXX_Unmarshal added in v1.0.0 

func (m *IstioTrafficRouting) XXX_Unmarshal(b []byte) error

type IstioVirtualService added in v0.7.0 

type IstioVirtualService struct {
	// Name holds the name of the VirtualService
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Routes are list of routes within VirtualService to edit. If omitted, VirtualService must have a single route
	Routes []string `json:"routes,omitempty" protobuf:"bytes,2,rep,name=routes"`
}

IstioVirtualService holds information on the virtual service the rollout needs to modify

func (*IstioVirtualService) DeepCopy added in v0.7.0 

func (in *IstioVirtualService) DeepCopy() *IstioVirtualService

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

func (*IstioVirtualService) DeepCopyInto added in v0.7.0 

func (in *IstioVirtualService) DeepCopyInto(out *IstioVirtualService)

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

func (*IstioVirtualService) Descriptor added in v1.0.0 

func (*IstioVirtualService) Descriptor() ([]byte, []int)

func (*IstioVirtualService) Marshal added in v1.0.0 

func (m *IstioVirtualService) Marshal() (dAtA []byte, err error)

func (*IstioVirtualService) MarshalTo added in v1.0.0 

func (m *IstioVirtualService) MarshalTo(dAtA []byte) (int, error)

func (*IstioVirtualService) MarshalToSizedBuffer added in v1.0.0 

func (m *IstioVirtualService) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IstioVirtualService) ProtoMessage added in v1.0.0 

func (*IstioVirtualService) ProtoMessage()

func (*IstioVirtualService) Reset added in v1.0.0 

func (m *IstioVirtualService) Reset()

func (*IstioVirtualService) Size added in v1.0.0 

func (m *IstioVirtualService) Size() (n int)

func (*IstioVirtualService) String added in v1.0.0 

func (this *IstioVirtualService) String() string

func (*IstioVirtualService) Unmarshal added in v1.0.0 

func (m *IstioVirtualService) Unmarshal(dAtA []byte) error

func (*IstioVirtualService) XXX_DiscardUnknown added in v1.0.0 

func (m *IstioVirtualService) XXX_DiscardUnknown()

func (*IstioVirtualService) XXX_Marshal added in v1.0.0 

func (m *IstioVirtualService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IstioVirtualService) XXX_Merge added in v1.0.0 

func (m *IstioVirtualService) XXX_Merge(src proto.Message)

func (*IstioVirtualService) XXX_Size added in v1.0.0 

func (m *IstioVirtualService) XXX_Size() int

func (*IstioVirtualService) XXX_Unmarshal added in v1.0.0 

func (m *IstioVirtualService) XXX_Unmarshal(b []byte) error

type JobMetric added in v0.6.0 

type JobMetric struct {
	Metadata metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec     batchv1.JobSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

JobMetric defines a job to run which acts as a metric

func (*JobMetric) DeepCopy added in v0.6.0 

func (in *JobMetric) DeepCopy() *JobMetric

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

func (*JobMetric) DeepCopyInto added in v0.6.0 

func (in *JobMetric) DeepCopyInto(out *JobMetric)

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

func (*JobMetric) Descriptor added in v1.0.0 

func (*JobMetric) Descriptor() ([]byte, []int)

func (*JobMetric) Marshal added in v1.0.0 

func (m *JobMetric) Marshal() (dAtA []byte, err error)

func (*JobMetric) MarshalTo added in v1.0.0 

func (m *JobMetric) MarshalTo(dAtA []byte) (int, error)

func (*JobMetric) MarshalToSizedBuffer added in v1.0.0 

func (m *JobMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobMetric) ProtoMessage added in v1.0.0 

func (*JobMetric) ProtoMessage()

func (*JobMetric) Reset added in v1.0.0 

func (m *JobMetric) Reset()

func (*JobMetric) Size added in v1.0.0 

func (m *JobMetric) Size() (n int)

func (*JobMetric) String added in v1.0.0 

func (this *JobMetric) String() string

func (*JobMetric) Unmarshal added in v1.0.0 

func (m *JobMetric) Unmarshal(dAtA []byte) error

func (*JobMetric) XXX_DiscardUnknown added in v1.0.0 

func (m *JobMetric) XXX_DiscardUnknown()

func (*JobMetric) XXX_Marshal added in v1.0.0 

func (m *JobMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobMetric) XXX_Merge added in v1.0.0 

func (m *JobMetric) XXX_Merge(src proto.Message)

func (*JobMetric) XXX_Size added in v1.0.0 

func (m *JobMetric) XXX_Size() int

func (*JobMetric) XXX_Unmarshal added in v1.0.0 

func (m *JobMetric) XXX_Unmarshal(b []byte) error

type KayentaMetric added in v0.6.0 

type KayentaMetric struct {
	Address string `json:"address" protobuf:"bytes,1,opt,name=address"`

	Application string `json:"application" protobuf:"bytes,2,opt,name=application"`

	CanaryConfigName string `json:"canaryConfigName" protobuf:"bytes,3,opt,name=canaryConfigName"`

	MetricsAccountName       string `json:"metricsAccountName" protobuf:"bytes,4,opt,name=metricsAccountName"`
	ConfigurationAccountName string `json:"configurationAccountName" protobuf:"bytes,5,opt,name=configurationAccountName"`
	StorageAccountName       string `json:"storageAccountName" protobuf:"bytes,6,opt,name=storageAccountName"`

	Threshold KayentaThreshold `json:"threshold" protobuf:"bytes,7,opt,name=threshold"`

	Scopes []KayentaScope `json:"scopes" protobuf:"bytes,8,rep,name=scopes"`
}

func (*KayentaMetric) DeepCopy added in v0.6.0 

func (in *KayentaMetric) DeepCopy() *KayentaMetric

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

func (*KayentaMetric) DeepCopyInto added in v0.6.0 

func (in *KayentaMetric) DeepCopyInto(out *KayentaMetric)

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

func (*KayentaMetric) Descriptor added in v1.0.0 

func (*KayentaMetric) Descriptor() ([]byte, []int)

func (*KayentaMetric) Marshal added in v1.0.0 

func (m *KayentaMetric) Marshal() (dAtA []byte, err error)

func (*KayentaMetric) MarshalTo added in v1.0.0 

func (m *KayentaMetric) MarshalTo(dAtA []byte) (int, error)

func (*KayentaMetric) MarshalToSizedBuffer added in v1.0.0 

func (m *KayentaMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KayentaMetric) ProtoMessage added in v1.0.0 

func (*KayentaMetric) ProtoMessage()

func (*KayentaMetric) Reset added in v1.0.0 

func (m *KayentaMetric) Reset()

func (*KayentaMetric) Size added in v1.0.0 

func (m *KayentaMetric) Size() (n int)

func (*KayentaMetric) String added in v1.0.0 

func (this *KayentaMetric) String() string

func (*KayentaMetric) Unmarshal added in v1.0.0 

func (m *KayentaMetric) Unmarshal(dAtA []byte) error

func (*KayentaMetric) XXX_DiscardUnknown added in v1.0.0 

func (m *KayentaMetric) XXX_DiscardUnknown()

func (*KayentaMetric) XXX_Marshal added in v1.0.0 

func (m *KayentaMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KayentaMetric) XXX_Merge added in v1.0.0 

func (m *KayentaMetric) XXX_Merge(src proto.Message)

func (*KayentaMetric) XXX_Size added in v1.0.0 

func (m *KayentaMetric) XXX_Size() int

func (*KayentaMetric) XXX_Unmarshal added in v1.0.0 

func (m *KayentaMetric) XXX_Unmarshal(b []byte) error

type KayentaScope added in v0.6.0 

type KayentaScope struct {
	Name            string      `json:"name" protobuf:"bytes,1,opt,name=name"`
	ControlScope    ScopeDetail `json:"controlScope" protobuf:"bytes,2,opt,name=controlScope"`
	ExperimentScope ScopeDetail `json:"experimentScope" protobuf:"bytes,3,opt,name=experimentScope"`
}

func (*KayentaScope) DeepCopy added in v0.6.0 

func (in *KayentaScope) DeepCopy() *KayentaScope

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

func (*KayentaScope) DeepCopyInto added in v0.6.0 

func (in *KayentaScope) DeepCopyInto(out *KayentaScope)

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

func (*KayentaScope) Descriptor added in v1.0.0 

func (*KayentaScope) Descriptor() ([]byte, []int)

func (*KayentaScope) Marshal added in v1.0.0 

func (m *KayentaScope) Marshal() (dAtA []byte, err error)

func (*KayentaScope) MarshalTo added in v1.0.0 

func (m *KayentaScope) MarshalTo(dAtA []byte) (int, error)

func (*KayentaScope) MarshalToSizedBuffer added in v1.0.0 

func (m *KayentaScope) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KayentaScope) ProtoMessage added in v1.0.0 

func (*KayentaScope) ProtoMessage()

func (*KayentaScope) Reset added in v1.0.0 

func (m *KayentaScope) Reset()

func (*KayentaScope) Size added in v1.0.0 

func (m *KayentaScope) Size() (n int)

func (*KayentaScope) String added in v1.0.0 

func (this *KayentaScope) String() string

func (*KayentaScope) Unmarshal added in v1.0.0 

func (m *KayentaScope) Unmarshal(dAtA []byte) error

func (*KayentaScope) XXX_DiscardUnknown added in v1.0.0 

func (m *KayentaScope) XXX_DiscardUnknown()

func (*KayentaScope) XXX_Marshal added in v1.0.0 

func (m *KayentaScope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KayentaScope) XXX_Merge added in v1.0.0 

func (m *KayentaScope) XXX_Merge(src proto.Message)

func (*KayentaScope) XXX_Size added in v1.0.0 

func (m *KayentaScope) XXX_Size() int

func (*KayentaScope) XXX_Unmarshal added in v1.0.0 

func (m *KayentaScope) XXX_Unmarshal(b []byte) error

type KayentaThreshold added in v0.6.0 

type KayentaThreshold struct {
	Pass     int64 `json:"pass" protobuf:"varint,1,opt,name=pass"`
	Marginal int64 `json:"marginal" protobuf:"varint,2,opt,name=marginal"`
}

func (*KayentaThreshold) DeepCopy added in v0.6.0 

func (in *KayentaThreshold) DeepCopy() *KayentaThreshold

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

func (*KayentaThreshold) DeepCopyInto added in v0.6.0 

func (in *KayentaThreshold) DeepCopyInto(out *KayentaThreshold)

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

func (*KayentaThreshold) Descriptor added in v1.0.0 

func (*KayentaThreshold) Descriptor() ([]byte, []int)

func (*KayentaThreshold) Marshal added in v1.0.0 

func (m *KayentaThreshold) Marshal() (dAtA []byte, err error)

func (*KayentaThreshold) MarshalTo added in v1.0.0 

func (m *KayentaThreshold) MarshalTo(dAtA []byte) (int, error)

func (*KayentaThreshold) MarshalToSizedBuffer added in v1.0.0 

func (m *KayentaThreshold) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KayentaThreshold) ProtoMessage added in v1.0.0 

func (*KayentaThreshold) ProtoMessage()

func (*KayentaThreshold) Reset added in v1.0.0 

func (m *KayentaThreshold) Reset()

func (*KayentaThreshold) Size added in v1.0.0 

func (m *KayentaThreshold) Size() (n int)

func (*KayentaThreshold) String added in v1.0.0 

func (this *KayentaThreshold) String() string

func (*KayentaThreshold) Unmarshal added in v1.0.0 

func (m *KayentaThreshold) Unmarshal(dAtA []byte) error

func (*KayentaThreshold) XXX_DiscardUnknown added in v1.0.0 

func (m *KayentaThreshold) XXX_DiscardUnknown()

func (*KayentaThreshold) XXX_Marshal added in v1.0.0 

func (m *KayentaThreshold) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KayentaThreshold) XXX_Merge added in v1.0.0 

func (m *KayentaThreshold) XXX_Merge(src proto.Message)

func (*KayentaThreshold) XXX_Size added in v1.0.0 

func (m *KayentaThreshold) XXX_Size() int

func (*KayentaThreshold) XXX_Unmarshal added in v1.0.0 

func (m *KayentaThreshold) XXX_Unmarshal(b []byte) error

type Measurement added in v0.6.0 

type Measurement struct {
	// Phase is the status of this single measurement
	Phase AnalysisPhase `json:"phase" protobuf:"bytes,1,opt,name=phase,casttype=AnalysisPhase"`
	// Message contains a message describing current condition (e.g. error messages)
	Message string `json:"message,omitempty" protobuf:"bytes,2,opt,name=message"`
	// StartedAt is the timestamp in which this measurement started to be measured
	StartedAt *metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,3,opt,name=startedAt"`
	// FinishedAt is the timestamp in which this measurement completed and value was collected
	FinishedAt *metav1.Time `json:"finishedAt,omitempty" protobuf:"bytes,4,opt,name=finishedAt"`
	// Value is the measured value of the metric
	Value string `json:"value,omitempty" protobuf:"bytes,5,opt,name=value"`
	// Metadata stores additional metadata about this metric result, used by the different providers
	// (e.g. kayenta run ID, job name)
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,6,rep,name=metadata"`
	// ResumeAt is the  timestamp when the analysisRun should try to resume the measurement
	ResumeAt *metav1.Time `json:"resumeAt,omitempty" protobuf:"bytes,7,opt,name=resumeAt"`
}

Measurement is a point in time result value of a single metric, and the time it was measured

func (*Measurement) DeepCopy added in v0.6.0 

func (in *Measurement) DeepCopy() *Measurement

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

func (*Measurement) DeepCopyInto added in v0.6.0 

func (in *Measurement) DeepCopyInto(out *Measurement)

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

func (*Measurement) Descriptor added in v1.0.0 

func (*Measurement) Descriptor() ([]byte, []int)

func (*Measurement) Marshal added in v1.0.0 

func (m *Measurement) Marshal() (dAtA []byte, err error)

func (*Measurement) MarshalTo added in v1.0.0 

func (m *Measurement) MarshalTo(dAtA []byte) (int, error)

func (*Measurement) MarshalToSizedBuffer added in v1.0.0 

func (m *Measurement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Measurement) ProtoMessage added in v1.0.0 

func (*Measurement) ProtoMessage()

func (*Measurement) Reset added in v1.0.0 

func (m *Measurement) Reset()

func (*Measurement) Size added in v1.0.0 

func (m *Measurement) Size() (n int)

func (*Measurement) String added in v1.0.0 

func (this *Measurement) String() string

func (*Measurement) Unmarshal added in v1.0.0 

func (m *Measurement) Unmarshal(dAtA []byte) error

func (*Measurement) XXX_DiscardUnknown added in v1.0.0 

func (m *Measurement) XXX_DiscardUnknown()

func (*Measurement) XXX_Marshal added in v1.0.0 

func (m *Measurement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Measurement) XXX_Merge added in v1.0.0 

func (m *Measurement) XXX_Merge(src proto.Message)

func (*Measurement) XXX_Size added in v1.0.0 

func (m *Measurement) XXX_Size() int

func (*Measurement) XXX_Unmarshal added in v1.0.0 

func (m *Measurement) XXX_Unmarshal(b []byte) error

type Metric added in v0.6.0 

type Metric struct {
	// Name is the name of the metric
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Interval defines an interval string (e.g. 30s, 5m, 1h) between each measurement.
	// If omitted, will perform a single measurement
	Interval DurationString `json:"interval,omitempty" protobuf:"bytes,2,opt,name=interval,casttype=DurationString"`
	// InitialDelay how long the AnalysisRun should wait before starting this metric
	InitialDelay DurationString `json:"initialDelay,omitempty" protobuf:"bytes,3,opt,name=initialDelay,casttype=DurationString"`
	// Count is the number of times to run the measurement. If both interval and count are omitted,
	// the effective count is 1. If only interval is specified, metric runs indefinitely.
	// If count > 1, interval must be specified.
	Count *intstrutil.IntOrString `json:"count,omitempty" protobuf:"bytes,4,opt,name=count"`
	// SuccessCondition is an expression which determines if a measurement is considered successful
	// Expression is a goevaluate expression. The keyword `result` is a variable reference to the
	// value of measurement. Results can be both structured data or primitive.
	// Examples:
	//   result > 10
	//   (result.requests_made * result.requests_succeeded / 100) >= 90
	SuccessCondition string `json:"successCondition,omitempty" protobuf:"bytes,5,opt,name=successCondition"`
	// FailureCondition is an expression which determines if a measurement is considered failed
	// If both success and failure conditions are specified, and the measurement does not fall into
	// either condition, the measurement is considered Inconclusive
	FailureCondition string `json:"failureCondition,omitempty" protobuf:"bytes,6,opt,name=failureCondition"`
	// FailureLimit is the maximum number of times the measurement is allowed to fail, before the
	// entire metric is considered Failed (default: 0)
	FailureLimit *intstrutil.IntOrString `json:"failureLimit,omitempty" protobuf:"bytes,7,opt,name=failureLimit"`
	// InconclusiveLimit is the maximum number of times the measurement is allowed to measure
	// Inconclusive, before the entire metric is considered Inconclusive (default: 0)
	InconclusiveLimit *intstrutil.IntOrString `json:"inconclusiveLimit,omitempty" protobuf:"bytes,8,opt,name=inconclusiveLimit"`
	// ConsecutiveErrorLimit is the maximum number of times the measurement is allowed to error in
	// succession, before the metric is considered error (default: 4)
	ConsecutiveErrorLimit *intstrutil.IntOrString `json:"consecutiveErrorLimit,omitempty" protobuf:"bytes,9,opt,name=consecutiveErrorLimit"`
	// Provider configuration to the external system to use to verify the analysis
	Provider MetricProvider `json:"provider" protobuf:"bytes,10,opt,name=provider"`
}

Metric defines a metric in which to perform analysis

func (*Metric) DeepCopy added in v0.6.0 

func (in *Metric) DeepCopy() *Metric

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

func (*Metric) DeepCopyInto added in v0.6.0 

func (in *Metric) DeepCopyInto(out *Metric)

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

func (*Metric) Descriptor added in v1.0.0 

func (*Metric) Descriptor() ([]byte, []int)

func (*Metric) EffectiveCount added in v0.6.0 

func (m *Metric) EffectiveCount() *intstrutil.IntOrString

EffectiveCount is the effective count based on whether or not count/interval is specified If neither count or interval is specified, the effective count is 1 If only interval is specified, metric runs indefinitely and there is no effective count (nil) Otherwise, it is the user specified value

func (*Metric) Marshal added in v1.0.0 

func (m *Metric) Marshal() (dAtA []byte, err error)

func (*Metric) MarshalTo added in v1.0.0 

func (m *Metric) MarshalTo(dAtA []byte) (int, error)

func (*Metric) MarshalToSizedBuffer added in v1.0.0 

func (m *Metric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metric) ProtoMessage added in v1.0.0 

func (*Metric) ProtoMessage()

func (*Metric) Reset added in v1.0.0 

func (m *Metric) Reset()

func (*Metric) Size added in v1.0.0 

func (m *Metric) Size() (n int)

func (*Metric) String added in v1.0.0 

func (this *Metric) String() string

func (*Metric) Unmarshal added in v1.0.0 

func (m *Metric) Unmarshal(dAtA []byte) error

func (*Metric) XXX_DiscardUnknown added in v1.0.0 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal added in v1.0.0 

func (m *Metric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metric) XXX_Merge added in v1.0.0 

func (m *Metric) XXX_Merge(src proto.Message)

func (*Metric) XXX_Size added in v1.0.0 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal added in v1.0.0 

func (m *Metric) XXX_Unmarshal(b []byte) error

type MetricProvider added in v0.6.0 

type MetricProvider struct {
	// Prometheus specifies the prometheus metric to query
	Prometheus *PrometheusMetric `json:"prometheus,omitempty" protobuf:"bytes,1,opt,name=prometheus"`
	// Kayenta specifies a Kayenta metric
	Kayenta *KayentaMetric `json:"kayenta,omitempty" protobuf:"bytes,2,opt,name=kayenta"`
	// Web specifies a generic HTTP web metric
	Web *WebMetric `json:"web,omitempty" protobuf:"bytes,3,opt,name=web"`
	// Datadog specifies a datadog metric to query
	Datadog *DatadogMetric `json:"datadog,omitempty" protobuf:"bytes,4,opt,name=datadog"`
	// Wavefront specifies the wavefront metric to query
	Wavefront *WavefrontMetric `json:"wavefront,omitempty" protobuf:"bytes,5,opt,name=wavefront"`
	// NewRelic specifies the newrelic metric to query
	NewRelic *NewRelicMetric `json:"newRelic,omitempty" protobuf:"bytes,6,opt,name=newRelic"`
	// Job specifies the job metric run
	Job *JobMetric `json:"job,omitempty" protobuf:"bytes,7,opt,name=job"`
}

MetricProvider which external system to use to verify the analysis Only one of the fields in this struct should be non-nil

func (*MetricProvider) DeepCopy added in v0.6.0 

func (in *MetricProvider) DeepCopy() *MetricProvider

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

func (*MetricProvider) DeepCopyInto added in v0.6.0 

func (in *MetricProvider) DeepCopyInto(out *MetricProvider)

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

func (*MetricProvider) Descriptor added in v1.0.0 

func (*MetricProvider) Descriptor() ([]byte, []int)

func (*MetricProvider) Marshal added in v1.0.0 

func (m *MetricProvider) Marshal() (dAtA []byte, err error)

func (*MetricProvider) MarshalTo added in v1.0.0 

func (m *MetricProvider) MarshalTo(dAtA []byte) (int, error)

func (*MetricProvider) MarshalToSizedBuffer added in v1.0.0 

func (m *MetricProvider) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricProvider) ProtoMessage added in v1.0.0 

func (*MetricProvider) ProtoMessage()

func (*MetricProvider) Reset added in v1.0.0 

func (m *MetricProvider) Reset()

func (*MetricProvider) Size added in v1.0.0 

func (m *MetricProvider) Size() (n int)

func (*MetricProvider) String added in v1.0.0 

func (this *MetricProvider) String() string

func (*MetricProvider) Unmarshal added in v1.0.0 

func (m *MetricProvider) Unmarshal(dAtA []byte) error

func (*MetricProvider) XXX_DiscardUnknown added in v1.0.0 

func (m *MetricProvider) XXX_DiscardUnknown()

func (*MetricProvider) XXX_Marshal added in v1.0.0 

func (m *MetricProvider) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricProvider) XXX_Merge added in v1.0.0 

func (m *MetricProvider) XXX_Merge(src proto.Message)

func (*MetricProvider) XXX_Size added in v1.0.0 

func (m *MetricProvider) XXX_Size() int

func (*MetricProvider) XXX_Unmarshal added in v1.0.0 

func (m *MetricProvider) XXX_Unmarshal(b []byte) error

type MetricResult added in v0.6.0 

type MetricResult struct {
	// Name is the name of the metric
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Phase is the overall aggregate status of the metric
	Phase AnalysisPhase `json:"phase" protobuf:"bytes,2,opt,name=phase,casttype=AnalysisPhase"`
	// Measurements holds the most recent measurements collected for the metric
	Measurements []Measurement `json:"measurements,omitempty" protobuf:"bytes,3,rep,name=measurements"`
	// Message contains a message describing current condition (e.g. error messages)
	Message string `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"`
	// Count is the number of times the metric was measured without Error
	// This is equal to the sum of Successful, Failed, Inconclusive
	Count int32 `json:"count,omitempty" protobuf:"varint,5,opt,name=count"`
	// Successful is the number of times the metric was measured Successful
	Successful int32 `json:"successful,omitempty" protobuf:"varint,6,opt,name=successful"`
	// Failed is the number of times the metric was measured Failed
	Failed int32 `json:"failed,omitempty" protobuf:"varint,7,opt,name=failed"`
	// Inconclusive is the number of times the metric was measured Inconclusive
	Inconclusive int32 `json:"inconclusive,omitempty" protobuf:"varint,8,opt,name=inconclusive"`
	// Error is the number of times an error was encountered during measurement
	Error int32 `json:"error,omitempty" protobuf:"varint,9,opt,name=error"`
	// ConsecutiveError is the number of times an error was encountered during measurement in succession
	// Resets to zero when non-errors are encountered
	ConsecutiveError int32 `json:"consecutiveError,omitempty" protobuf:"varint,10,opt,name=consecutiveError"`
}

MetricResult contain a list of the most recent measurements for a single metric along with counters on how often the measurement

func (*MetricResult) DeepCopy added in v0.6.0 

func (in *MetricResult) DeepCopy() *MetricResult

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

func (*MetricResult) DeepCopyInto added in v0.6.0 

func (in *MetricResult) DeepCopyInto(out *MetricResult)

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

func (*MetricResult) Descriptor added in v1.0.0 

func (*MetricResult) Descriptor() ([]byte, []int)

func (*MetricResult) Marshal added in v1.0.0 

func (m *MetricResult) Marshal() (dAtA []byte, err error)

func (*MetricResult) MarshalTo added in v1.0.0 

func (m *MetricResult) MarshalTo(dAtA []byte) (int, error)

func (*MetricResult) MarshalToSizedBuffer added in v1.0.0 

func (m *MetricResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricResult) ProtoMessage added in v1.0.0 

func (*MetricResult) ProtoMessage()

func (*MetricResult) Reset added in v1.0.0 

func (m *MetricResult) Reset()

func (*MetricResult) Size added in v1.0.0 

func (m *MetricResult) Size() (n int)

func (*MetricResult) String added in v1.0.0 

func (this *MetricResult) String() string

func (*MetricResult) Unmarshal added in v1.0.0 

func (m *MetricResult) Unmarshal(dAtA []byte) error

func (*MetricResult) XXX_DiscardUnknown added in v1.0.0 

func (m *MetricResult) XXX_DiscardUnknown()

func (*MetricResult) XXX_Marshal added in v1.0.0 

func (m *MetricResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricResult) XXX_Merge added in v1.0.0 

func (m *MetricResult) XXX_Merge(src proto.Message)

func (*MetricResult) XXX_Size added in v1.0.0 

func (m *MetricResult) XXX_Size() int

func (*MetricResult) XXX_Unmarshal added in v1.0.0 

func (m *MetricResult) XXX_Unmarshal(b []byte) error

type NewRelicMetric added in v0.10.0 

type NewRelicMetric struct {
	// Profile is the name of the secret holding NR account configuration
	Profile string `json:"profile,omitempty" protobuf:"bytes,1,opt,name=profile"`
	// Query is a raw newrelic NRQL query to perform
	Query string `json:"query" protobuf:"bytes,2,opt,name=query"`
}

NewRelicMetric defines the newrelic query to perform canary analysis

func (*NewRelicMetric) DeepCopy added in v0.10.0 

func (in *NewRelicMetric) DeepCopy() *NewRelicMetric

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

func (*NewRelicMetric) DeepCopyInto added in v0.10.0 

func (in *NewRelicMetric) DeepCopyInto(out *NewRelicMetric)

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

func (*NewRelicMetric) Descriptor added in v1.0.0 

func (*NewRelicMetric) Descriptor() ([]byte, []int)

func (*NewRelicMetric) Marshal added in v1.0.0 

func (m *NewRelicMetric) Marshal() (dAtA []byte, err error)

func (*NewRelicMetric) MarshalTo added in v1.0.0 

func (m *NewRelicMetric) MarshalTo(dAtA []byte) (int, error)

func (*NewRelicMetric) MarshalToSizedBuffer added in v1.0.0 

func (m *NewRelicMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NewRelicMetric) ProtoMessage added in v1.0.0 

func (*NewRelicMetric) ProtoMessage()

func (*NewRelicMetric) Reset added in v1.0.0 

func (m *NewRelicMetric) Reset()

func (*NewRelicMetric) Size added in v1.0.0 

func (m *NewRelicMetric) Size() (n int)

func (*NewRelicMetric) String added in v1.0.0 

func (this *NewRelicMetric) String() string

func (*NewRelicMetric) Unmarshal added in v1.0.0 

func (m *NewRelicMetric) Unmarshal(dAtA []byte) error

func (*NewRelicMetric) XXX_DiscardUnknown added in v1.0.0 

func (m *NewRelicMetric) XXX_DiscardUnknown()

func (*NewRelicMetric) XXX_Marshal added in v1.0.0 

func (m *NewRelicMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewRelicMetric) XXX_Merge added in v1.0.0 

func (m *NewRelicMetric) XXX_Merge(src proto.Message)

func (*NewRelicMetric) XXX_Size added in v1.0.0 

func (m *NewRelicMetric) XXX_Size() int

func (*NewRelicMetric) XXX_Unmarshal added in v1.0.0 

func (m *NewRelicMetric) XXX_Unmarshal(b []byte) error

type NginxTrafficRouting added in v0.8.0 

type NginxTrafficRouting struct {
	// AnnotationPrefix has to match the configured annotation prefix on the nginx ingress controller
	// +optional
	AnnotationPrefix string `json:"annotationPrefix,omitempty" protobuf:"bytes,1,opt,name=annotationPrefix"`
	// StableIngress refers to the name of an `Ingress` resource in the same namespace as the `Rollout`
	StableIngress string `json:"stableIngress" protobuf:"bytes,2,opt,name=stableIngress"`
	// +optional
	AdditionalIngressAnnotations map[string]string `json:"additionalIngressAnnotations,omitempty" protobuf:"bytes,3,rep,name=additionalIngressAnnotations"`
}

NginxTrafficRouting configuration for Nginx ingress controller to control traffic routing

func (*NginxTrafficRouting) DeepCopy added in v0.8.0 

func (in *NginxTrafficRouting) DeepCopy() *NginxTrafficRouting

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

func (*NginxTrafficRouting) DeepCopyInto added in v0.8.0 

func (in *NginxTrafficRouting) DeepCopyInto(out *NginxTrafficRouting)

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

func (*NginxTrafficRouting) Descriptor added in v1.0.0 

func (*NginxTrafficRouting) Descriptor() ([]byte, []int)

func (*NginxTrafficRouting) Marshal added in v1.0.0 

func (m *NginxTrafficRouting) Marshal() (dAtA []byte, err error)

func (*NginxTrafficRouting) MarshalTo added in v1.0.0 

func (m *NginxTrafficRouting) MarshalTo(dAtA []byte) (int, error)

func (*NginxTrafficRouting) MarshalToSizedBuffer added in v1.0.0 

func (m *NginxTrafficRouting) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NginxTrafficRouting) ProtoMessage added in v1.0.0 

func (*NginxTrafficRouting) ProtoMessage()

func (*NginxTrafficRouting) Reset added in v1.0.0 

func (m *NginxTrafficRouting) Reset()

func (*NginxTrafficRouting) Size added in v1.0.0 

func (m *NginxTrafficRouting) Size() (n int)

func (*NginxTrafficRouting) String added in v1.0.0 

func (this *NginxTrafficRouting) String() string

func (*NginxTrafficRouting) Unmarshal added in v1.0.0 

func (m *NginxTrafficRouting) Unmarshal(dAtA []byte) error

func (*NginxTrafficRouting) XXX_DiscardUnknown added in v1.0.0 

func (m *NginxTrafficRouting) XXX_DiscardUnknown()

func (*NginxTrafficRouting) XXX_Marshal added in v1.0.0 

func (m *NginxTrafficRouting) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NginxTrafficRouting) XXX_Merge added in v1.0.0 

func (m *NginxTrafficRouting) XXX_Merge(src proto.Message)

func (*NginxTrafficRouting) XXX_Size added in v1.0.0 

func (m *NginxTrafficRouting) XXX_Size() int

func (*NginxTrafficRouting) XXX_Unmarshal added in v1.0.0 

func (m *NginxTrafficRouting) XXX_Unmarshal(b []byte) error

type ObjectRef added in v1.0.0 

type ObjectRef struct {
	// API Version of the referent
	APIVersion string `json:"apiVersion,omitempty" protobuf:"bytes,1,opt,name=apiVersion"`
	// Kind of the referent
	Kind string `json:"kind,omitempty" protobuf:"bytes,2,opt,name=kind"`
	// Name of the referent
	Name string `json:"name,omitempty" protobuf:"bytes,3,opt,name=name"`
}

ObjectRef holds a references to the Kubernetes object

func (*ObjectRef) DeepCopy added in v1.0.0 

func (in *ObjectRef) DeepCopy() *ObjectRef

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

func (*ObjectRef) DeepCopyInto added in v1.0.0 

func (in *ObjectRef) DeepCopyInto(out *ObjectRef)

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

func (*ObjectRef) Descriptor added in v1.0.0 

func (*ObjectRef) Descriptor() ([]byte, []int)

func (*ObjectRef) Marshal added in v1.0.0 

func (m *ObjectRef) Marshal() (dAtA []byte, err error)

func (*ObjectRef) MarshalTo added in v1.0.0 

func (m *ObjectRef) MarshalTo(dAtA []byte) (int, error)

func (*ObjectRef) MarshalToSizedBuffer added in v1.0.0 

func (m *ObjectRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ObjectRef) ProtoMessage added in v1.0.0 

func (*ObjectRef) ProtoMessage()

func (*ObjectRef) Reset added in v1.0.0 

func (m *ObjectRef) Reset()

func (*ObjectRef) Size added in v1.0.0 

func (m *ObjectRef) Size() (n int)

func (*ObjectRef) String added in v1.0.0 

func (this *ObjectRef) String() string

func (*ObjectRef) Unmarshal added in v1.0.0 

func (m *ObjectRef) Unmarshal(dAtA []byte) error

func (*ObjectRef) XXX_DiscardUnknown added in v1.0.0 

func (m *ObjectRef) XXX_DiscardUnknown()

func (*ObjectRef) XXX_Marshal added in v1.0.0 

func (m *ObjectRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectRef) XXX_Merge added in v1.0.0 

func (m *ObjectRef) XXX_Merge(src proto.Message)

func (*ObjectRef) XXX_Size added in v1.0.0 

func (m *ObjectRef) XXX_Size() int

func (*ObjectRef) XXX_Unmarshal added in v1.0.0 

func (m *ObjectRef) XXX_Unmarshal(b []byte) error

type PauseCondition added in v0.6.0 

type PauseCondition struct {
	Reason    PauseReason `json:"reason" protobuf:"bytes,1,opt,name=reason,casttype=PauseReason"`
	StartTime metav1.Time `json:"startTime" protobuf:"bytes,2,opt,name=startTime"`
}

PauseCondition the reason for a pause and when it started

func (*PauseCondition) DeepCopy added in v0.6.0 

func (in *PauseCondition) DeepCopy() *PauseCondition

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

func (*PauseCondition) DeepCopyInto added in v0.6.0 

func (in *PauseCondition) DeepCopyInto(out *PauseCondition)

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

func (*PauseCondition) Descriptor added in v1.0.0 

func (*PauseCondition) Descriptor() ([]byte, []int)

func (*PauseCondition) Marshal added in v1.0.0 

func (m *PauseCondition) Marshal() (dAtA []byte, err error)

func (*PauseCondition) MarshalTo added in v1.0.0 

func (m *PauseCondition) MarshalTo(dAtA []byte) (int, error)

func (*PauseCondition) MarshalToSizedBuffer added in v1.0.0 

func (m *PauseCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PauseCondition) ProtoMessage added in v1.0.0 

func (*PauseCondition) ProtoMessage()

func (*PauseCondition) Reset added in v1.0.0 

func (m *PauseCondition) Reset()

func (*PauseCondition) Size added in v1.0.0 

func (m *PauseCondition) Size() (n int)

func (*PauseCondition) String added in v1.0.0 

func (this *PauseCondition) String() string

func (*PauseCondition) Unmarshal added in v1.0.0 

func (m *PauseCondition) Unmarshal(dAtA []byte) error

func (*PauseCondition) XXX_DiscardUnknown added in v1.0.0 

func (m *PauseCondition) XXX_DiscardUnknown()

func (*PauseCondition) XXX_Marshal added in v1.0.0 

func (m *PauseCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseCondition) XXX_Merge added in v1.0.0 

func (m *PauseCondition) XXX_Merge(src proto.Message)

func (*PauseCondition) XXX_Size added in v1.0.0 

func (m *PauseCondition) XXX_Size() int

func (*PauseCondition) XXX_Unmarshal added in v1.0.0 

func (m *PauseCondition) XXX_Unmarshal(b []byte) error

type PauseReason added in v0.6.0 

type PauseReason string

PauseReason reasons that the rollout can pause 

const (
	// PauseReasonInconclusiveAnalysis pauses rollout when rollout has an inconclusive analysis run
	PauseReasonInconclusiveAnalysis PauseReason = "InconclusiveAnalysisRun"
	// PauseReasonInconclusiveExperiment pauses rollout when rollout has an inconclusive experiment
	PauseReasonInconclusiveExperiment PauseReason = "InconclusiveExperiment"
	// PauseReasonCanaryPauseStep pause rollout for canary pause step
	PauseReasonCanaryPauseStep PauseReason = "CanaryPauseStep"
	// PauseReasonBlueGreenPause pause rollout before promoting rollout
	PauseReasonBlueGreenPause PauseReason = "BlueGreenPause"
)

type PodTemplateMetadata added in v0.6.0 

type PodTemplateMetadata struct {
	// Labels Additional labels to add to the experiment
	// +optional
	Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,1,rep,name=labels"`
	// Annotations additional annotations to add to the experiment
	// +optional
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,2,rep,name=annotations"`
}

PodTemplateMetadata extra labels to add to the template

func (*PodTemplateMetadata) DeepCopy added in v0.6.0 

func (in *PodTemplateMetadata) DeepCopy() *PodTemplateMetadata

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

func (*PodTemplateMetadata) DeepCopyInto added in v0.6.0 

func (in *PodTemplateMetadata) DeepCopyInto(out *PodTemplateMetadata)

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

func (*PodTemplateMetadata) Descriptor added in v1.0.0 

func (*PodTemplateMetadata) Descriptor() ([]byte, []int)

func (*PodTemplateMetadata) Marshal added in v1.0.0 

func (m *PodTemplateMetadata) Marshal() (dAtA []byte, err error)

func (*PodTemplateMetadata) MarshalTo added in v1.0.0 

func (m *PodTemplateMetadata) MarshalTo(dAtA []byte) (int, error)

func (*PodTemplateMetadata) MarshalToSizedBuffer added in v1.0.0 

func (m *PodTemplateMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodTemplateMetadata) ProtoMessage added in v1.0.0 

func (*PodTemplateMetadata) ProtoMessage()

func (*PodTemplateMetadata) Reset added in v1.0.0 

func (m *PodTemplateMetadata) Reset()

func (*PodTemplateMetadata) Size added in v1.0.0 

func (m *PodTemplateMetadata) Size() (n int)

func (*PodTemplateMetadata) String added in v1.0.0 

func (this *PodTemplateMetadata) String() string

func (*PodTemplateMetadata) Unmarshal added in v1.0.0 

func (m *PodTemplateMetadata) Unmarshal(dAtA []byte) error

func (*PodTemplateMetadata) XXX_DiscardUnknown added in v1.0.0 

func (m *PodTemplateMetadata) XXX_DiscardUnknown()

func (*PodTemplateMetadata) XXX_Marshal added in v1.0.0 

func (m *PodTemplateMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodTemplateMetadata) XXX_Merge added in v1.0.0 

func (m *PodTemplateMetadata) XXX_Merge(src proto.Message)

func (*PodTemplateMetadata) XXX_Size added in v1.0.0 

func (m *PodTemplateMetadata) XXX_Size() int

func (*PodTemplateMetadata) XXX_Unmarshal added in v1.0.0 

func (m *PodTemplateMetadata) XXX_Unmarshal(b []byte) error

type PreferredDuringSchedulingIgnoredDuringExecution added in v0.8.0 

type PreferredDuringSchedulingIgnoredDuringExecution struct {
	// Weight associated with matching the corresponding podAffinityTerm, in the range 1-100.
	Weight int32 `json:"weight" protobuf:"varint,1,opt,name=weight"`
}

PreferredDuringSchedulingIgnoredDuringExecution defines the weight of the anti-affinity injection

func (*PreferredDuringSchedulingIgnoredDuringExecution) DeepCopy added in v0.8.0 

func (in *PreferredDuringSchedulingIgnoredDuringExecution) DeepCopy() *PreferredDuringSchedulingIgnoredDuringExecution

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

func (*PreferredDuringSchedulingIgnoredDuringExecution) DeepCopyInto added in v0.8.0 

func (in *PreferredDuringSchedulingIgnoredDuringExecution) DeepCopyInto(out *PreferredDuringSchedulingIgnoredDuringExecution)

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

func (*PreferredDuringSchedulingIgnoredDuringExecution) Descriptor added in v1.0.0 

func (*PreferredDuringSchedulingIgnoredDuringExecution) Descriptor() ([]byte, []int)

func (*PreferredDuringSchedulingIgnoredDuringExecution) Marshal added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) Marshal() (dAtA []byte, err error)

func (*PreferredDuringSchedulingIgnoredDuringExecution) MarshalTo added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) MarshalTo(dAtA []byte) (int, error)

func (*PreferredDuringSchedulingIgnoredDuringExecution) MarshalToSizedBuffer added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreferredDuringSchedulingIgnoredDuringExecution) ProtoMessage added in v1.0.0 

func (*PreferredDuringSchedulingIgnoredDuringExecution) ProtoMessage()

func (*PreferredDuringSchedulingIgnoredDuringExecution) Reset added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) Reset()

func (*PreferredDuringSchedulingIgnoredDuringExecution) Size added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) Size() (n int)

func (*PreferredDuringSchedulingIgnoredDuringExecution) String added in v1.0.0 

func (this *PreferredDuringSchedulingIgnoredDuringExecution) String() string

func (*PreferredDuringSchedulingIgnoredDuringExecution) Unmarshal added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) Unmarshal(dAtA []byte) error

func (*PreferredDuringSchedulingIgnoredDuringExecution) XXX_DiscardUnknown added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) XXX_DiscardUnknown()

func (*PreferredDuringSchedulingIgnoredDuringExecution) XXX_Marshal added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PreferredDuringSchedulingIgnoredDuringExecution) XXX_Merge added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) XXX_Merge(src proto.Message)

func (*PreferredDuringSchedulingIgnoredDuringExecution) XXX_Size added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) XXX_Size() int

func (*PreferredDuringSchedulingIgnoredDuringExecution) XXX_Unmarshal added in v1.0.0 

func (m *PreferredDuringSchedulingIgnoredDuringExecution) XXX_Unmarshal(b []byte) error

type PrometheusMetric added in v0.6.0 

type PrometheusMetric struct {
	// Address is the HTTP address and port of the prometheus server
	Address string `json:"address,omitempty" protobuf:"bytes,1,opt,name=address"`
	// Query is a raw prometheus query to perform
	Query string `json:"query,omitempty" protobuf:"bytes,2,opt,name=query"`
}

PrometheusMetric defines the prometheus query to perform canary analysis

func (*PrometheusMetric) DeepCopy added in v0.6.0 

func (in *PrometheusMetric) DeepCopy() *PrometheusMetric

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

func (*PrometheusMetric) DeepCopyInto added in v0.6.0 

func (in *PrometheusMetric) DeepCopyInto(out *PrometheusMetric)

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

func (*PrometheusMetric) Descriptor added in v1.0.0 

func (*PrometheusMetric) Descriptor() ([]byte, []int)

func (*PrometheusMetric) Marshal added in v1.0.0 

func (m *PrometheusMetric) Marshal() (dAtA []byte, err error)

func (*PrometheusMetric) MarshalTo added in v1.0.0 

func (m *PrometheusMetric) MarshalTo(dAtA []byte) (int, error)

func (*PrometheusMetric) MarshalToSizedBuffer added in v1.0.0 

func (m *PrometheusMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PrometheusMetric) ProtoMessage added in v1.0.0 

func (*PrometheusMetric) ProtoMessage()

func (*PrometheusMetric) Reset added in v1.0.0 

func (m *PrometheusMetric) Reset()

func (*PrometheusMetric) Size added in v1.0.0 

func (m *PrometheusMetric) Size() (n int)

func (*PrometheusMetric) String added in v1.0.0 

func (this *PrometheusMetric) String() string

func (*PrometheusMetric) Unmarshal added in v1.0.0 

func (m *PrometheusMetric) Unmarshal(dAtA []byte) error

func (*PrometheusMetric) XXX_DiscardUnknown added in v1.0.0 

func (m *PrometheusMetric) XXX_DiscardUnknown()

func (*PrometheusMetric) XXX_Marshal added in v1.0.0 

func (m *PrometheusMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrometheusMetric) XXX_Merge added in v1.0.0 

func (m *PrometheusMetric) XXX_Merge(src proto.Message)

func (*PrometheusMetric) XXX_Size added in v1.0.0 

func (m *PrometheusMetric) XXX_Size() int

func (*PrometheusMetric) XXX_Unmarshal added in v1.0.0 

func (m *PrometheusMetric) XXX_Unmarshal(b []byte) error

type ReplicaSetSpecRef added in v0.6.0 

type ReplicaSetSpecRef string

ReplicaSetSpecRef defines which RS that the experiment's template will use. 

const (
	// CanarySpecRef indicates the RS template should be pulled from the newRS's template
	CanarySpecRef ReplicaSetSpecRef = "canary"
	// StableSpecRef indicates the RS template should be pulled from the stableRS's template
	StableSpecRef ReplicaSetSpecRef = "stable"
)

type RequiredDuringSchedulingIgnoredDuringExecution added in v0.8.0 

type RequiredDuringSchedulingIgnoredDuringExecution struct{}

RequiredDuringSchedulingIgnoredDuringExecution defines inter-pod scheduling rule to be RequiredDuringSchedulingIgnoredDuringExecution

func (*RequiredDuringSchedulingIgnoredDuringExecution) DeepCopy added in v0.8.0 

func (in *RequiredDuringSchedulingIgnoredDuringExecution) DeepCopy() *RequiredDuringSchedulingIgnoredDuringExecution

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

func (*RequiredDuringSchedulingIgnoredDuringExecution) DeepCopyInto added in v0.8.0 

func (in *RequiredDuringSchedulingIgnoredDuringExecution) DeepCopyInto(out *RequiredDuringSchedulingIgnoredDuringExecution)

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

func (*RequiredDuringSchedulingIgnoredDuringExecution) Descriptor added in v1.0.0 

func (*RequiredDuringSchedulingIgnoredDuringExecution) Descriptor() ([]byte, []int)

func (*RequiredDuringSchedulingIgnoredDuringExecution) Marshal added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) Marshal() (dAtA []byte, err error)

func (*RequiredDuringSchedulingIgnoredDuringExecution) MarshalTo added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) MarshalTo(dAtA []byte) (int, error)

func (*RequiredDuringSchedulingIgnoredDuringExecution) MarshalToSizedBuffer added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequiredDuringSchedulingIgnoredDuringExecution) ProtoMessage added in v1.0.0 

func (*RequiredDuringSchedulingIgnoredDuringExecution) ProtoMessage()

func (*RequiredDuringSchedulingIgnoredDuringExecution) Reset added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) Reset()

func (*RequiredDuringSchedulingIgnoredDuringExecution) Size added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) Size() (n int)

func (*RequiredDuringSchedulingIgnoredDuringExecution) String added in v1.0.0 

func (this *RequiredDuringSchedulingIgnoredDuringExecution) String() string

func (*RequiredDuringSchedulingIgnoredDuringExecution) Unmarshal added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) Unmarshal(dAtA []byte) error

func (*RequiredDuringSchedulingIgnoredDuringExecution) XXX_DiscardUnknown added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) XXX_DiscardUnknown()

func (*RequiredDuringSchedulingIgnoredDuringExecution) XXX_Marshal added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequiredDuringSchedulingIgnoredDuringExecution) XXX_Merge added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) XXX_Merge(src proto.Message)

func (*RequiredDuringSchedulingIgnoredDuringExecution) XXX_Size added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) XXX_Size() int

func (*RequiredDuringSchedulingIgnoredDuringExecution) XXX_Unmarshal added in v1.0.0 

func (m *RequiredDuringSchedulingIgnoredDuringExecution) XXX_Unmarshal(b []byte) error

type Rollout 

type Rollout struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   RolloutSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	Status RolloutStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

Rollout is a specification for a Rollout resource

func (*Rollout) DeepCopy 

func (in *Rollout) DeepCopy() *Rollout

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

func (*Rollout) DeepCopyInto 

func (in *Rollout) DeepCopyInto(out *Rollout)

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

func (*Rollout) DeepCopyObject 

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

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

func (*Rollout) Descriptor added in v1.0.0 

func (*Rollout) Descriptor() ([]byte, []int)

func (*Rollout) Marshal added in v1.0.0 

func (m *Rollout) Marshal() (dAtA []byte, err error)

func (*Rollout) MarshalTo added in v1.0.0 

func (m *Rollout) MarshalTo(dAtA []byte) (int, error)

func (*Rollout) MarshalToSizedBuffer added in v1.0.0 

func (m *Rollout) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Rollout) ProtoMessage added in v1.0.0 

func (*Rollout) ProtoMessage()

func (*Rollout) Reset added in v1.0.0 

func (m *Rollout) Reset()

func (*Rollout) Size added in v1.0.0 

func (m *Rollout) Size() (n int)

func (*Rollout) String added in v1.0.0 

func (this *Rollout) String() string

func (*Rollout) Unmarshal added in v1.0.0 

func (m *Rollout) Unmarshal(dAtA []byte) error

func (*Rollout) XXX_DiscardUnknown added in v1.0.0 

func (m *Rollout) XXX_DiscardUnknown()

func (*Rollout) XXX_Marshal added in v1.0.0 

func (m *Rollout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Rollout) XXX_Merge added in v1.0.0 

func (m *Rollout) XXX_Merge(src proto.Message)

func (*Rollout) XXX_Size added in v1.0.0 

func (m *Rollout) XXX_Size() int

func (*Rollout) XXX_Unmarshal added in v1.0.0 

func (m *Rollout) XXX_Unmarshal(b []byte) error

type RolloutAnalysis added in v0.8.0 

type RolloutAnalysis struct {
	//Templates reference to a list of analysis templates to combine for an AnalysisRun
	Templates []RolloutAnalysisTemplate `json:"templates,omitempty" protobuf:"bytes,1,rep,name=templates"`
	// Args the arguments that will be added to the AnalysisRuns
	// +patchMergeKey=name
	// +patchStrategy=merge
	Args []AnalysisRunArgument `json:"args,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=args"`
}

RolloutAnalysis defines a template that is used to create a analysisRun

func (*RolloutAnalysis) DeepCopy added in v0.8.0 

func (in *RolloutAnalysis) DeepCopy() *RolloutAnalysis

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

func (*RolloutAnalysis) DeepCopyInto added in v0.8.0 

func (in *RolloutAnalysis) DeepCopyInto(out *RolloutAnalysis)

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

func (*RolloutAnalysis) Descriptor added in v1.0.0 

func (*RolloutAnalysis) Descriptor() ([]byte, []int)

func (*RolloutAnalysis) Marshal added in v1.0.0 

func (m *RolloutAnalysis) Marshal() (dAtA []byte, err error)

func (*RolloutAnalysis) MarshalTo added in v1.0.0 

func (m *RolloutAnalysis) MarshalTo(dAtA []byte) (int, error)

func (*RolloutAnalysis) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutAnalysis) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutAnalysis) ProtoMessage added in v1.0.0 

func (*RolloutAnalysis) ProtoMessage()

func (*RolloutAnalysis) Reset added in v1.0.0 

func (m *RolloutAnalysis) Reset()

func (*RolloutAnalysis) Size added in v1.0.0 

func (m *RolloutAnalysis) Size() (n int)

func (*RolloutAnalysis) String added in v1.0.0 

func (this *RolloutAnalysis) String() string

func (*RolloutAnalysis) Unmarshal added in v1.0.0 

func (m *RolloutAnalysis) Unmarshal(dAtA []byte) error

func (*RolloutAnalysis) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutAnalysis) XXX_DiscardUnknown()

func (*RolloutAnalysis) XXX_Marshal added in v1.0.0 

func (m *RolloutAnalysis) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutAnalysis) XXX_Merge added in v1.0.0 

func (m *RolloutAnalysis) XXX_Merge(src proto.Message)

func (*RolloutAnalysis) XXX_Size added in v1.0.0 

func (m *RolloutAnalysis) XXX_Size() int

func (*RolloutAnalysis) XXX_Unmarshal added in v1.0.0 

func (m *RolloutAnalysis) XXX_Unmarshal(b []byte) error

type RolloutAnalysisBackground added in v0.7.0 

type RolloutAnalysisBackground struct {
	RolloutAnalysis `json:",inline" protobuf:"bytes,1,opt,name=rolloutAnalysis"`
	// StartingStep indicates which step the background analysis should start on
	// If not listed, controller defaults to 0
	StartingStep *int32 `json:"startingStep,omitempty" protobuf:"varint,2,opt,name=startingStep"`
}

RolloutAnalysisBackground defines a template that is used to create a background analysisRun

func (*RolloutAnalysisBackground) DeepCopy added in v0.7.0 

func (in *RolloutAnalysisBackground) DeepCopy() *RolloutAnalysisBackground

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

func (*RolloutAnalysisBackground) DeepCopyInto added in v0.7.0 

func (in *RolloutAnalysisBackground) DeepCopyInto(out *RolloutAnalysisBackground)

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

func (*RolloutAnalysisBackground) Descriptor added in v1.0.0 

func (*RolloutAnalysisBackground) Descriptor() ([]byte, []int)

func (*RolloutAnalysisBackground) Marshal added in v1.0.0 

func (m *RolloutAnalysisBackground) Marshal() (dAtA []byte, err error)

func (*RolloutAnalysisBackground) MarshalTo added in v1.0.0 

func (m *RolloutAnalysisBackground) MarshalTo(dAtA []byte) (int, error)

func (*RolloutAnalysisBackground) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutAnalysisBackground) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutAnalysisBackground) ProtoMessage added in v1.0.0 

func (*RolloutAnalysisBackground) ProtoMessage()

func (*RolloutAnalysisBackground) Reset added in v1.0.0 

func (m *RolloutAnalysisBackground) Reset()

func (*RolloutAnalysisBackground) Size added in v1.0.0 

func (m *RolloutAnalysisBackground) Size() (n int)

func (*RolloutAnalysisBackground) String added in v1.0.0 

func (this *RolloutAnalysisBackground) String() string

func (*RolloutAnalysisBackground) Unmarshal added in v1.0.0 

func (m *RolloutAnalysisBackground) Unmarshal(dAtA []byte) error

func (*RolloutAnalysisBackground) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutAnalysisBackground) XXX_DiscardUnknown()

func (*RolloutAnalysisBackground) XXX_Marshal added in v1.0.0 

func (m *RolloutAnalysisBackground) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutAnalysisBackground) XXX_Merge added in v1.0.0 

func (m *RolloutAnalysisBackground) XXX_Merge(src proto.Message)

func (*RolloutAnalysisBackground) XXX_Size added in v1.0.0 

func (m *RolloutAnalysisBackground) XXX_Size() int

func (*RolloutAnalysisBackground) XXX_Unmarshal added in v1.0.0 

func (m *RolloutAnalysisBackground) XXX_Unmarshal(b []byte) error

type RolloutAnalysisRunStatus added in v0.9.0 

type RolloutAnalysisRunStatus struct {
	Name    string        `json:"name" protobuf:"bytes,1,opt,name=name"`
	Status  AnalysisPhase `json:"status" protobuf:"bytes,2,opt,name=status,casttype=AnalysisPhase"`
	Message string        `json:"message,omitempty" protobuf:"bytes,3,opt,name=message"`
}

func (*RolloutAnalysisRunStatus) DeepCopy added in v0.9.0 

func (in *RolloutAnalysisRunStatus) DeepCopy() *RolloutAnalysisRunStatus

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

func (*RolloutAnalysisRunStatus) DeepCopyInto added in v0.9.0 

func (in *RolloutAnalysisRunStatus) DeepCopyInto(out *RolloutAnalysisRunStatus)

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

func (*RolloutAnalysisRunStatus) Descriptor added in v1.0.0 

func (*RolloutAnalysisRunStatus) Descriptor() ([]byte, []int)

func (*RolloutAnalysisRunStatus) Marshal added in v1.0.0 

func (m *RolloutAnalysisRunStatus) Marshal() (dAtA []byte, err error)

func (*RolloutAnalysisRunStatus) MarshalTo added in v1.0.0 

func (m *RolloutAnalysisRunStatus) MarshalTo(dAtA []byte) (int, error)

func (*RolloutAnalysisRunStatus) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutAnalysisRunStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutAnalysisRunStatus) ProtoMessage added in v1.0.0 

func (*RolloutAnalysisRunStatus) ProtoMessage()

func (*RolloutAnalysisRunStatus) Reset added in v1.0.0 

func (m *RolloutAnalysisRunStatus) Reset()

func (*RolloutAnalysisRunStatus) Size added in v1.0.0 

func (m *RolloutAnalysisRunStatus) Size() (n int)

func (*RolloutAnalysisRunStatus) String added in v1.0.0 

func (this *RolloutAnalysisRunStatus) String() string

func (*RolloutAnalysisRunStatus) Unmarshal added in v1.0.0 

func (m *RolloutAnalysisRunStatus) Unmarshal(dAtA []byte) error

func (*RolloutAnalysisRunStatus) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutAnalysisRunStatus) XXX_DiscardUnknown()

func (*RolloutAnalysisRunStatus) XXX_Marshal added in v1.0.0 

func (m *RolloutAnalysisRunStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutAnalysisRunStatus) XXX_Merge added in v1.0.0 

func (m *RolloutAnalysisRunStatus) XXX_Merge(src proto.Message)

func (*RolloutAnalysisRunStatus) XXX_Size added in v1.0.0 

func (m *RolloutAnalysisRunStatus) XXX_Size() int

func (*RolloutAnalysisRunStatus) XXX_Unmarshal added in v1.0.0 

func (m *RolloutAnalysisRunStatus) XXX_Unmarshal(b []byte) error

type RolloutAnalysisTemplate added in v0.9.0 

type RolloutAnalysisTemplate struct {
	//TemplateName name of template to use in AnalysisRun
	// +optional
	TemplateName string `json:"templateName" protobuf:"bytes,1,opt,name=templateName"`
	// Whether to look for the templateName at cluster scope or namespace scope
	// +optional
	ClusterScope bool `json:"clusterScope,omitempty" protobuf:"varint,2,opt,name=clusterScope"`
}

func (*RolloutAnalysisTemplate) DeepCopy added in v0.9.0 

func (in *RolloutAnalysisTemplate) DeepCopy() *RolloutAnalysisTemplate

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

func (*RolloutAnalysisTemplate) DeepCopyInto added in v0.9.0 

func (in *RolloutAnalysisTemplate) DeepCopyInto(out *RolloutAnalysisTemplate)

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

func (*RolloutAnalysisTemplate) Descriptor added in v1.0.0 

func (*RolloutAnalysisTemplate) Descriptor() ([]byte, []int)

func (*RolloutAnalysisTemplate) Marshal added in v1.0.0 

func (m *RolloutAnalysisTemplate) Marshal() (dAtA []byte, err error)

func (*RolloutAnalysisTemplate) MarshalTo added in v1.0.0 

func (m *RolloutAnalysisTemplate) MarshalTo(dAtA []byte) (int, error)

func (*RolloutAnalysisTemplate) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutAnalysisTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutAnalysisTemplate) ProtoMessage added in v1.0.0 

func (*RolloutAnalysisTemplate) ProtoMessage()

func (*RolloutAnalysisTemplate) Reset added in v1.0.0 

func (m *RolloutAnalysisTemplate) Reset()

func (*RolloutAnalysisTemplate) Size added in v1.0.0 

func (m *RolloutAnalysisTemplate) Size() (n int)

func (*RolloutAnalysisTemplate) String added in v1.0.0 

func (this *RolloutAnalysisTemplate) String() string

func (*RolloutAnalysisTemplate) Unmarshal added in v1.0.0 

func (m *RolloutAnalysisTemplate) Unmarshal(dAtA []byte) error

func (*RolloutAnalysisTemplate) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutAnalysisTemplate) XXX_DiscardUnknown()

func (*RolloutAnalysisTemplate) XXX_Marshal added in v1.0.0 

func (m *RolloutAnalysisTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutAnalysisTemplate) XXX_Merge added in v1.0.0 

func (m *RolloutAnalysisTemplate) XXX_Merge(src proto.Message)

func (*RolloutAnalysisTemplate) XXX_Size added in v1.0.0 

func (m *RolloutAnalysisTemplate) XXX_Size() int

func (*RolloutAnalysisTemplate) XXX_Unmarshal added in v1.0.0 

func (m *RolloutAnalysisTemplate) XXX_Unmarshal(b []byte) error

type RolloutCondition 

type RolloutCondition struct {
	// Type of deployment condition.
	Type RolloutConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=RolloutConditionType"`
	// Phase of the condition, one of True, False, Unknown.
	Status corev1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/api/core/v1.ConditionStatus"`
	// The last time this condition was updated.
	LastUpdateTime metav1.Time `json:"lastUpdateTime" protobuf:"bytes,3,opt,name=lastUpdateTime"`
	// Last time the condition transitioned from one status to another.
	LastTransitionTime metav1.Time `json:"lastTransitionTime" protobuf:"bytes,4,opt,name=lastTransitionTime"`
	// The reason for the condition's last transition.
	Reason string `json:"reason" protobuf:"bytes,5,opt,name=reason"`
	// A human readable message indicating details about the transition.
	Message string `json:"message" protobuf:"bytes,6,opt,name=message"`
}

RolloutCondition describes the state of a rollout at a certain point.

func (*RolloutCondition) DeepCopy 

func (in *RolloutCondition) DeepCopy() *RolloutCondition

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

func (*RolloutCondition) DeepCopyInto 

func (in *RolloutCondition) DeepCopyInto(out *RolloutCondition)

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

func (*RolloutCondition) Descriptor added in v1.0.0 

func (*RolloutCondition) Descriptor() ([]byte, []int)

func (*RolloutCondition) Marshal added in v1.0.0 

func (m *RolloutCondition) Marshal() (dAtA []byte, err error)

func (*RolloutCondition) MarshalTo added in v1.0.0 

func (m *RolloutCondition) MarshalTo(dAtA []byte) (int, error)

func (*RolloutCondition) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutCondition) ProtoMessage added in v1.0.0 

func (*RolloutCondition) ProtoMessage()

func (*RolloutCondition) Reset added in v1.0.0 

func (m *RolloutCondition) Reset()

func (*RolloutCondition) Size added in v1.0.0 

func (m *RolloutCondition) Size() (n int)

func (*RolloutCondition) String added in v1.0.0 

func (this *RolloutCondition) String() string

func (*RolloutCondition) Unmarshal added in v1.0.0 

func (m *RolloutCondition) Unmarshal(dAtA []byte) error

func (*RolloutCondition) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutCondition) XXX_DiscardUnknown()

func (*RolloutCondition) XXX_Marshal added in v1.0.0 

func (m *RolloutCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutCondition) XXX_Merge added in v1.0.0 

func (m *RolloutCondition) XXX_Merge(src proto.Message)

func (*RolloutCondition) XXX_Size added in v1.0.0 

func (m *RolloutCondition) XXX_Size() int

func (*RolloutCondition) XXX_Unmarshal added in v1.0.0 

func (m *RolloutCondition) XXX_Unmarshal(b []byte) error

type RolloutConditionType 

type RolloutConditionType string

RolloutConditionType defines the conditions of Rollout 

const (
	// InvalidSpec means the rollout has an invalid spec and will not progress until
	// the spec is fixed.
	InvalidSpec RolloutConditionType = "InvalidSpec"
	// RolloutAvailable means the rollout is available, ie. the active service is pointing at a
	// replicaset with the required replicas up and running for at least minReadySeconds.
	RolloutAvailable RolloutConditionType = "Available"
	// RolloutProgressing means the rollout is progressing. Progress for a rollout is
	// considered when a new replica set is created or adopted, when pods scale
	// up or old pods scale down, or when the services are updated. Progress is not estimated
	// for paused rollouts.
	RolloutProgressing RolloutConditionType = "Progressing"
	// RolloutReplicaFailure ReplicaFailure is added in a deployment when one of its pods
	// fails to be created or deleted.
	RolloutReplicaFailure RolloutConditionType = "ReplicaFailure"
	// RolloutPaused means that rollout is in a paused state. It is still progressing at this point.
	RolloutPaused RolloutConditionType = "Paused"
	// RolloutCompleted means that rollout is in a completed state. It is still progressing at this point.
	RolloutCompleted RolloutConditionType = "Completed"
)

These are valid conditions of a rollout.

type RolloutExperimentStep added in v0.6.0 

type RolloutExperimentStep struct {
	// Templates what templates that should be added to the experiment. Should be non-nil
	// +patchMergeKey=name
	// +patchStrategy=merge
	Templates []RolloutExperimentTemplate `json:"templates" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,1,rep,name=templates"`
	// Duration is a duration string (e.g. 30s, 5m, 1h) that the experiment should run for
	// +optional
	Duration DurationString `json:"duration,omitempty" protobuf:"bytes,2,opt,name=duration,casttype=DurationString"`
	// Analyses reference which analysis templates to run with the experiment
	// +patchMergeKey=name
	// +patchStrategy=merge
	Analyses []RolloutExperimentStepAnalysisTemplateRef `json:"analyses,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,3,rep,name=analyses"`
}

RolloutExperimentStep defines a template that is used to create a experiment for a step

func (*RolloutExperimentStep) DeepCopy added in v0.6.0 

func (in *RolloutExperimentStep) DeepCopy() *RolloutExperimentStep

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

func (*RolloutExperimentStep) DeepCopyInto added in v0.6.0 

func (in *RolloutExperimentStep) DeepCopyInto(out *RolloutExperimentStep)

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

func (*RolloutExperimentStep) Descriptor added in v1.0.0 

func (*RolloutExperimentStep) Descriptor() ([]byte, []int)

func (*RolloutExperimentStep) Marshal added in v1.0.0 

func (m *RolloutExperimentStep) Marshal() (dAtA []byte, err error)

func (*RolloutExperimentStep) MarshalTo added in v1.0.0 

func (m *RolloutExperimentStep) MarshalTo(dAtA []byte) (int, error)

func (*RolloutExperimentStep) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutExperimentStep) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutExperimentStep) ProtoMessage added in v1.0.0 

func (*RolloutExperimentStep) ProtoMessage()

func (*RolloutExperimentStep) Reset added in v1.0.0 

func (m *RolloutExperimentStep) Reset()

func (*RolloutExperimentStep) Size added in v1.0.0 

func (m *RolloutExperimentStep) Size() (n int)

func (*RolloutExperimentStep) String added in v1.0.0 

func (this *RolloutExperimentStep) String() string

func (*RolloutExperimentStep) Unmarshal added in v1.0.0 

func (m *RolloutExperimentStep) Unmarshal(dAtA []byte) error

func (*RolloutExperimentStep) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutExperimentStep) XXX_DiscardUnknown()

func (*RolloutExperimentStep) XXX_Marshal added in v1.0.0 

func (m *RolloutExperimentStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutExperimentStep) XXX_Merge added in v1.0.0 

func (m *RolloutExperimentStep) XXX_Merge(src proto.Message)

func (*RolloutExperimentStep) XXX_Size added in v1.0.0 

func (m *RolloutExperimentStep) XXX_Size() int

func (*RolloutExperimentStep) XXX_Unmarshal added in v1.0.0 

func (m *RolloutExperimentStep) XXX_Unmarshal(b []byte) error

type RolloutExperimentStepAnalysisTemplateRef added in v0.6.0 

type RolloutExperimentStepAnalysisTemplateRef struct {
	// Name is a name for this analysis template invocation
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// TemplateName reference of the AnalysisTemplate name used by the Experiment to create the run
	TemplateName string `json:"templateName" protobuf:"bytes,2,opt,name=templateName"`
	// Whether to look for the templateName at cluster scope or namespace scope
	// +optional
	ClusterScope bool `json:"clusterScope,omitempty" protobuf:"varint,3,opt,name=clusterScope"`
	// Args the arguments that will be added to the AnalysisRuns
	// +patchMergeKey=name
	// +patchStrategy=merge
	Args []AnalysisRunArgument `json:"args,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,4,rep,name=args"`
	// RequiredForCompletion blocks the Experiment from completing until the analysis has completed
	RequiredForCompletion bool `json:"requiredForCompletion,omitempty" protobuf:"varint,5,opt,name=requiredForCompletion"`
}

func (*RolloutExperimentStepAnalysisTemplateRef) DeepCopy added in v0.6.0 

func (in *RolloutExperimentStepAnalysisTemplateRef) DeepCopy() *RolloutExperimentStepAnalysisTemplateRef

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

func (*RolloutExperimentStepAnalysisTemplateRef) DeepCopyInto added in v0.6.0 

func (in *RolloutExperimentStepAnalysisTemplateRef) DeepCopyInto(out *RolloutExperimentStepAnalysisTemplateRef)

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

func (*RolloutExperimentStepAnalysisTemplateRef) Descriptor added in v1.0.0 

func (*RolloutExperimentStepAnalysisTemplateRef) Descriptor() ([]byte, []int)

func (*RolloutExperimentStepAnalysisTemplateRef) Marshal added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) Marshal() (dAtA []byte, err error)

func (*RolloutExperimentStepAnalysisTemplateRef) MarshalTo added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) MarshalTo(dAtA []byte) (int, error)

func (*RolloutExperimentStepAnalysisTemplateRef) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutExperimentStepAnalysisTemplateRef) ProtoMessage added in v1.0.0 

func (*RolloutExperimentStepAnalysisTemplateRef) ProtoMessage()

func (*RolloutExperimentStepAnalysisTemplateRef) Reset added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) Reset()

func (*RolloutExperimentStepAnalysisTemplateRef) Size added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) Size() (n int)

func (*RolloutExperimentStepAnalysisTemplateRef) String added in v1.0.0 

func (this *RolloutExperimentStepAnalysisTemplateRef) String() string

func (*RolloutExperimentStepAnalysisTemplateRef) Unmarshal added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) Unmarshal(dAtA []byte) error

func (*RolloutExperimentStepAnalysisTemplateRef) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) XXX_DiscardUnknown()

func (*RolloutExperimentStepAnalysisTemplateRef) XXX_Marshal added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutExperimentStepAnalysisTemplateRef) XXX_Merge added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) XXX_Merge(src proto.Message)

func (*RolloutExperimentStepAnalysisTemplateRef) XXX_Size added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) XXX_Size() int

func (*RolloutExperimentStepAnalysisTemplateRef) XXX_Unmarshal added in v1.0.0 

func (m *RolloutExperimentStepAnalysisTemplateRef) XXX_Unmarshal(b []byte) error

type RolloutExperimentTemplate added in v0.6.0 

type RolloutExperimentTemplate struct {
	// Name description of template that passed to the template
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// SpecRef indicates where the rollout should get the RS template from
	SpecRef ReplicaSetSpecRef `json:"specRef" protobuf:"bytes,2,opt,name=specRef,casttype=ReplicaSetSpecRef"`
	// Replicas replica count for the template
	// +optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,3,opt,name=replicas"`
	// Metadata sets labels and annotations to use for the RS created from the template
	// +optional
	Metadata PodTemplateMetadata `json:"metadata,omitempty" protobuf:"bytes,4,opt,name=metadata"`
	// Selector overrides the selector to be used for the template's ReplicaSet. If omitted, will
	// use the same selector as the Rollout
	// +optional
	Selector *metav1.LabelSelector `json:"selector,omitempty" protobuf:"bytes,5,opt,name=selector"`
}

RolloutExperimentTemplate defines the template used to create experiments for the Rollout's experiment canary step

func (*RolloutExperimentTemplate) DeepCopy added in v0.6.0 

func (in *RolloutExperimentTemplate) DeepCopy() *RolloutExperimentTemplate

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

func (*RolloutExperimentTemplate) DeepCopyInto added in v0.6.0 

func (in *RolloutExperimentTemplate) DeepCopyInto(out *RolloutExperimentTemplate)

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

func (*RolloutExperimentTemplate) Descriptor added in v1.0.0 

func (*RolloutExperimentTemplate) Descriptor() ([]byte, []int)

func (*RolloutExperimentTemplate) Marshal added in v1.0.0 

func (m *RolloutExperimentTemplate) Marshal() (dAtA []byte, err error)

func (*RolloutExperimentTemplate) MarshalTo added in v1.0.0 

func (m *RolloutExperimentTemplate) MarshalTo(dAtA []byte) (int, error)

func (*RolloutExperimentTemplate) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutExperimentTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutExperimentTemplate) ProtoMessage added in v1.0.0 

func (*RolloutExperimentTemplate) ProtoMessage()

func (*RolloutExperimentTemplate) Reset added in v1.0.0 

func (m *RolloutExperimentTemplate) Reset()

func (*RolloutExperimentTemplate) Size added in v1.0.0 

func (m *RolloutExperimentTemplate) Size() (n int)

func (*RolloutExperimentTemplate) String added in v1.0.0 

func (this *RolloutExperimentTemplate) String() string

func (*RolloutExperimentTemplate) Unmarshal added in v1.0.0 

func (m *RolloutExperimentTemplate) Unmarshal(dAtA []byte) error

func (*RolloutExperimentTemplate) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutExperimentTemplate) XXX_DiscardUnknown()

func (*RolloutExperimentTemplate) XXX_Marshal added in v1.0.0 

func (m *RolloutExperimentTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutExperimentTemplate) XXX_Merge added in v1.0.0 

func (m *RolloutExperimentTemplate) XXX_Merge(src proto.Message)

func (*RolloutExperimentTemplate) XXX_Size added in v1.0.0 

func (m *RolloutExperimentTemplate) XXX_Size() int

func (*RolloutExperimentTemplate) XXX_Unmarshal added in v1.0.0 

func (m *RolloutExperimentTemplate) XXX_Unmarshal(b []byte) error

type RolloutList 

type RolloutList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`

	Items []Rollout `json:"items" protobuf:"bytes,2,rep,name=items"`
}

RolloutList is a list of Rollout resources

func (*RolloutList) DeepCopy 

func (in *RolloutList) DeepCopy() *RolloutList

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

func (*RolloutList) DeepCopyInto 

func (in *RolloutList) DeepCopyInto(out *RolloutList)

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

func (*RolloutList) DeepCopyObject 

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

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

func (*RolloutList) Descriptor added in v1.0.0 

func (*RolloutList) Descriptor() ([]byte, []int)

func (*RolloutList) Marshal added in v1.0.0 

func (m *RolloutList) Marshal() (dAtA []byte, err error)

func (*RolloutList) MarshalTo added in v1.0.0 

func (m *RolloutList) MarshalTo(dAtA []byte) (int, error)

func (*RolloutList) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutList) ProtoMessage added in v1.0.0 

func (*RolloutList) ProtoMessage()

func (*RolloutList) Reset added in v1.0.0 

func (m *RolloutList) Reset()

func (*RolloutList) Size added in v1.0.0 

func (m *RolloutList) Size() (n int)

func (*RolloutList) String added in v1.0.0 

func (this *RolloutList) String() string

func (*RolloutList) Unmarshal added in v1.0.0 

func (m *RolloutList) Unmarshal(dAtA []byte) error

func (*RolloutList) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutList) XXX_DiscardUnknown()

func (*RolloutList) XXX_Marshal added in v1.0.0 

func (m *RolloutList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutList) XXX_Merge added in v1.0.0 

func (m *RolloutList) XXX_Merge(src proto.Message)

func (*RolloutList) XXX_Size added in v1.0.0 

func (m *RolloutList) XXX_Size() int

func (*RolloutList) XXX_Unmarshal added in v1.0.0 

func (m *RolloutList) XXX_Unmarshal(b []byte) error

type RolloutPause added in v0.2.0 

type RolloutPause struct {
	// Duration the amount of time to wait before moving to the next step.
	// +optional
	Duration *intstr.IntOrString `json:"duration,omitempty" protobuf:"bytes,1,opt,name=duration"`
}

RolloutPause defines a pause stage for a rollout

func (*RolloutPause) DeepCopy added in v0.2.0 

func (in *RolloutPause) DeepCopy() *RolloutPause

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

func (*RolloutPause) DeepCopyInto added in v0.2.0 

func (in *RolloutPause) DeepCopyInto(out *RolloutPause)

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

func (*RolloutPause) Descriptor added in v1.0.0 

func (*RolloutPause) Descriptor() ([]byte, []int)

func (RolloutPause) DurationSeconds added in v0.8.0 

func (p RolloutPause) DurationSeconds() int32

DurationSeconds converts the pause duration to seconds If Duration is nil 0 is returned if Duration values is string and does not contain a valid unit -1 is returned

func (*RolloutPause) Marshal added in v1.0.0 

func (m *RolloutPause) Marshal() (dAtA []byte, err error)

func (*RolloutPause) MarshalTo added in v1.0.0 

func (m *RolloutPause) MarshalTo(dAtA []byte) (int, error)

func (*RolloutPause) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutPause) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutPause) ProtoMessage added in v1.0.0 

func (*RolloutPause) ProtoMessage()

func (*RolloutPause) Reset added in v1.0.0 

func (m *RolloutPause) Reset()

func (*RolloutPause) Size added in v1.0.0 

func (m *RolloutPause) Size() (n int)

func (*RolloutPause) String added in v1.0.0 

func (this *RolloutPause) String() string

func (*RolloutPause) Unmarshal added in v1.0.0 

func (m *RolloutPause) Unmarshal(dAtA []byte) error

func (*RolloutPause) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutPause) XXX_DiscardUnknown()

func (*RolloutPause) XXX_Marshal added in v1.0.0 

func (m *RolloutPause) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutPause) XXX_Merge added in v1.0.0 

func (m *RolloutPause) XXX_Merge(src proto.Message)

func (*RolloutPause) XXX_Size added in v1.0.0 

func (m *RolloutPause) XXX_Size() int

func (*RolloutPause) XXX_Unmarshal added in v1.0.0 

func (m *RolloutPause) XXX_Unmarshal(b []byte) error

type RolloutPhase added in v1.0.0 

type RolloutPhase string

RolloutPhase are a set of phases that this rollout 

const (
	// RolloutPhaseHealthy indicates a rollout is healthy
	RolloutPhaseHealthy RolloutPhase = "Healthy"
	// RolloutPhaseDegraded indicates a rollout is degraded (e.g. pod unavailability, misconfiguration)
	RolloutPhaseDegraded RolloutPhase = "Degraded"
	// RolloutPhaseProgressing indicates a rollout is not yet healthy but still making progress towards a healthy state
	RolloutPhaseProgressing RolloutPhase = "Progressing"
	// RolloutPhasePaused indicates a rollout is not yet healthy and will not make progress until unpaused
	RolloutPhasePaused RolloutPhase = "Paused"
)

type RolloutSpec 

type RolloutSpec struct {
	TemplateResolvedFromRef bool `json:"-"`
	SelectorResolvedFromRef bool `json:"-"`
	// Number of desired pods. This is a pointer to distinguish between explicit
	// zero and not specified. Defaults to 1.
	// +optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,1,opt,name=replicas"`
	// Label selector for pods. Existing ReplicaSets whose pods are
	// selected by this will be the ones affected by this rollout.
	// It must match the pod template's labels.
	// +optional
	Selector *metav1.LabelSelector `json:"selector" protobuf:"bytes,2,opt,name=selector"`
	// Template describes the pods that will be created.
	// +optional
	Template corev1.PodTemplateSpec `json:"template" protobuf:"bytes,3,opt,name=template"`
	// WorkloadRef holds a references to a workload that provides Pod template
	// +optional
	WorkloadRef *ObjectRef `json:"workloadRef,omitempty" protobuf:"bytes,10,opt,name=workloadRef"`
	// Minimum number of seconds for which a newly created pod should be ready
	// without any of its container crashing, for it to be considered available.
	// Defaults to 0 (pod will be considered available as soon as it is ready)
	// +optional
	MinReadySeconds int32 `json:"minReadySeconds,omitempty" protobuf:"varint,4,opt,name=minReadySeconds"`
	// The deployment strategy to use to replace existing pods with new ones.
	// +optional
	Strategy RolloutStrategy `json:"strategy" protobuf:"bytes,5,opt,name=strategy"`
	// The number of old ReplicaSets to retain. If unspecified, will retain 10 old ReplicaSets
	RevisionHistoryLimit *int32 `json:"revisionHistoryLimit,omitempty" protobuf:"varint,6,opt,name=revisionHistoryLimit"`
	// Paused pauses the rollout at its current step.
	Paused bool `json:"paused,omitempty" protobuf:"varint,7,opt,name=paused"`
	// ProgressDeadlineSeconds The maximum time in seconds for a rollout to
	// make progress before it is considered to be failed. Argo Rollouts will
	// continue to process failed rollouts and a condition with a
	// ProgressDeadlineExceeded reason will be surfaced in the rollout status.
	// Note that progress will not be estimated during the time a rollout is paused.
	// Defaults to 600s.
	ProgressDeadlineSeconds *int32 `json:"progressDeadlineSeconds,omitempty" protobuf:"varint,8,opt,name=progressDeadlineSeconds"`
	// RestartAt indicates when all the pods of a Rollout should be restarted
	RestartAt *metav1.Time `json:"restartAt,omitempty" protobuf:"bytes,9,opt,name=restartAt"`
}

RolloutSpec is the spec for a Rollout resource

func (*RolloutSpec) DeepCopy 

func (in *RolloutSpec) DeepCopy() *RolloutSpec

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

func (*RolloutSpec) DeepCopyInto 

func (in *RolloutSpec) DeepCopyInto(out *RolloutSpec)

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

func (*RolloutSpec) Descriptor added in v1.0.0 

func (*RolloutSpec) Descriptor() ([]byte, []int)

func (*RolloutSpec) EmptyTemplate added in v1.0.2 

func (s *RolloutSpec) EmptyTemplate() bool

func (*RolloutSpec) Marshal added in v1.0.0 

func (m *RolloutSpec) Marshal() (dAtA []byte, err error)

func (*RolloutSpec) MarshalJSON added in v1.0.0 

func (s *RolloutSpec) MarshalJSON() ([]byte, error)

func (*RolloutSpec) MarshalTo added in v1.0.0 

func (m *RolloutSpec) MarshalTo(dAtA []byte) (int, error)

func (*RolloutSpec) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutSpec) ProtoMessage added in v1.0.0 

func (*RolloutSpec) ProtoMessage()

func (*RolloutSpec) Reset added in v1.0.0 

func (m *RolloutSpec) Reset()

func (*RolloutSpec) SetResolvedSelector added in v1.0.0 

func (s *RolloutSpec) SetResolvedSelector(selector *metav1.LabelSelector)

func (*RolloutSpec) SetResolvedTemplate added in v1.0.0 

func (s *RolloutSpec) SetResolvedTemplate(template corev1.PodTemplateSpec)

func (*RolloutSpec) Size added in v1.0.0 

func (m *RolloutSpec) Size() (n int)

func (*RolloutSpec) String added in v1.0.0 

func (this *RolloutSpec) String() string

func (*RolloutSpec) Unmarshal added in v1.0.0 

func (m *RolloutSpec) Unmarshal(dAtA []byte) error

func (*RolloutSpec) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutSpec) XXX_DiscardUnknown()

func (*RolloutSpec) XXX_Marshal added in v1.0.0 

func (m *RolloutSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutSpec) XXX_Merge added in v1.0.0 

func (m *RolloutSpec) XXX_Merge(src proto.Message)

func (*RolloutSpec) XXX_Size added in v1.0.0 

func (m *RolloutSpec) XXX_Size() int

func (*RolloutSpec) XXX_Unmarshal added in v1.0.0 

func (m *RolloutSpec) XXX_Unmarshal(b []byte) error

type RolloutStatus 

type RolloutStatus struct {
	// Abort cancel the current rollout progression
	Abort bool `json:"abort,omitempty" protobuf:"varint,1,opt,name=abort"`
	// PauseConditions indicates why the rollout is currently paused
	PauseConditions []PauseCondition `json:"pauseConditions,omitempty" protobuf:"bytes,2,rep,name=pauseConditions"`
	// ControllerPause indicates the controller has paused the rollout. It is set to true when
	// the controller adds a pause condition. This field helps to discern the scenario where a
	// rollout was resumed after being paused by the controller (e.g. via the plugin). In that
	// situation, the pauseConditions would have been cleared , but controllerPause would still be
	// set to true.
	ControllerPause bool `json:"controllerPause,omitempty" protobuf:"varint,3,opt,name=controllerPause"`
	// AbortedAt indicates the controller reconciled an aborted rollout. The controller uses this to understand if
	// the controller needs to do some specific work when a Rollout is aborted. For example, the reconcileAbort is used
	// to indicate if the Rollout should enter an aborted state when the latest AnalysisRun is a failure, or the controller
	// has already put the Rollout into an aborted and should create a new AnalysisRun.
	AbortedAt *metav1.Time `json:"abortedAt,omitempty" protobuf:"bytes,4,opt,name=abortedAt"`
	// CurrentPodHash the hash of the current pod template
	// +optional
	CurrentPodHash string `json:"currentPodHash,omitempty" protobuf:"bytes,5,opt,name=currentPodHash"`
	// CurrentStepHash the hash of the current list of steps for the current strategy. This is used to detect when the
	// list of current steps change
	// +optional
	CurrentStepHash string `json:"currentStepHash,omitempty" protobuf:"bytes,6,opt,name=currentStepHash"`
	// Total number of non-terminated pods targeted by this rollout (their labels match the selector).
	// +optional
	Replicas int32 `json:"replicas,omitempty" protobuf:"varint,7,opt,name=replicas"`
	// Total number of non-terminated pods targeted by this rollout that have the desired template spec.
	// +optional
	UpdatedReplicas int32 `json:"updatedReplicas,omitempty" protobuf:"varint,8,opt,name=updatedReplicas"`
	// Total number of ready pods targeted by this rollout.
	// +optional
	ReadyReplicas int32 `json:"readyReplicas,omitempty" protobuf:"varint,9,opt,name=readyReplicas"`
	// Total number of available pods (ready for at least minReadySeconds) targeted by this rollout.
	// +optional
	AvailableReplicas int32 `json:"availableReplicas,omitempty" protobuf:"varint,10,opt,name=availableReplicas"`
	// CurrentStepIndex defines the current step of the rollout is on. If the current step index is null, the
	// controller will execute the rollout.
	// +optional
	CurrentStepIndex *int32 `json:"currentStepIndex,omitempty" protobuf:"varint,11,opt,name=currentStepIndex"`
	// Count of hash collisions for the Rollout. The Rollout controller uses this
	// field as a collision avoidance mechanism when it needs to create the name for the
	// newest ReplicaSet.
	// +optional
	CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,12,opt,name=collisionCount"`
	// The generation observed by the rollout controller from metadata.generation
	// +optional
	ObservedGeneration string `json:"observedGeneration,omitempty" protobuf:"bytes,13,opt,name=observedGeneration"`
	// Conditions a list of conditions a rollout can have.
	// +optional
	Conditions []RolloutCondition `json:"conditions,omitempty" protobuf:"bytes,14,rep,name=conditions"`
	// Canary describes the state of the canary rollout
	// +optional
	Canary CanaryStatus `json:"canary,omitempty" protobuf:"bytes,15,opt,name=canary"`
	// BlueGreen describes the state of the bluegreen rollout
	// +optional
	BlueGreen BlueGreenStatus `json:"blueGreen,omitempty" protobuf:"bytes,16,opt,name=blueGreen"`
	// HPAReplicas the number of non-terminated replicas that are receiving active traffic
	// +optional
	HPAReplicas int32 `json:"HPAReplicas,omitempty" protobuf:"varint,17,opt,name=HPAReplicas"`
	// Selector that identifies the pods that are receiving active traffic
	// +optional
	Selector string `json:"selector,omitempty" protobuf:"bytes,18,opt,name=selector"`
	// StableRS indicates the replicaset that has successfully rolled out
	// +optional
	StableRS string `json:"stableRS,omitempty" protobuf:"bytes,19,opt,name=stableRS"`
	// RestartedAt indicates last time a Rollout was restarted
	RestartedAt *metav1.Time `json:"restartedAt,omitempty" protobuf:"bytes,20,opt,name=restartedAt"`
	// PromoteFull indicates if the rollout should perform a full promotion, skipping analysis and pauses.
	PromoteFull bool `json:"promoteFull,omitempty" protobuf:"varint,21,opt,name=promoteFull"`
	// Phase is the rollout phase. Clients should only rely on the value if status.observedGeneration equals metadata.generation
	Phase RolloutPhase `json:"phase,omitempty" protobuf:"bytes,22,opt,name=phase,casttype=RolloutPhase"`
	// Message provides details on why the rollout is in its current phase
	Message string `json:"message,omitempty" protobuf:"bytes,23,opt,name=message"`
}

RolloutStatus is the status for a Rollout resource

func (*RolloutStatus) DeepCopy 

func (in *RolloutStatus) DeepCopy() *RolloutStatus

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

func (*RolloutStatus) DeepCopyInto 

func (in *RolloutStatus) DeepCopyInto(out *RolloutStatus)

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

func (*RolloutStatus) Descriptor added in v1.0.0 

func (*RolloutStatus) Descriptor() ([]byte, []int)

func (*RolloutStatus) Marshal added in v1.0.0 

func (m *RolloutStatus) Marshal() (dAtA []byte, err error)

func (*RolloutStatus) MarshalTo added in v1.0.0 

func (m *RolloutStatus) MarshalTo(dAtA []byte) (int, error)

func (*RolloutStatus) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutStatus) ProtoMessage added in v1.0.0 

func (*RolloutStatus) ProtoMessage()

func (*RolloutStatus) Reset added in v1.0.0 

func (m *RolloutStatus) Reset()

func (*RolloutStatus) Size added in v1.0.0 

func (m *RolloutStatus) Size() (n int)

func (*RolloutStatus) String added in v1.0.0 

func (this *RolloutStatus) String() string

func (*RolloutStatus) Unmarshal added in v1.0.0 

func (m *RolloutStatus) Unmarshal(dAtA []byte) error

func (*RolloutStatus) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutStatus) XXX_DiscardUnknown()

func (*RolloutStatus) XXX_Marshal added in v1.0.0 

func (m *RolloutStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutStatus) XXX_Merge added in v1.0.0 

func (m *RolloutStatus) XXX_Merge(src proto.Message)

func (*RolloutStatus) XXX_Size added in v1.0.0 

func (m *RolloutStatus) XXX_Size() int

func (*RolloutStatus) XXX_Unmarshal added in v1.0.0 

func (m *RolloutStatus) XXX_Unmarshal(b []byte) error

type RolloutStrategy 

type RolloutStrategy struct {
	// +optional
	BlueGreen *BlueGreenStrategy `json:"blueGreen,omitempty" protobuf:"bytes,1,opt,name=blueGreen"`
	// +optional
	Canary *CanaryStrategy `json:"canary,omitempty" protobuf:"bytes,2,opt,name=canary"`
}

RolloutStrategy defines strategy to apply during next rollout

func (*RolloutStrategy) DeepCopy 

func (in *RolloutStrategy) DeepCopy() *RolloutStrategy

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

func (*RolloutStrategy) DeepCopyInto 

func (in *RolloutStrategy) DeepCopyInto(out *RolloutStrategy)

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

func (*RolloutStrategy) Descriptor added in v1.0.0 

func (*RolloutStrategy) Descriptor() ([]byte, []int)

func (*RolloutStrategy) Marshal added in v1.0.0 

func (m *RolloutStrategy) Marshal() (dAtA []byte, err error)

func (*RolloutStrategy) MarshalTo added in v1.0.0 

func (m *RolloutStrategy) MarshalTo(dAtA []byte) (int, error)

func (*RolloutStrategy) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutStrategy) ProtoMessage added in v1.0.0 

func (*RolloutStrategy) ProtoMessage()

func (*RolloutStrategy) Reset added in v1.0.0 

func (m *RolloutStrategy) Reset()

func (*RolloutStrategy) Size added in v1.0.0 

func (m *RolloutStrategy) Size() (n int)

func (*RolloutStrategy) String added in v1.0.0 

func (this *RolloutStrategy) String() string

func (*RolloutStrategy) Unmarshal added in v1.0.0 

func (m *RolloutStrategy) Unmarshal(dAtA []byte) error

func (*RolloutStrategy) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutStrategy) XXX_DiscardUnknown()

func (*RolloutStrategy) XXX_Marshal added in v1.0.0 

func (m *RolloutStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutStrategy) XXX_Merge added in v1.0.0 

func (m *RolloutStrategy) XXX_Merge(src proto.Message)

func (*RolloutStrategy) XXX_Size added in v1.0.0 

func (m *RolloutStrategy) XXX_Size() int

func (*RolloutStrategy) XXX_Unmarshal added in v1.0.0 

func (m *RolloutStrategy) XXX_Unmarshal(b []byte) error

type RolloutTrafficRouting added in v0.7.0 

type RolloutTrafficRouting struct {
	// Istio holds Istio specific configuration to route traffic
	Istio *IstioTrafficRouting `json:"istio,omitempty" protobuf:"bytes,1,opt,name=istio"`
	// Nginx holds Nginx Ingress specific configuration to route traffic
	Nginx *NginxTrafficRouting `json:"nginx,omitempty" protobuf:"bytes,2,opt,name=nginx"`
	// Nginx holds ALB Ingress specific configuration to route traffic
	ALB *ALBTrafficRouting `json:"alb,omitempty" protobuf:"bytes,3,opt,name=alb"`
	// SMI holds TrafficSplit specific configuration to route traffic
	SMI *SMITrafficRouting `json:"smi,omitempty" protobuf:"bytes,4,opt,name=smi"`
	// Ambassador holds specific configuration to use Ambassador to route traffic
	Ambassador *AmbassadorTrafficRouting `json:"ambassador,omitempty" protobuf:"bytes,5,opt,name=ambassador"`
}

RolloutTrafficRouting hosts all the different configuration for supported service meshes to enable more fine-grained traffic routing

func (*RolloutTrafficRouting) DeepCopy added in v0.7.0 

func (in *RolloutTrafficRouting) DeepCopy() *RolloutTrafficRouting

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

func (*RolloutTrafficRouting) DeepCopyInto added in v0.7.0 

func (in *RolloutTrafficRouting) DeepCopyInto(out *RolloutTrafficRouting)

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

func (*RolloutTrafficRouting) Descriptor added in v1.0.0 

func (*RolloutTrafficRouting) Descriptor() ([]byte, []int)

func (*RolloutTrafficRouting) Marshal added in v1.0.0 

func (m *RolloutTrafficRouting) Marshal() (dAtA []byte, err error)

func (*RolloutTrafficRouting) MarshalTo added in v1.0.0 

func (m *RolloutTrafficRouting) MarshalTo(dAtA []byte) (int, error)

func (*RolloutTrafficRouting) MarshalToSizedBuffer added in v1.0.0 

func (m *RolloutTrafficRouting) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RolloutTrafficRouting) ProtoMessage added in v1.0.0 

func (*RolloutTrafficRouting) ProtoMessage()

func (*RolloutTrafficRouting) Reset added in v1.0.0 

func (m *RolloutTrafficRouting) Reset()

func (*RolloutTrafficRouting) Size added in v1.0.0 

func (m *RolloutTrafficRouting) Size() (n int)

func (*RolloutTrafficRouting) String added in v1.0.0 

func (this *RolloutTrafficRouting) String() string

func (*RolloutTrafficRouting) Unmarshal added in v1.0.0 

func (m *RolloutTrafficRouting) Unmarshal(dAtA []byte) error

func (*RolloutTrafficRouting) XXX_DiscardUnknown added in v1.0.0 

func (m *RolloutTrafficRouting) XXX_DiscardUnknown()

func (*RolloutTrafficRouting) XXX_Marshal added in v1.0.0 

func (m *RolloutTrafficRouting) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RolloutTrafficRouting) XXX_Merge added in v1.0.0 

func (m *RolloutTrafficRouting) XXX_Merge(src proto.Message)

func (*RolloutTrafficRouting) XXX_Size added in v1.0.0 

func (m *RolloutTrafficRouting) XXX_Size() int

func (*RolloutTrafficRouting) XXX_Unmarshal added in v1.0.0 

func (m *RolloutTrafficRouting) XXX_Unmarshal(b []byte) error

type SMITrafficRouting added in v0.9.0 

type SMITrafficRouting struct {
	// RootService holds the name of that clients use to communicate.
	// +optional
	RootService string `json:"rootService,omitempty" protobuf:"bytes,1,opt,name=rootService"`
	// TrafficSplitName holds the name of the TrafficSplit.
	// +optional
	TrafficSplitName string `json:"trafficSplitName,omitempty" protobuf:"bytes,2,opt,name=trafficSplitName"`
}

SMITrafficRouting configuration for TrafficSplit Custom Resource to control traffic routing

func (*SMITrafficRouting) DeepCopy added in v0.9.0 

func (in *SMITrafficRouting) DeepCopy() *SMITrafficRouting

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

func (*SMITrafficRouting) DeepCopyInto added in v0.9.0 

func (in *SMITrafficRouting) DeepCopyInto(out *SMITrafficRouting)

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

func (*SMITrafficRouting) Descriptor added in v1.0.0 

func (*SMITrafficRouting) Descriptor() ([]byte, []int)

func (*SMITrafficRouting) Marshal added in v1.0.0 

func (m *SMITrafficRouting) Marshal() (dAtA []byte, err error)

func (*SMITrafficRouting) MarshalTo added in v1.0.0 

func (m *SMITrafficRouting) MarshalTo(dAtA []byte) (int, error)

func (*SMITrafficRouting) MarshalToSizedBuffer added in v1.0.0 

func (m *SMITrafficRouting) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SMITrafficRouting) ProtoMessage added in v1.0.0 

func (*SMITrafficRouting) ProtoMessage()

func (*SMITrafficRouting) Reset added in v1.0.0 

func (m *SMITrafficRouting) Reset()

func (*SMITrafficRouting) Size added in v1.0.0 

func (m *SMITrafficRouting) Size() (n int)

func (*SMITrafficRouting) String added in v1.0.0 

func (this *SMITrafficRouting) String() string

func (*SMITrafficRouting) Unmarshal added in v1.0.0 

func (m *SMITrafficRouting) Unmarshal(dAtA []byte) error

func (*SMITrafficRouting) XXX_DiscardUnknown added in v1.0.0 

func (m *SMITrafficRouting) XXX_DiscardUnknown()

func (*SMITrafficRouting) XXX_Marshal added in v1.0.0 

func (m *SMITrafficRouting) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SMITrafficRouting) XXX_Merge added in v1.0.0 

func (m *SMITrafficRouting) XXX_Merge(src proto.Message)

func (*SMITrafficRouting) XXX_Size added in v1.0.0 

func (m *SMITrafficRouting) XXX_Size() int

func (*SMITrafficRouting) XXX_Unmarshal added in v1.0.0 

func (m *SMITrafficRouting) XXX_Unmarshal(b []byte) error

type ScopeDetail added in v0.6.0 

type ScopeDetail struct {
	Scope  string `json:"scope" protobuf:"bytes,1,opt,name=scope"`
	Region string `json:"region" protobuf:"bytes,2,opt,name=region"`
	Step   int64  `json:"step" protobuf:"varint,3,opt,name=step"`
	Start  string `json:"start" protobuf:"bytes,4,opt,name=start"`
	End    string `json:"end" protobuf:"bytes,5,opt,name=end"`
}

func (*ScopeDetail) DeepCopy added in v0.6.0 

func (in *ScopeDetail) DeepCopy() *ScopeDetail

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

func (*ScopeDetail) DeepCopyInto added in v0.6.0 

func (in *ScopeDetail) DeepCopyInto(out *ScopeDetail)

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

func (*ScopeDetail) Descriptor added in v1.0.0 

func (*ScopeDetail) Descriptor() ([]byte, []int)

func (*ScopeDetail) Marshal added in v1.0.0 

func (m *ScopeDetail) Marshal() (dAtA []byte, err error)

func (*ScopeDetail) MarshalTo added in v1.0.0 

func (m *ScopeDetail) MarshalTo(dAtA []byte) (int, error)

func (*ScopeDetail) MarshalToSizedBuffer added in v1.0.0 

func (m *ScopeDetail) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScopeDetail) ProtoMessage added in v1.0.0 

func (*ScopeDetail) ProtoMessage()

func (*ScopeDetail) Reset added in v1.0.0 

func (m *ScopeDetail) Reset()

func (*ScopeDetail) Size added in v1.0.0 

func (m *ScopeDetail) Size() (n int)

func (*ScopeDetail) String added in v1.0.0 

func (this *ScopeDetail) String() string

func (*ScopeDetail) Unmarshal added in v1.0.0 

func (m *ScopeDetail) Unmarshal(dAtA []byte) error

func (*ScopeDetail) XXX_DiscardUnknown added in v1.0.0 

func (m *ScopeDetail) XXX_DiscardUnknown()

func (*ScopeDetail) XXX_Marshal added in v1.0.0 

func (m *ScopeDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScopeDetail) XXX_Merge added in v1.0.0 

func (m *ScopeDetail) XXX_Merge(src proto.Message)

func (*ScopeDetail) XXX_Size added in v1.0.0 

func (m *ScopeDetail) XXX_Size() int

func (*ScopeDetail) XXX_Unmarshal added in v1.0.0 

func (m *ScopeDetail) XXX_Unmarshal(b []byte) error

type SecretKeyRef added in v0.8.0 

type SecretKeyRef struct {
	// Name is the name of the secret
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Key is the key of the secret to select from.
	Key string `json:"key" protobuf:"bytes,2,opt,name=key"`
}

func (*SecretKeyRef) DeepCopy added in v0.8.0 

func (in *SecretKeyRef) DeepCopy() *SecretKeyRef

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

func (*SecretKeyRef) DeepCopyInto added in v0.8.0 

func (in *SecretKeyRef) DeepCopyInto(out *SecretKeyRef)

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

func (*SecretKeyRef) Descriptor added in v1.0.0 

func (*SecretKeyRef) Descriptor() ([]byte, []int)

func (*SecretKeyRef) Marshal added in v1.0.0 

func (m *SecretKeyRef) Marshal() (dAtA []byte, err error)

func (*SecretKeyRef) MarshalTo added in v1.0.0 

func (m *SecretKeyRef) MarshalTo(dAtA []byte) (int, error)

func (*SecretKeyRef) MarshalToSizedBuffer added in v1.0.0 

func (m *SecretKeyRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SecretKeyRef) ProtoMessage added in v1.0.0 

func (*SecretKeyRef) ProtoMessage()

func (*SecretKeyRef) Reset added in v1.0.0 

func (m *SecretKeyRef) Reset()

func (*SecretKeyRef) Size added in v1.0.0 

func (m *SecretKeyRef) Size() (n int)

func (*SecretKeyRef) String added in v1.0.0 

func (this *SecretKeyRef) String() string

func (*SecretKeyRef) Unmarshal added in v1.0.0 

func (m *SecretKeyRef) Unmarshal(dAtA []byte) error

func (*SecretKeyRef) XXX_DiscardUnknown added in v1.0.0 

func (m *SecretKeyRef) XXX_DiscardUnknown()

func (*SecretKeyRef) XXX_Marshal added in v1.0.0 

func (m *SecretKeyRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretKeyRef) XXX_Merge added in v1.0.0 

func (m *SecretKeyRef) XXX_Merge(src proto.Message)

func (*SecretKeyRef) XXX_Size added in v1.0.0 

func (m *SecretKeyRef) XXX_Size() int

func (*SecretKeyRef) XXX_Unmarshal added in v1.0.0 

func (m *SecretKeyRef) XXX_Unmarshal(b []byte) error

type SetCanaryScale added in v0.10.0 

type SetCanaryScale struct {
	// Weight sets the percentage of replicas the newRS should have
	// +optional
	Weight *int32 `json:"weight,omitempty" protobuf:"varint,1,opt,name=weight"`
	// Replicas sets the number of replicas the newRS should have
	// +optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`
	// MatchTrafficWeight cancels out previously set Replicas or Weight, effectively activating SetWeight
	// +optional
	MatchTrafficWeight bool `json:"matchTrafficWeight,omitempty" protobuf:"varint,3,opt,name=matchTrafficWeight"`
}

SetCanaryScale defines how to scale the newRS without changing traffic weight

func (*SetCanaryScale) DeepCopy added in v0.10.0 

func (in *SetCanaryScale) DeepCopy() *SetCanaryScale

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

func (*SetCanaryScale) DeepCopyInto added in v0.10.0 

func (in *SetCanaryScale) DeepCopyInto(out *SetCanaryScale)

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

func (*SetCanaryScale) Descriptor added in v1.0.0 

func (*SetCanaryScale) Descriptor() ([]byte, []int)

func (*SetCanaryScale) Marshal added in v1.0.0 

func (m *SetCanaryScale) Marshal() (dAtA []byte, err error)

func (*SetCanaryScale) MarshalTo added in v1.0.0 

func (m *SetCanaryScale) MarshalTo(dAtA []byte) (int, error)

func (*SetCanaryScale) MarshalToSizedBuffer added in v1.0.0 

func (m *SetCanaryScale) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetCanaryScale) ProtoMessage added in v1.0.0 

func (*SetCanaryScale) ProtoMessage()

func (*SetCanaryScale) Reset added in v1.0.0 

func (m *SetCanaryScale) Reset()

func (*SetCanaryScale) Size added in v1.0.0 

func (m *SetCanaryScale) Size() (n int)

func (*SetCanaryScale) String added in v1.0.0 

func (this *SetCanaryScale) String() string

func (*SetCanaryScale) Unmarshal added in v1.0.0 

func (m *SetCanaryScale) Unmarshal(dAtA []byte) error

func (*SetCanaryScale) XXX_DiscardUnknown added in v1.0.0 

func (m *SetCanaryScale) XXX_DiscardUnknown()

func (*SetCanaryScale) XXX_Marshal added in v1.0.0 

func (m *SetCanaryScale) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetCanaryScale) XXX_Merge added in v1.0.0 

func (m *SetCanaryScale) XXX_Merge(src proto.Message)

func (*SetCanaryScale) XXX_Size added in v1.0.0 

func (m *SetCanaryScale) XXX_Size() int

func (*SetCanaryScale) XXX_Unmarshal added in v1.0.0 

func (m *SetCanaryScale) XXX_Unmarshal(b []byte) error

type TemplateSpec added in v0.5.0 

type TemplateSpec struct {
	// Name of the template used to identity replicaset running for this experiment
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Number of desired pods. This is a pointer to distinguish between explicit
	// zero and not specified. Defaults to 1.
	// +optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`
	// Minimum number of seconds for which a newly created pod should be ready
	// without any of its container crashing, for it to be considered available.
	// Defaults to 0 (pod will be considered available as soon as it is ready)
	// +optional
	MinReadySeconds int32 `json:"minReadySeconds,omitempty" protobuf:"varint,3,opt,name=minReadySeconds"`
	// Label selector for pods. Existing ReplicaSets whose pods are
	// selected by this will be the ones affected by this experiment.
	// It must match the pod template's labels. Each selector must be unique to the other selectors in the other templates
	Selector *metav1.LabelSelector `json:"selector" protobuf:"bytes,4,opt,name=selector"`
	// Template describes the pods that will be created.
	Template corev1.PodTemplateSpec `json:"template" protobuf:"bytes,5,opt,name=template"`
}

func (*TemplateSpec) DeepCopy added in v0.5.0 

func (in *TemplateSpec) DeepCopy() *TemplateSpec

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

func (*TemplateSpec) DeepCopyInto added in v0.5.0 

func (in *TemplateSpec) DeepCopyInto(out *TemplateSpec)

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

func (*TemplateSpec) Descriptor added in v1.0.0 

func (*TemplateSpec) Descriptor() ([]byte, []int)

func (*TemplateSpec) Marshal added in v1.0.0 

func (m *TemplateSpec) Marshal() (dAtA []byte, err error)

func (*TemplateSpec) MarshalTo added in v1.0.0 

func (m *TemplateSpec) MarshalTo(dAtA []byte) (int, error)

func (*TemplateSpec) MarshalToSizedBuffer added in v1.0.0 

func (m *TemplateSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TemplateSpec) ProtoMessage added in v1.0.0 

func (*TemplateSpec) ProtoMessage()

func (*TemplateSpec) Reset added in v1.0.0 

func (m *TemplateSpec) Reset()

func (*TemplateSpec) Size added in v1.0.0 

func (m *TemplateSpec) Size() (n int)

func (*TemplateSpec) String added in v1.0.0 

func (this *TemplateSpec) String() string

func (*TemplateSpec) Unmarshal added in v1.0.0 

func (m *TemplateSpec) Unmarshal(dAtA []byte) error

func (*TemplateSpec) XXX_DiscardUnknown added in v1.0.0 

func (m *TemplateSpec) XXX_DiscardUnknown()

func (*TemplateSpec) XXX_Marshal added in v1.0.0 

func (m *TemplateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TemplateSpec) XXX_Merge added in v1.0.0 

func (m *TemplateSpec) XXX_Merge(src proto.Message)

func (*TemplateSpec) XXX_Size added in v1.0.0 

func (m *TemplateSpec) XXX_Size() int

func (*TemplateSpec) XXX_Unmarshal added in v1.0.0 

func (m *TemplateSpec) XXX_Unmarshal(b []byte) error

type TemplateStatus added in v0.5.0 

type TemplateStatus struct {
	// Name of the template used to identity which hash to compare to the hash
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// Total number of non-terminated pods targeted by this experiment (their labels match the selector).
	Replicas int32 `json:"replicas" protobuf:"varint,2,opt,name=replicas"`
	// Total number of non-terminated pods targeted by this experiment that have the desired template spec.
	UpdatedReplicas int32 `json:"updatedReplicas" protobuf:"varint,3,opt,name=updatedReplicas"`
	// Total number of ready pods targeted by this experiment.
	ReadyReplicas int32 `json:"readyReplicas" protobuf:"varint,4,opt,name=readyReplicas"`
	// Total number of available pods (ready for at least minReadySeconds) targeted by this experiment.
	AvailableReplicas int32 `json:"availableReplicas" protobuf:"varint,5,opt,name=availableReplicas"`
	// CollisionCount count of hash collisions for the Experiment. The Experiment controller uses this
	// field as a collision avoidance mechanism when it needs to create the name for the
	// newest ReplicaSet.
	// +optional
	CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,6,opt,name=collisionCount"`
	// Phase is the status of the ReplicaSet associated with the template
	Status TemplateStatusCode `json:"status,omitempty" protobuf:"bytes,7,opt,name=status,casttype=TemplateStatusCode"`
	// Message is a message explaining the current status
	Message string `json:"message,omitempty" protobuf:"bytes,8,opt,name=message"`
	// LastTransitionTime is the last time the replicaset transitioned, which resets the countdown
	// on the ProgressDeadlineSeconds check.
	LastTransitionTime *metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,9,opt,name=lastTransitionTime"`
}

TemplateStatus is the status of a specific template of an Experiment

func (*TemplateStatus) DeepCopy added in v0.5.0 

func (in *TemplateStatus) DeepCopy() *TemplateStatus

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

func (*TemplateStatus) DeepCopyInto added in v0.5.0 

func (in *TemplateStatus) DeepCopyInto(out *TemplateStatus)

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

func (*TemplateStatus) Descriptor added in v1.0.0 

func (*TemplateStatus) Descriptor() ([]byte, []int)

func (*TemplateStatus) Marshal added in v1.0.0 

func (m *TemplateStatus) Marshal() (dAtA []byte, err error)

func (*TemplateStatus) MarshalTo added in v1.0.0 

func (m *TemplateStatus) MarshalTo(dAtA []byte) (int, error)

func (*TemplateStatus) MarshalToSizedBuffer added in v1.0.0 

func (m *TemplateStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TemplateStatus) ProtoMessage added in v1.0.0 

func (*TemplateStatus) ProtoMessage()

func (*TemplateStatus) Reset added in v1.0.0 

func (m *TemplateStatus) Reset()

func (*TemplateStatus) Size added in v1.0.0 

func (m *TemplateStatus) Size() (n int)

func (*TemplateStatus) String added in v1.0.0 

func (this *TemplateStatus) String() string

func (*TemplateStatus) Unmarshal added in v1.0.0 

func (m *TemplateStatus) Unmarshal(dAtA []byte) error

func (*TemplateStatus) XXX_DiscardUnknown added in v1.0.0 

func (m *TemplateStatus) XXX_DiscardUnknown()

func (*TemplateStatus) XXX_Marshal added in v1.0.0 

func (m *TemplateStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TemplateStatus) XXX_Merge added in v1.0.0 

func (m *TemplateStatus) XXX_Merge(src proto.Message)

func (*TemplateStatus) XXX_Size added in v1.0.0 

func (m *TemplateStatus) XXX_Size() int

func (*TemplateStatus) XXX_Unmarshal added in v1.0.0 

func (m *TemplateStatus) XXX_Unmarshal(b []byte) error

type TemplateStatusCode added in v0.6.0 

type TemplateStatusCode string
const (
	TemplateStatusProgressing TemplateStatusCode = "Progressing"
	TemplateStatusRunning     TemplateStatusCode = "Running"
	TemplateStatusSuccessful  TemplateStatusCode = "Successful"
	TemplateStatusFailed      TemplateStatusCode = "Failed"
	TemplateStatusError       TemplateStatusCode = "Error"
)

func (TemplateStatusCode) Completed added in v0.6.0 

func (ts TemplateStatusCode) Completed() bool

type ValueFrom added in v0.8.0 

type ValueFrom struct {
	// Secret is a reference to where a secret is stored. This field is one of the fields with valueFrom
	// +optional
	SecretKeyRef *SecretKeyRef `json:"secretKeyRef,omitempty" protobuf:"bytes,1,opt,name=secretKeyRef"`
	//FieldRef is a reference to the fields in metadata which we are referencing. This field is one of the fields with
	//valueFrom
	// +optional
	FieldRef *FieldRef `json:"fieldRef,omitempty" protobuf:"bytes,2,opt,name=fieldRef"`
}

func (*ValueFrom) DeepCopy added in v0.8.0 

func (in *ValueFrom) DeepCopy() *ValueFrom

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

func (*ValueFrom) DeepCopyInto added in v0.8.0 

func (in *ValueFrom) DeepCopyInto(out *ValueFrom)

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

func (*ValueFrom) Descriptor added in v1.0.0 

func (*ValueFrom) Descriptor() ([]byte, []int)

func (*ValueFrom) Marshal added in v1.0.0 

func (m *ValueFrom) Marshal() (dAtA []byte, err error)

func (*ValueFrom) MarshalTo added in v1.0.0 

func (m *ValueFrom) MarshalTo(dAtA []byte) (int, error)

func (*ValueFrom) MarshalToSizedBuffer added in v1.0.0 

func (m *ValueFrom) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValueFrom) ProtoMessage added in v1.0.0 

func (*ValueFrom) ProtoMessage()

func (*ValueFrom) Reset added in v1.0.0 

func (m *ValueFrom) Reset()

func (*ValueFrom) Size added in v1.0.0 

func (m *ValueFrom) Size() (n int)

func (*ValueFrom) String added in v1.0.0 

func (this *ValueFrom) String() string

func (*ValueFrom) Unmarshal added in v1.0.0 

func (m *ValueFrom) Unmarshal(dAtA []byte) error

func (*ValueFrom) XXX_DiscardUnknown added in v1.0.0 

func (m *ValueFrom) XXX_DiscardUnknown()

func (*ValueFrom) XXX_Marshal added in v1.0.0 

func (m *ValueFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueFrom) XXX_Merge added in v1.0.0 

func (m *ValueFrom) XXX_Merge(src proto.Message)

func (*ValueFrom) XXX_Size added in v1.0.0 

func (m *ValueFrom) XXX_Size() int

func (*ValueFrom) XXX_Unmarshal added in v1.0.0 

func (m *ValueFrom) XXX_Unmarshal(b []byte) error

type ValueFromPodTemplateHash added in v0.6.0 

type ValueFromPodTemplateHash string

ValueFromPodTemplateHash indicates which ReplicaSet pod template pod hash to use 

const (
	// Stable tells the Rollout to get the pod template hash from the stable ReplicaSet
	Stable ValueFromPodTemplateHash = "Stable"
	// Latest tells the Rollout to get the pod template hash from the latest ReplicaSet
	Latest ValueFromPodTemplateHash = "Latest"
)

type WavefrontMetric added in v0.7.0 

type WavefrontMetric struct {
	// Address is the HTTP address and port of the wavefront server
	Address string `json:"address,omitempty" protobuf:"bytes,1,opt,name=address"`
	// Query is a raw wavefront query to perform
	Query string `json:"query,omitempty" protobuf:"bytes,2,opt,name=query"`
}

WavefrontMetric defines the wavefront query to perform canary analysis

func (*WavefrontMetric) DeepCopy added in v0.7.0 

func (in *WavefrontMetric) DeepCopy() *WavefrontMetric

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

func (*WavefrontMetric) DeepCopyInto added in v0.7.0 

func (in *WavefrontMetric) DeepCopyInto(out *WavefrontMetric)

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

func (*WavefrontMetric) Descriptor added in v1.0.0 

func (*WavefrontMetric) Descriptor() ([]byte, []int)

func (*WavefrontMetric) Marshal added in v1.0.0 

func (m *WavefrontMetric) Marshal() (dAtA []byte, err error)

func (*WavefrontMetric) MarshalTo added in v1.0.0 

func (m *WavefrontMetric) MarshalTo(dAtA []byte) (int, error)

func (*WavefrontMetric) MarshalToSizedBuffer added in v1.0.0 

func (m *WavefrontMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WavefrontMetric) ProtoMessage added in v1.0.0 

func (*WavefrontMetric) ProtoMessage()

func (*WavefrontMetric) Reset added in v1.0.0 

func (m *WavefrontMetric) Reset()

func (*WavefrontMetric) Size added in v1.0.0 

func (m *WavefrontMetric) Size() (n int)

func (*WavefrontMetric) String added in v1.0.0 

func (this *WavefrontMetric) String() string

func (*WavefrontMetric) Unmarshal added in v1.0.0 

func (m *WavefrontMetric) Unmarshal(dAtA []byte) error

func (*WavefrontMetric) XXX_DiscardUnknown added in v1.0.0 

func (m *WavefrontMetric) XXX_DiscardUnknown()

func (*WavefrontMetric) XXX_Marshal added in v1.0.0 

func (m *WavefrontMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WavefrontMetric) XXX_Merge added in v1.0.0 

func (m *WavefrontMetric) XXX_Merge(src proto.Message)

func (*WavefrontMetric) XXX_Size added in v1.0.0 

func (m *WavefrontMetric) XXX_Size() int

func (*WavefrontMetric) XXX_Unmarshal added in v1.0.0 

func (m *WavefrontMetric) XXX_Unmarshal(b []byte) error

type WebMetric added in v0.7.0 

type WebMetric struct {
	// URL is the address of the web metric
	URL string `json:"url" protobuf:"bytes,1,opt,name=url"`
	// +patchMergeKey=key
	// +patchStrategy=merge
	// Headers are optional HTTP headers to use in the request
	Headers []WebMetricHeader `json:"headers,omitempty" patchStrategy:"merge" patchMergeKey:"key" protobuf:"bytes,2,rep,name=headers"`
	// TimeoutSeconds is the timeout for the request in seconds (default: 10)
	TimeoutSeconds int64 `json:"timeoutSeconds,omitempty" protobuf:"varint,3,opt,name=timeoutSeconds"`
	// JSONPath is a JSON Path to use as the result variable (default: "{$}")
	JSONPath string `json:"jsonPath,omitempty" protobuf:"bytes,4,opt,name=jsonPath"`
	// Insecure skips host TLS verification
	Insecure bool `json:"insecure,omitempty" protobuf:"varint,5,opt,name=insecure"`
}

func (*WebMetric) DeepCopy added in v0.7.0 

func (in *WebMetric) DeepCopy() *WebMetric

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

func (*WebMetric) DeepCopyInto added in v0.7.0 

func (in *WebMetric) DeepCopyInto(out *WebMetric)

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

func (*WebMetric) Descriptor added in v1.0.0 

func (*WebMetric) Descriptor() ([]byte, []int)

func (*WebMetric) Marshal added in v1.0.0 

func (m *WebMetric) Marshal() (dAtA []byte, err error)

func (*WebMetric) MarshalTo added in v1.0.0 

func (m *WebMetric) MarshalTo(dAtA []byte) (int, error)

func (*WebMetric) MarshalToSizedBuffer added in v1.0.0 

func (m *WebMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WebMetric) ProtoMessage added in v1.0.0 

func (*WebMetric) ProtoMessage()

func (*WebMetric) Reset added in v1.0.0 

func (m *WebMetric) Reset()

func (*WebMetric) Size added in v1.0.0 

func (m *WebMetric) Size() (n int)

func (*WebMetric) String added in v1.0.0 

func (this *WebMetric) String() string

func (*WebMetric) Unmarshal added in v1.0.0 

func (m *WebMetric) Unmarshal(dAtA []byte) error

func (*WebMetric) XXX_DiscardUnknown added in v1.0.0 

func (m *WebMetric) XXX_DiscardUnknown()

func (*WebMetric) XXX_Marshal added in v1.0.0 

func (m *WebMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WebMetric) XXX_Merge added in v1.0.0 

func (m *WebMetric) XXX_Merge(src proto.Message)

func (*WebMetric) XXX_Size added in v1.0.0 

func (m *WebMetric) XXX_Size() int

func (*WebMetric) XXX_Unmarshal added in v1.0.0 

func (m *WebMetric) XXX_Unmarshal(b []byte) error

type WebMetricHeader added in v0.7.0 

type WebMetricHeader struct {
	Key   string `json:"key" protobuf:"bytes,1,opt,name=key"`
	Value string `json:"value" protobuf:"bytes,2,opt,name=value"`
}

func (*WebMetricHeader) DeepCopy added in v0.7.0 

func (in *WebMetricHeader) DeepCopy() *WebMetricHeader

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

func (*WebMetricHeader) DeepCopyInto added in v0.7.0 

func (in *WebMetricHeader) DeepCopyInto(out *WebMetricHeader)

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

func (*WebMetricHeader) Descriptor added in v1.0.0 

func (*WebMetricHeader) Descriptor() ([]byte, []int)

func (*WebMetricHeader) Marshal added in v1.0.0 

func (m *WebMetricHeader) Marshal() (dAtA []byte, err error)

func (*WebMetricHeader) MarshalTo added in v1.0.0 

func (m *WebMetricHeader) MarshalTo(dAtA []byte) (int, error)

func (*WebMetricHeader) MarshalToSizedBuffer added in v1.0.0 

func (m *WebMetricHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WebMetricHeader) ProtoMessage added in v1.0.0 

func (*WebMetricHeader) ProtoMessage()

func (*WebMetricHeader) Reset added in v1.0.0 

func (m *WebMetricHeader) Reset()

func (*WebMetricHeader) Size added in v1.0.0 

func (m *WebMetricHeader) Size() (n int)

func (*WebMetricHeader) String added in v1.0.0 

func (this *WebMetricHeader) String() string

func (*WebMetricHeader) Unmarshal added in v1.0.0 

func (m *WebMetricHeader) Unmarshal(dAtA []byte) error

func (*WebMetricHeader) XXX_DiscardUnknown added in v1.0.0 

func (m *WebMetricHeader) XXX_DiscardUnknown()

func (*WebMetricHeader) XXX_Marshal added in v1.0.0 

func (m *WebMetricHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WebMetricHeader) XXX_Merge added in v1.0.0 

func (m *WebMetricHeader) XXX_Merge(src proto.Message)

func (*WebMetricHeader) XXX_Size added in v1.0.0 

func (m *WebMetricHeader) XXX_Size() int

func (*WebMetricHeader) XXX_Unmarshal added in v1.0.0 

func (m *WebMetricHeader) XXX_Unmarshal(b []byte) error

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.