Documentation
¶
Index ¶
- Constants
- func IsSelectorMatch(selector string, labels map[string]string) bool
- type CertificateFetcher
- type LBMetadata
- type LoadBalancerController
- func (lbc *LoadBalancerController) BuildConfigFromMetadata(lbName string, envUUID string, lbMeta *LBMetadata) ([]*config.LoadBalancerConfig, error)
- func (lbc *LoadBalancerController) CollectLBMetadata(lbSvc metadata.Service) (*LBMetadata, error)
- func (lbc *LoadBalancerController) GetLBConfigs() ([]*config.LoadBalancerConfig, error)
- func (lbc *LoadBalancerController) GetName() string
- func (lbc *LoadBalancerController) Init()
- func (lbc *LoadBalancerController) IsHealthy() bool
- func (lbc *LoadBalancerController) Run(provider provider.LBProvider)
- func (lbc *LoadBalancerController) ScheduleApplyConfig(string)
- func (lbc *LoadBalancerController) Stop() error
- type MetadataFetcher
- type RCertificateFetcher
- type RMetaFetcher
- func (mf RMetaFetcher) GetSelfService() (metadata.Service, error)
- func (mf RMetaFetcher) GetService(envUUID string, svcName string, stackName string) (*metadata.Service, error)
- func (mf RMetaFetcher) GetServices() ([]metadata.Service, error)
- func (mf RMetaFetcher) OnChange(intervalSeconds int, do func(string))
- type SelectorConstraint
- type SelectorConstraintEq
- type SelectorConstraintIn
- type SelectorConstraintNEq
- type SelectorConstraintNoop
- type SelectorConstraintNotIn
Constants ¶
View Source
const ( NEQ = "!=" EQ = "=" NOTIN = " notin " IN = " in " NOOP = "" )
supported protocols
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CertificateFetcher ¶
type LBMetadata ¶
type LBMetadata struct {
PortRules []metadata.PortRule `json:"port_rules"`
Certs []string `json:"certs"`
DefaultCert string `json:"default_cert"`
Config string `json:"config"`
StickinessPolicy config.StickinessPolicy `json:"stickiness_policy"`
}
func GetLBMetadata ¶ added in v0.5.2
func GetLBMetadata(data interface{}) (*LBMetadata, error)
type LoadBalancerController ¶ added in v0.5.2
type LoadBalancerController struct {
LBProvider provider.LBProvider
CertFetcher CertificateFetcher
MetaFetcher MetadataFetcher
// contains filtered or unexported fields
}
func NewLoadBalancerController ¶ added in v0.5.2
func NewLoadBalancerController() (*LoadBalancerController, error)
func (*LoadBalancerController) BuildConfigFromMetadata ¶ added in v0.5.2
func (lbc *LoadBalancerController) BuildConfigFromMetadata(lbName string, envUUID string, lbMeta *LBMetadata) ([]*config.LoadBalancerConfig, error)
func (*LoadBalancerController) CollectLBMetadata ¶ added in v0.5.2
func (lbc *LoadBalancerController) CollectLBMetadata(lbSvc metadata.Service) (*LBMetadata, error)
func (*LoadBalancerController) GetLBConfigs ¶ added in v0.5.2
func (lbc *LoadBalancerController) GetLBConfigs() ([]*config.LoadBalancerConfig, error)
func (*LoadBalancerController) GetName ¶ added in v0.5.2
func (lbc *LoadBalancerController) GetName() string
func (*LoadBalancerController) Init ¶ added in v0.5.2
func (lbc *LoadBalancerController) Init()
func (*LoadBalancerController) IsHealthy ¶ added in v0.5.2
func (lbc *LoadBalancerController) IsHealthy() bool
func (*LoadBalancerController) Run ¶ added in v0.5.2
func (lbc *LoadBalancerController) Run(provider provider.LBProvider)
func (*LoadBalancerController) ScheduleApplyConfig ¶ added in v0.5.2
func (lbc *LoadBalancerController) ScheduleApplyConfig(string)
func (*LoadBalancerController) Stop ¶ added in v0.5.2
func (lbc *LoadBalancerController) Stop() error
type MetadataFetcher ¶
type RCertificateFetcher ¶ added in v0.5.2
type RCertificateFetcher struct {
Client *client.RancherClient
}
func (*RCertificateFetcher) FetchCertificate ¶ added in v0.5.2
func (fetcher *RCertificateFetcher) FetchCertificate(certName string) (*config.Certificate, error)
func (*RCertificateFetcher) UpdateEndpoints ¶ added in v0.5.2
func (fetcher *RCertificateFetcher) UpdateEndpoints(lbSvc *metadata.Service, eps []client.PublicEndpoint) error
type RMetaFetcher ¶ added in v0.5.2
func (RMetaFetcher) GetSelfService ¶ added in v0.5.2
func (mf RMetaFetcher) GetSelfService() (metadata.Service, error)
func (RMetaFetcher) GetService ¶ added in v0.5.2
func (RMetaFetcher) GetServices ¶ added in v0.5.2
func (mf RMetaFetcher) GetServices() ([]metadata.Service, error)
func (RMetaFetcher) OnChange ¶ added in v0.5.2
func (mf RMetaFetcher) OnChange(intervalSeconds int, do func(string))
type SelectorConstraint ¶
func GetSelectorConstraint ¶
func GetSelectorConstraint(selector string) SelectorConstraint
func GetSelectorConstraints ¶
func GetSelectorConstraints(selector string) []SelectorConstraint
type SelectorConstraintEq ¶
func (SelectorConstraintEq) IsSelectorMatch ¶
func (s SelectorConstraintEq) IsSelectorMatch(labels map[string]string) bool
type SelectorConstraintIn ¶
func (SelectorConstraintIn) IsSelectorMatch ¶
func (s SelectorConstraintIn) IsSelectorMatch(labels map[string]string) bool
type SelectorConstraintNEq ¶
func (SelectorConstraintNEq) IsSelectorMatch ¶
func (s SelectorConstraintNEq) IsSelectorMatch(labels map[string]string) bool
type SelectorConstraintNoop ¶
type SelectorConstraintNoop struct {
Key string
}
func (SelectorConstraintNoop) IsSelectorMatch ¶
func (s SelectorConstraintNoop) IsSelectorMatch(labels map[string]string) bool
type SelectorConstraintNotIn ¶
func (SelectorConstraintNotIn) IsSelectorMatch ¶
func (s SelectorConstraintNotIn) IsSelectorMatch(labels map[string]string) bool
Click to show internal directories.
Click to hide internal directories.