rancher

package
v0.9.14 Latest Latest
Warning

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

 Go to latest Published: May 1, 2020 License: Apache-2.0 Imports: 23 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	DefaultCertName = "fullchain.pem"
	DefaultKeyName  = "privkey.pem"
)
View Source 
const (
	NEQ   = "!="
	EQ    = "="
	NOTIN = " notin "
	IN    = " in "
	NOOP  = ""
)

supported protocols

Variables

This section is empty.

Functions

func IsActiveService added in v0.5.3 

func IsActiveService(svc *metadata.Service) bool

func IsSelectorMatch 

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

Types

type CertificateFetcher 

type CertificateFetcher interface {
	FetchCertificates(lbMeta *LBMetadata, isDefaultCert bool) ([]*config.Certificate, error)
	UpdateEndpoints(lbSvc *metadata.Service, eps []client.PublicEndpoint) error
	LookForCertUpdates(do func(string))
}

type EventsHandler added in v0.7.11 

type EventsHandler interface {
	Subscribe() 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
	EventsHandler EventsHandler
	// 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, envUUID, selfHostUUID, localServicePreference 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) DrainEndpoint added in v0.7.11 

func (lbc *LoadBalancerController) DrainEndpoint(ep *config.Endpoint) bool

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) GetRegionServices added in v0.7.19 

func (lbc *LoadBalancerController) GetRegionServices(localsvcs *[]metadata.Service, regionName string, envName string) ([]metadata.Service, error)

func (*LoadBalancerController) Init added in v0.5.2 

func (lbc *LoadBalancerController) Init(metadataURL string)

func (*LoadBalancerController) IsEndpointDrained added in v0.7.11 

func (lbc *LoadBalancerController) IsEndpointDrained(ep *config.Endpoint) bool

func (*LoadBalancerController) IsEndpointUpForDrain added in v0.7.11 

func (lbc *LoadBalancerController) IsEndpointUpForDrain(ep *config.Endpoint) bool

func (*LoadBalancerController) IsHealthy added in v0.5.2 

func (lbc *LoadBalancerController) IsHealthy() bool

func (*LoadBalancerController) RemoveEndpointFromDrain added in v0.7.11 

func (lbc *LoadBalancerController) RemoveEndpointFromDrain(ep *config.Endpoint)

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(link string) (*metadata.Service, error)
	OnChange(intervalSeconds int, do func(string))
	GetServices() ([]metadata.Service, error)
	GetSelfHostUUID() (string, error)
	GetContainer(envUUID string, instanceName string) (*metadata.Container, error)
	GetRegionName() (string, error)
	GetServiceFromRegionEnvironment(regionName string, envName string, stackName string, svcName string) (metadata.Service, error)
	GetServiceInLocalRegion(envName string, stackName string, svcName string) (metadata.Service, error)
	GetServiceInLocalEnvironment(stackName string, svcName string) (metadata.Service, error)
	GetServicesFromRegionEnvironment(regionName string, envName string) ([]metadata.Service, error)
	GetServicesInLocalRegion(envName string) ([]metadata.Service, error)
}

type RCertificateFetcher added in v0.5.2 

type RCertificateFetcher struct {
	Client *client.RancherClient

	CertDir        string
	DefaultCertDir string

	CertsCache  map[string]*config.Certificate //cert name (sub dir name) -> cert
	DefaultCert *config.Certificate

	CertName string
	KeyName  string
	// contains filtered or unexported fields
}

func (*RCertificateFetcher) FetchCertificates added in v0.7.0 

func (fetcher *RCertificateFetcher) FetchCertificates(lbMeta *LBMetadata, isDefaultCert bool) ([]*config.Certificate, error)

func (*RCertificateFetcher) FetchRancherCertificate added in v0.7.0 

func (fetcher *RCertificateFetcher) FetchRancherCertificate(certName string) (*config.Certificate, error)

func (*RCertificateFetcher) LookForCertUpdates added in v0.7.0 

