deployments

Documentation

Index

• type Manager
  • func NewManager(mgr ctrl.Manager) (*Manager, error)
  • func (r *Manager) AtLeastOne(deploymentName string)
  • func (r *Manager) Bootstrap(ctx context.Context) error
  • func (r *Manager) ReadinessChecker(_ *http.Request) error
  • func (r *Manager) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Manager) ResolveDeployment(model string) (string, bool)
  • func (r *Manager) SetDesiredScale(deploymentName string, n int32)
  • func (r *Manager) SetupWithManager(mgr ctrl.Manager) error
• type MetricsCollector
  • func NewMetricsCollector(m *Manager) *MetricsCollector
  • func (p *MetricsCollector) Collect(c chan<- prometheus.Metric)
  • func (p *MetricsCollector) Describe(descs chan<- *prometheus.Desc)
  • func (p *MetricsCollector) MustRegister(r prometheus.Registerer)

Types

type Manager

type Manager struct {
	client.Client

	Namespace string

	ScaleDownPeriod time.Duration
	// contains filtered or unexported fields
}

func NewManager

func NewManager(mgr ctrl.Manager) (*Manager, error)

func (*Manager) AtLeastOne

func (r *Manager) AtLeastOne(deploymentName string)

func (*Manager) Bootstrap

func (r *Manager) Bootstrap(ctx context.Context) error

Bootstrap initializes the Manager by retrieving a list of deployments from the k8s cluster and adding them to the Manager's internal state.

func (*Manager) ReadinessChecker

func (r *Manager) ReadinessChecker(_ *http.Request) error

ReadinessChecker checks if the Manager state is loaded and ready to handle requests. It returns an error if Manager is not bootstrapped yet. To be used with sigs.k8s.io/controller-runtime manager `AddReadyzCheck`

func (*Manager) Reconcile

func (r *Manager) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*Manager) ResolveDeployment

func (r *Manager) ResolveDeployment(model string) (string, bool)

func (*Manager) SetDesiredScale

func (r *Manager) SetDesiredScale(deploymentName string, n int32)

func (*Manager) SetupWithManager

func (r *Manager) SetupWithManager(mgr ctrl.Manager) error

type MetricsCollector

type MetricsCollector struct {
	// contains filtered or unexported fields
}

func NewMetricsCollector

func NewMetricsCollector(m *Manager) *MetricsCollector

NewMetricsCollector constructor

func (*MetricsCollector) Collect

func (p *MetricsCollector) Collect(c chan<- prometheus.Metric)

Collect is called by the Prometheus registry when collecting metrics.

func (*MetricsCollector) Describe

func (p *MetricsCollector) Describe(descs chan<- *prometheus.Desc)

Describe sends the super-set of all possible descriptors of metrics

func (*MetricsCollector) MustRegister

func (p *MetricsCollector) MustRegister(r prometheus.Registerer)

MustRegister registers all metrics