rancher

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

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"`
}

type LoadBalancerController struct {
	LBProvider provider.LBProvider

	CertFetcher CertificateFetcher
	MetaFetcher MetadataFetcher
	// contains filtered or unexported fields
}

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)
	GetSelfHostUUID() (string, error)
	GetContainer(envUUID string, instanceName string) (*metadata.Container, error)
}

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
}

type RMetaFetcher struct {
	MetadataClient metadata.Client
}

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

type SelectorConstraintEq struct {
	Key   string
	Value string
}

type SelectorConstraintIn struct {
	Key   string
	Value []string
}

type SelectorConstraintNEq struct {
	Key   string
	Value string
}

type SelectorConstraintNoop struct {
	Key string
}

type SelectorConstraintNotIn struct {
	Key   string
	Value []string
}