Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIServer ¶ added in v0.5.0
type APIServer struct {
Namespace string `yaml:"namespace,omitempty"`
PodSelector *metav1.LabelSelector `yaml:"podSelector,omitempty"`
ContainerName string `yaml:"containerName,omitempty"`
}
type Config ¶
type Config struct {
GenerateTopologyURL string `yaml:"generateTopologyUrl"`
Trigger Trigger `yaml:"trigger"`
APIServer APIServer `yaml:"apiServer,omitempty"`
Provider topology.Provider `yaml:"provider"`
Engine topology.Engine `yaml:"engine"`
RetryDelay metav1.Duration `yaml:"retryDelay"`
}
func NewConfigFromFile ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(ctx context.Context, client kubernetes.Interface, cfg *Config) (*Controller, error)
func (*Controller) Start ¶
func (c *Controller) Start() error
func (*Controller) Stop ¶
func (c *Controller) Stop(err error)
type StatusInformer ¶ added in v0.3.0
type StatusInformer struct {
// contains filtered or unexported fields
}
StatusInformer watches the configured Kubernetes resources and reconciles their cluster-wide topology through a single rate-limited work queue key. The exported name is retained for compatibility with existing callers.
func NewStatusInformer ¶ added in v0.3.0
func NewStatusInformer(ctx context.Context, client kubernetes.Interface, trigger *Trigger, apiServer *APIServer, brokerName, brokerNamespace string, retryDelay time.Duration, reqFunc httpreq.RequestFunc) (*StatusInformer, error)
func (*StatusInformer) Start ¶ added in v0.3.0
func (s *StatusInformer) Start() error
func (*StatusInformer) Stop ¶ added in v0.3.0
func (s *StatusInformer) Stop(_ error)
Click to show internal directories.
Click to hide internal directories.