servicescale

Documentation

Index

• func Register(ctx context.Context, rContext *types.Context, lock *sync.RWMutex, ...) error
• type SSRHandler
  • func NewHandler(ctx context.Context, services riov1controller.ServiceController, ...) *SSRHandler
  • func (s *SSRHandler) OnChange(key string, svc *riov1.Service) (*riov1.Service, error)
• type SimpleScale
  • func NewSimpleScale(svc *riov1.Service, podCache corev1controller.PodCache, ...) SimpleScale
  • func (s *SimpleScale) ReportMetric()
  • func (s *SimpleScale) Scale() error
  • func (s *SimpleScale) Start()
  • func (s *SimpleScale) Stop()

Functions

func Register

func Register(ctx context.Context, rContext *types.Context, lock *sync.RWMutex, autoscalers map[string]*SimpleScale) error

Types

type SSRHandler

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

func NewHandler

func NewHandler(ctx context.Context,
	services riov1controller.ServiceController,
	podClientCache corev1controller.PodCache,
	autoscalers map[string]*SimpleScale,
	lock *sync.RWMutex) *SSRHandler

func (*SSRHandler) OnChange

func (s *SSRHandler) OnChange(key string, svc *riov1.Service) (*riov1.Service, error)

type SimpleScale

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

func NewSimpleScale

func NewSimpleScale(svc *riov1.Service, podCache corev1controller.PodCache, services riov1controller.ServiceController) SimpleScale

func (*SimpleScale) ReportMetric

func (s *SimpleScale) ReportMetric()

func (*SimpleScale) Scale

func (s *SimpleScale) Scale() error

func (*SimpleScale) Start

func (s *SimpleScale) Start()

func (*SimpleScale) Stop

func (s *SimpleScale) Stop()