rancher

package
v0.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 5, 2017 License: Apache-2.0 Imports: 17 Imported by: 2

Documentation

Index

Constants

View Source
const (
	NEQ   = "!="
	EQ    = "="
	NOTIN = " notin "
	IN    = " in "
	NOOP  = ""
)

supported protocols

Variables

This section is empty.

Functions

func IsSelectorMatch

func IsSelectorMatch(selector string, labels map[string]string) bool

Types

type CertificateFetcher

type CertificateFetcher interface {
	FetchCertificate(certName string) (*config.Certificate, error)
	UpdateEndpoints(lbSvc *metadata.Service, eps []client.PublicEndpoint) error
}

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 MetadataFetcher interface {
	GetSelfService() (metadata.Service, error)
	GetService(envUUID string, svcName string, stackName string) (*metadata.Service, error)
	OnChange(intervalSeconds int, do func(string))
	GetServices() ([]metadata.Service, error)
}

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

type RMetaFetcher struct {
	MetadataClient metadata.Client
}

func (RMetaFetcher) GetSelfService added in v0.5.2

func (mf RMetaFetcher) GetSelfService() (metadata.Service, error)

func (RMetaFetcher) GetService added in v0.5.2

func (mf RMetaFetcher) GetService(envUUID string, svcName string, stackName string) (*metadata.Service, error)

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

type SelectorConstraint interface {
	IsSelectorMatch(labels map[string]string) bool
}

func GetSelectorConstraint

func GetSelectorConstraint(selector string) SelectorConstraint

func GetSelectorConstraints

func GetSelectorConstraints(selector string) []SelectorConstraint

type SelectorConstraintEq

type SelectorConstraintEq struct {
	Key   string
	Value string
}

func (SelectorConstraintEq) IsSelectorMatch

func (s SelectorConstraintEq) IsSelectorMatch(labels map[string]string) bool

type SelectorConstraintIn

type SelectorConstraintIn struct {
	Key   string
	Value []string
}

func (SelectorConstraintIn) IsSelectorMatch

func (s SelectorConstraintIn) IsSelectorMatch(labels map[string]string) bool

type SelectorConstraintNEq

type SelectorConstraintNEq struct {
	Key   string
	Value string
}

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

type SelectorConstraintNotIn struct {
	Key   string
	Value []string
}

func (SelectorConstraintNotIn) IsSelectorMatch

func (s SelectorConstraintNotIn) IsSelectorMatch(labels map[string]string) bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL