Documentation ¶
Index ¶
- func GetLBServiceInternal(rancherClient *client.RancherClient, opts *client.ListOpts) ([]client.LoadBalancerService, error)
- type LBProvider
- func (lbp *LBProvider) ApplyConfig(lbConfig *config.LoadBalancerConfig) error
- func (lbp *LBProvider) CleanupConfig(name string) error
- func (lbp *LBProvider) DrainEndpoint(ep *config.Endpoint) bool
- func (lbp *LBProvider) GetExistingConfigNames() (map[string]bool, error)
- func (lbp *LBProvider) GetName() string
- func (lbp *LBProvider) GetPublicEndpoints(configName string) ([]string, error)
- func (lbp *LBProvider) GetServiceLinks(lb *client.LoadBalancerService) ([]client.ServiceConsumeMap, error)
- func (lbp *LBProvider) GetSetting(key string) (string, bool)
- func (lbp *LBProvider) IsEndpointDrained(ep *config.Endpoint) bool
- func (lbp *LBProvider) IsEndpointUpForDrain(ep *config.Endpoint) bool
- func (lbp *LBProvider) IsHealthy() bool
- func (lbp *LBProvider) ProcessCustomConfig(lbConfig *config.LoadBalancerConfig, customConfig string) error
- func (lbp *LBProvider) RemoveEndpointFromDrain(ep *config.Endpoint)
- func (lbp *LBProvider) Run(syncEndpointsQueue *utils.TaskQueue)
- func (lbp *LBProvider) Stop() error
- type PublicEndpoint
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetLBServiceInternal ¶ added in v0.9.10
func GetLBServiceInternal(rancherClient *client.RancherClient, opts *client.ListOpts) ([]client.LoadBalancerService, error)
Types ¶
type LBProvider ¶
type LBProvider struct {
// contains filtered or unexported fields
}
func (*LBProvider) ApplyConfig ¶
func (lbp *LBProvider) ApplyConfig(lbConfig *config.LoadBalancerConfig) error
func (*LBProvider) CleanupConfig ¶
func (lbp *LBProvider) CleanupConfig(name string) error
func (*LBProvider) DrainEndpoint ¶ added in v0.7.11
func (lbp *LBProvider) DrainEndpoint(ep *config.Endpoint) bool
func (*LBProvider) GetExistingConfigNames ¶ added in v0.9.8
func (lbp *LBProvider) GetExistingConfigNames() (map[string]bool, error)
func (*LBProvider) GetName ¶
func (lbp *LBProvider) GetName() string
func (*LBProvider) GetPublicEndpoints ¶
func (lbp *LBProvider) GetPublicEndpoints(configName string) ([]string, error)
func (*LBProvider) GetServiceLinks ¶ added in v0.2.2
func (lbp *LBProvider) GetServiceLinks(lb *client.LoadBalancerService) ([]client.ServiceConsumeMap, error)
func (*LBProvider) GetSetting ¶ added in v0.4.0
func (lbp *LBProvider) GetSetting(key string) (string, bool)
func (*LBProvider) IsEndpointDrained ¶ added in v0.7.11
func (lbp *LBProvider) IsEndpointDrained(ep *config.Endpoint) bool
func (*LBProvider) IsEndpointUpForDrain ¶ added in v0.7.11
func (lbp *LBProvider) IsEndpointUpForDrain(ep *config.Endpoint) bool
func (*LBProvider) IsHealthy ¶
func (lbp *LBProvider) IsHealthy() bool
func (*LBProvider) ProcessCustomConfig ¶ added in v0.4.0
func (lbp *LBProvider) ProcessCustomConfig(lbConfig *config.LoadBalancerConfig, customConfig string) error
func (*LBProvider) RemoveEndpointFromDrain ¶ added in v0.7.11
func (lbp *LBProvider) RemoveEndpointFromDrain(ep *config.Endpoint)
func (*LBProvider) Run ¶
func (lbp *LBProvider) Run(syncEndpointsQueue *utils.TaskQueue)
func (*LBProvider) Stop ¶
func (lbp *LBProvider) Stop() error
type PublicEndpoint ¶
Click to show internal directories.
Click to hide internal directories.