activator

Documentation

Index

• Constants
• type Activator
  • func New(istioClient istionetworkingclient.VirtualServiceInterface, ...) Activator
• type Handler
  • func NewHandler(act Activator, logger *zap.SugaredLogger) *Handler
  • func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type PrometheusStatsReporter
  • func NewPrometheusStatsReporter() *PrometheusStatsReporter
  • func (r *PrometheusStatsReporter) AddAPI(apiName string)
  • func (r *PrometheusStatsReporter) RemoveAPI(apiName string)
  • func (r *PrometheusStatsReporter) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type StatsReporter

Constants

const APINameCtxKey ctxValue = "apiName"

Types

type Activator

type Activator interface {
	Try(ctx context.Context, fn func() error) error
}

func New

func New(
	istioClient istionetworkingclient.VirtualServiceInterface,
	deploymentInformer cache.SharedIndexInformer,
	virtualServiceInformer cache.SharedIndexInformer,
	autoscalerClient autoscaler.Client,
	reporter StatsReporter,
	logger *zap.SugaredLogger,
) Activator

type Handler

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

func NewHandler

func NewHandler(act Activator, logger *zap.SugaredLogger) *Handler

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type PrometheusStatsReporter

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

func NewPrometheusStatsReporter

func NewPrometheusStatsReporter() *PrometheusStatsReporter

func (*PrometheusStatsReporter) AddAPI

func (r *PrometheusStatsReporter) AddAPI(apiName string)

func (*PrometheusStatsReporter) RemoveAPI

func (r *PrometheusStatsReporter) RemoveAPI(apiName string)

func (*PrometheusStatsReporter) ServeHTTP

func (r *PrometheusStatsReporter) ServeHTTP(w http.ResponseWriter, req *http.Request)

type StatsReporter

type StatsReporter interface {
	AddAPI(apiName string)
	RemoveAPI(apiName string)
}