-
Notifications
You must be signed in to change notification settings - Fork 326
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
crds: Add support for ServiceSplitter
- Loading branch information
Showing
27 changed files
with
1,148 additions
and
37 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,191 @@ | ||
| package v1alpha1 | ||
|
|
||
| import ( | ||
| "reflect" | ||
|
|
||
| "github.com/hashicorp/consul-k8s/api/common" | ||
| capi "github.com/hashicorp/consul/api" | ||
| corev1 "k8s.io/api/core/v1" | ||
| apierrors "k8s.io/apimachinery/pkg/api/errors" | ||
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| "k8s.io/apimachinery/pkg/runtime/schema" | ||
| "k8s.io/apimachinery/pkg/util/validation/field" | ||
| ) | ||
|
|
||
| // +kubebuilder:object:root=true | ||
| // +kubebuilder:subresource:status | ||
|
|
||
| // ServiceSplitter is the Schema for the servicesplitters API | ||
| type ServiceSplitter struct { | ||
| metav1.TypeMeta `json:",inline"` | ||
| metav1.ObjectMeta `json:"metadata,omitempty"` | ||
|
|
||
| Spec ServiceSplitterSpec `json:"spec,omitempty"` | ||
| Status `json:"status,omitempty"` | ||
| } | ||
|
|
||
| type ServiceSplits []ServiceSplit | ||
|
|
||
| // ServiceSplitterSpec defines the desired state of ServiceSplitter | ||
| type ServiceSplitterSpec struct { | ||
| // Splits defines how much traffic to send to which set of service instances during a traffic split. | ||
| // The sum of weights across all splits must add up to 100. | ||
| Splits ServiceSplits `json:"splits,omitempty"` | ||
| } | ||
|
|
||
| type ServiceSplit struct { | ||
| // Weight is a value between 0 and 100 reflecting what portion of traffic should be directed to this split. | ||
| // The smallest representable weight is 1/10000 or .01%. | ||
| Weight float32 `json:"weight,omitempty"` | ||
| // Service is the service to resolve instead of the default. | ||
| Service string `json:"service,omitempty"` | ||
| // ServiceSubset is a named subset of the given service to resolve instead of one defined | ||
| // as that service's DefaultSubset. If empty the default subset is used. | ||
| ServiceSubset string `json:"serviceSubset,omitempty"` | ||
| // The namespace to resolve the service from instead of the current namespace. | ||
| // If empty the current namespace is assumed. | ||
| Namespace string `json:"namespace,omitempty"` | ||
| } | ||
|
|
||
| // +kubebuilder:object:root=true | ||
|
|
||
| // ServiceSplitterList contains a list of ServiceSplitter | ||
| type ServiceSplitterList struct { | ||
| metav1.TypeMeta `json:",inline"` | ||
| metav1.ListMeta `json:"metadata,omitempty"` | ||
| Items []ServiceSplitter `json:"items"` | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) GetObjectMeta() metav1.ObjectMeta { | ||
| return in.ObjectMeta | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) AddFinalizer(name string) { | ||
| in.ObjectMeta.Finalizers = append(in.Finalizers(), name) | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) RemoveFinalizer(name string) { | ||
| var newFinalizers []string | ||
| for _, oldF := range in.Finalizers() { | ||
| if oldF != name { | ||
| newFinalizers = append(newFinalizers, oldF) | ||
| } | ||
| } | ||
| in.ObjectMeta.Finalizers = newFinalizers | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) Finalizers() []string { | ||
| return in.ObjectMeta.Finalizers | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) ConsulKind() string { | ||
| return capi.ServiceSplitter | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) ConsulNamespaced() bool { | ||
| return true | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) KubeKind() string { | ||
| return common.ServiceSplitter | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) Name() string { | ||
| return in.ObjectMeta.Name | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) SetSyncedCondition(status corev1.ConditionStatus, reason, message string) { | ||
| in.Status.Conditions = Conditions{ | ||
| { | ||
| Type: ConditionSynced, | ||
| Status: status, | ||
| LastTransitionTime: metav1.Now(), | ||
| Reason: reason, | ||
| Message: message, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) SyncedCondition() (status corev1.ConditionStatus, reason, message string) { | ||
| cond := in.Status.GetCondition(ConditionSynced) | ||
| if cond == nil { | ||
| return corev1.ConditionUnknown, "", "" | ||
| } | ||
| return cond.Status, cond.Reason, cond.Message | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) SyncedConditionStatus() corev1.ConditionStatus { | ||
| condition := in.Status.GetCondition(ConditionSynced) | ||
| if condition == nil { | ||
| return corev1.ConditionUnknown | ||
| } | ||
| return condition.Status | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) ToConsul() capi.ConfigEntry { | ||
| return &capi.ServiceSplitterConfigEntry{ | ||
| Kind: in.ConsulKind(), | ||
| Name: in.Name(), | ||
| Splits: in.Spec.Splits.toConsul(), | ||
| } | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) MatchesConsul(candidate capi.ConfigEntry) bool { | ||
| serviceSplitterCandidate, ok := candidate.(*capi.ServiceSplitterConfigEntry) | ||
| if !ok { | ||
| return false | ||
| } | ||
| serviceSplitterCandidate.Namespace = "" | ||
| serviceSplitterCandidate.CreateIndex = 0 | ||
| serviceSplitterCandidate.ModifyIndex = 0 | ||
|
|
||
| return reflect.DeepEqual(in.ToConsul(), candidate) | ||
| } | ||
|
|
||
| func (in *ServiceSplitter) Validate() error { | ||
| var errs field.ErrorList | ||
| path := field.NewPath("spec").Child("splits") | ||
|
|
||
| // The sum of weights across all splits must add up to 100. | ||
| sumOfWeights := float32(0) | ||
| for i, split := range in.Spec.Splits { | ||
| // Validate that the weight value is between 0.01 and 100. | ||
| if split.Weight > 100 || split.Weight < 0.01 { | ||
| errs = append(errs, field.Invalid(path.Index(i).Child("weight"), split.Weight, | ||
| "weight must be between 0.01% and 100%")) | ||
| } | ||
|
|
||
| // If valid, add to sumOfWeights. | ||
| sumOfWeights += split.Weight | ||
| } | ||
|
|
||
| if sumOfWeights != 100 { | ||
| errs = append(errs, field.Invalid(path, sumOfWeights, | ||
| "the sum of weights across all splits must add up to 100%")) | ||
| } | ||
|
|
||
| if len(errs) > 0 { | ||
| return apierrors.NewInvalid( | ||
| schema.GroupKind{Group: ConsulHashicorpGroup, Kind: in.KubeKind()}, | ||
| in.Name(), errs) | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func (in ServiceSplits) toConsul() []capi.ServiceSplit { | ||
| var consulServiceSplits []capi.ServiceSplit | ||
| for _, split := range in { | ||
| consulServiceSplits = append(consulServiceSplits, capi.ServiceSplit{ | ||
| Weight: split.Weight, | ||
| Service: split.Service, | ||
| ServiceSubset: split.ServiceSubset, | ||
| Namespace: split.Namespace, | ||
| }) | ||
| } | ||
|
|
||
| return consulServiceSplits | ||
| } | ||
|
|
||
| func init() { | ||
| SchemeBuilder.Register(&ServiceSplitter{}, &ServiceSplitterList{}) | ||
| } |
Oops, something went wrong.