func (fetcher *RCertificateFetcher) LookForCertUpdates(doOnUpdate func(string))

func (*RCertificateFetcher) ReadAllCertificatesFromDir added in v0.7.0 

func (fetcher *RCertificateFetcher) ReadAllCertificatesFromDir(certDir string) []*config.Certificate

func (*RCertificateFetcher) ReadDefaultCertificate added in v0.7.0 

func (fetcher *RCertificateFetcher) ReadDefaultCertificate(defaultCertDir string) *config.Certificate

func (*RCertificateFetcher) UpdateEndpoints added in v0.5.2 

func (fetcher *RCertificateFetcher) UpdateEndpoints(lbSvc *metadata.Service, eps []client.PublicEndpoint) error

type REventsHandler added in v0.7.11 

type REventsHandler struct {
	CattleURL       string
	CattleAccessKey string
	CattleSecretKey string
	DoOnEvent       func(*config.Endpoint) bool
	CheckOnEvent    func(*config.Endpoint) bool
	DoOnTimeout     func(*config.Endpoint)
	PollStatus      func(*config.Endpoint) bool
	EventMap        map[string]*revents.Event
	EventMu         *sync.RWMutex
}

func (*REventsHandler) CreateAndPublishReply added in v0.7.11 

func (ehandler *REventsHandler) CreateAndPublishReply(event *revents.Event, cli *client.RancherClient) error

func (*REventsHandler) ErrorReply added in v0.7.11 

func (ehandler *REventsHandler) ErrorReply(event *revents.Event, cli *client.RancherClient, eventError error) error

func (*REventsHandler) HandleDrainEvent added in v0.7.11 

func (ehandler *REventsHandler) HandleDrainEvent(event *revents.Event, cli *client.RancherClient) (bool, error)

func (*REventsHandler) NewReply added in v0.7.11 

func (ehandler *REventsHandler) NewReply(event *revents.Event) *client.Publish

func (*REventsHandler) PublishReply added in v0.7.11 

func (ehandler *REventsHandler) PublishReply(reply *client.Publish, apiClient *client.RancherClient) error

func (*REventsHandler) Subscribe added in v0.7.11 

func (ehandler *REventsHandler) Subscribe() error

type RMetaFetcher added in v0.5.2 

type RMetaFetcher struct {
	MetadataClient metadata.Client
}

func (RMetaFetcher) GetContainer added in v0.6.3 

func (mf RMetaFetcher) GetContainer(envUUID string, containerName string) (*metadata.Container, error)

func (RMetaFetcher) GetRegionName added in v0.7.19 

func (mf RMetaFetcher) GetRegionName() (string, error)

func (RMetaFetcher) GetSelfHostUUID added in v0.5.5 

func (mf RMetaFetcher) GetSelfHostUUID() (string, error)

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(link string) (*metadata.Service, error)

func (RMetaFetcher) GetServiceFromRegionEnvironment added in v0.7.19 

func (mf RMetaFetcher) GetServiceFromRegionEnvironment(regionName string, envName string, stackName string, svcName string) (metadata.Service, error)

func (RMetaFetcher) GetServiceInLocalEnvironment added in v0.7.19 

func (mf RMetaFetcher) GetServiceInLocalEnvironment(stackName string, svcName string) (metadata.Service, error)

func (RMetaFetcher) GetServiceInLocalRegion added in v0.7.19 

func (mf RMetaFetcher) GetServiceInLocalRegion(envName string, stackName string, svcName string) (metadata.Service, error)

func (RMetaFetcher) GetServices added in v0.5.2 

func (mf RMetaFetcher) GetServices() ([]metadata.Service, error)

func (RMetaFetcher) GetServicesFromRegionEnvironment added in v0.7.19 

func (mf RMetaFetcher) GetServicesFromRegionEnvironment(regionName string, envName string) ([]metadata.Service, error)

func (RMetaFetcher) GetServicesInLocalRegion added in v0.7.19 

func (mf RMetaFetcher) GetServicesInLocalRegion(envName string) ([]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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.