proxy

Documentation

Index

• Constants
• func ConstructCascadingDeployment(proxy *v1alpha1.ShardingSphereProxy) *v1.Deployment
• func ConstructCascadingService(proxy *v1alpha1.ShardingSphereProxy) *v1.Service
• func ConstructDefaultHPAMetric(target *int32) []autoscalingv2beta2.MetricSpec
• func ConstructHPA(proxy *v1alpha1.ShardingSphereProxy) *autoscalingv2beta2.HorizontalPodAutoscaler
• func CountingReadyPods(podList *v1.PodList) int32
• func IsRunning(podList *v1.PodList) bool
• func NewDeployment(ssproxy *v1alpha1.ShardingSphereProxy) *v1.Deployment
• func NewHPA(ssproxy *v1alpha1.ShardingSphereProxy) *autoscalingv2beta2.HorizontalPodAutoscaler
• func NewService(ssproxy *v1alpha1.ShardingSphereProxy) *v1.Service
• func ReconcileStatus(podlist *corev1.PodList, rt *v1alpha1.ShardingSphereProxy) v1alpha1.ProxyStatus
• func UpdateDeployment(proxy *v1alpha1.ShardingSphereProxy, act *v1.Deployment) *v1.Deployment
• func UpdateHPA(proxy *v1alpha1.ShardingSphereProxy, ...) *autoscalingv2beta2.HorizontalPodAutoscaler
• func UpdateService(proxy *v1alpha1.ShardingSphereProxy, runtimeService *v1.Service) *v1.Service

Constants

const (
	// AnnoRollingUpdateMaxSurge refers to Deployment RollingUpdate Strategy
	AnnoRollingUpdateMaxSurge = "shardingsphereproxy.shardingsphere.org/rolling-update-max-surge"
	// AnnoRollingUpdateMaxUnavailable refers to Deployment RollingUpdate Strategy
	AnnoRollingUpdateMaxUnavailable = "shardingsphereproxy.shardingsphere.org/rolling-update-max-unavailable"
)

Functions

func ConstructCascadingDeployment

func ConstructCascadingDeployment(proxy *v1alpha1.ShardingSphereProxy) *v1.Deployment

ConstructCascadingDeployment construct a Deployment from crd ShardingSphereProxy

func ConstructCascadingService

func ConstructCascadingService(proxy *v1alpha1.ShardingSphereProxy) *v1.Service

ConstructCascadingService contructs a Service from ShardingSphereProxy

func ConstructDefaultHPAMetric

func ConstructDefaultHPAMetric(target *int32) []autoscalingv2beta2.MetricSpec

ConstructDefaultHPAMetric using CPU as default HPA metrics

func ConstructHPA

func ConstructHPA(proxy *v1alpha1.ShardingSphereProxy) *autoscalingv2beta2.HorizontalPodAutoscaler

ConstructHPA Create HPA if you need

func CountingReadyPods

func CountingReadyPods(podList *v1.PodList) int32

CountingReadyPods returns the current count of ready pods

func IsRunning

func IsRunning(podList *v1.PodList) bool

IsRunning returns true if one of the Pods is running

func NewDeployment

func NewDeployment(ssproxy *v1alpha1.ShardingSphereProxy) *v1.Deployment

NewDeployment creates a new Deployment

func NewHPA

func NewHPA(ssproxy *v1alpha1.ShardingSphereProxy) *autoscalingv2beta2.HorizontalPodAutoscaler

NewHPA returns a new HorizontalPodAutoscaler

func NewService

func NewService(ssproxy *v1alpha1.ShardingSphereProxy) *v1.Service

NewService returns a new Service

func ReconcileStatus

func ReconcileStatus(podlist *corev1.PodList, rt *v1alpha1.ShardingSphereProxy) v1alpha1.ProxyStatus

ReconcileStatus returns the status of ShardingSphereProxy

func UpdateDeployment

func UpdateDeployment(proxy *v1alpha1.ShardingSphereProxy, act *v1.Deployment) *v1.Deployment

UpdateDeployment FIXME:merge UpdateDeployment and ConstructCascadingDeployment

func UpdateHPA

func UpdateHPA(proxy *v1alpha1.ShardingSphereProxy, act *autoscalingv2beta2.HorizontalPodAutoscaler) *autoscalingv2beta2.HorizontalPodAutoscaler

UpdateHPA update HorizontalPodAutoscaler with ShardingSphereProxy

func UpdateService

func UpdateService(proxy *v1alpha1.ShardingSphereProxy, runtimeService *v1.Service) *v1.Service

UpdateService updates the specified service with ShardingSphereProxy