applier

Documentation

Index

• func GetPodCondition(pod *v1.Pod, conditionType v1.PodConditionType) (v1.PodCondition, bool)
• func HasAnyOfReadinessGates(pod *v1.Pod, conditionTypes []v1.PodConditionType) bool
• func NewAlbConfigManagerApplier(store store.Storer, kubeClient client.Client, provider prvd.Provider, ...) *defaultAlbConfigManagerApplier
• func NewAlbLoadBalancerApplier(albProvider prvd.Provider, trackingProvider tracking.TrackingProvider, ...) *albLoadBalancerApplier
• func NewListenerApplier(albProvider prvd.Provider, stack core.Manager, logger logr.Logger) *listenerApplier
• func NewListenerRuleApplier(albProvider prvd.Provider, stack core.Manager, logger logr.Logger) *listenerRuleApplier
• func NewServerApplier(kubeClient client.Client, albProvider prvd.Provider, serverGroupID string, ...) *serverApplier
• func NewServerGroupApplier(kubeClient client.Client, backendManager backend.Manager, ...) *serverGroupApplier
• func NewServiceManagerApplier(kubeClient client.Client, albProvider prvd.Provider, logger logr.Logger) *defaultServiceManagerApplier
• func NewServiceStackApplier(albProvider prvd.Provider, serviceStack *albmodel.ServiceManager, ...) *serviceStackApplier
• type AlbConfigManagerApplier
• type ResourceApply
• type ServiceManagerApplier

Functions

func GetPodCondition

func GetPodCondition(pod *v1.Pod, conditionType v1.PodConditionType) (v1.PodCondition, bool)

GetPodCondition will get Pod's condition.

func HasAnyOfReadinessGates

func HasAnyOfReadinessGates(pod *v1.Pod, conditionTypes []v1.PodConditionType) bool

HasAnyOfReadinessGates returns whether podInfo has any of these readinessGates

func NewAlbConfigManagerApplier

func NewAlbConfigManagerApplier(store store.Storer, kubeClient client.Client, provider prvd.Provider, tagPrefix string, logger logr.Logger) *defaultAlbConfigManagerApplier

func NewAlbLoadBalancerApplier

func NewAlbLoadBalancerApplier(albProvider prvd.Provider, trackingProvider tracking.TrackingProvider, stack core.Manager, logger logr.Logger) *albLoadBalancerApplier

func NewListenerApplier

func NewListenerApplier(albProvider prvd.Provider, stack core.Manager, logger logr.Logger) *listenerApplier

func NewListenerRuleApplier

func NewListenerRuleApplier(albProvider prvd.Provider, stack core.Manager, logger logr.Logger) *listenerRuleApplier

func NewServerApplier

func NewServerApplier(kubeClient client.Client, albProvider prvd.Provider, serverGroupID string, endpoints []albmodel.BackendItem, trafficPolicy string, logger logr.Logger) *serverApplier

func NewServerGroupApplier

func NewServerGroupApplier(kubeClient client.Client, backendManager backend.Manager, albProvider prvd.Provider, trackingProvider tracking.TrackingProvider, stack core.Manager, logger logr.Logger) *serverGroupApplier

func NewServiceManagerApplier

func NewServiceManagerApplier(kubeClient client.Client, albProvider prvd.Provider, logger logr.Logger) *defaultServiceManagerApplier

func NewServiceStackApplier

func NewServiceStackApplier(albProvider prvd.Provider, serviceStack *albmodel.ServiceManager, logger logr.Logger) *serviceStackApplier

Types

type AlbConfigManagerApplier

type AlbConfigManagerApplier interface {
	Apply(ctx context.Context, stack core.Manager) error
}

type ResourceApply

type ResourceApply interface {
	Apply(ctx context.Context) error
	PostApply(ctx context.Context) error
}

type ServiceManagerApplier

type ServiceManagerApplier interface {
	Apply(ctx context.Context, albProvider prvd.Provider, serviceStack *albmodel.ServiceManager) error
}