resourcescaler

Documentation

Index

• func New(logger logger.Logger, namespace string, ...) (scalertypes.ResourceScaler, error)
• type NuclioResourceScaler
  • func (n *NuclioResourceScaler) GetConfig() (*scalertypes.ResourceScalerConfig, error)
  • func (n *NuclioResourceScaler) GetHTTPClient() *http.Client
  • func (n *NuclioResourceScaler) GetResources() ([]scalertypes.Resource, error)
  • func (n *NuclioResourceScaler) ResolveServiceName(resource scalertypes.Resource) (string, error)
  • func (n *NuclioResourceScaler) SetFunctionReadinessVerificationEnabled(enable bool)
  • func (n *NuclioResourceScaler) SetHTTPClient(httpClient *http.Client)
  • func (n *NuclioResourceScaler) SetScale(resources []scalertypes.Resource, scale int) error
  • func (n *NuclioResourceScaler) SetScaleCtx(ctx context.Context, resources []scalertypes.Resource, scale int) error

Functions

func New

func New(logger logger.Logger,
	namespace string,
	nuclioClientSet nuclioioclient.Interface,
	platformConfiguration *platformconfig.Config) (scalertypes.ResourceScaler, error)

Types

type NuclioResourceScaler

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

NuclioResourceScaler leverages github.com/v3io/scaler to allow extending scale to zero and from zero nuclio functions

func (*NuclioResourceScaler) GetConfig

func (n *NuclioResourceScaler) GetConfig() (*scalertypes.ResourceScalerConfig, error)

func (*NuclioResourceScaler) GetHTTPClient

func (n *NuclioResourceScaler) GetHTTPClient() *http.Client

GetHTTPClient returns the http client for testing purposes

func (*NuclioResourceScaler) GetResources

func (n *NuclioResourceScaler) GetResources() ([]scalertypes.Resource, error)

func (*NuclioResourceScaler) ResolveServiceName

func (n *NuclioResourceScaler) ResolveServiceName(resource scalertypes.Resource) (string, error)

func (*NuclioResourceScaler) SetFunctionReadinessVerificationEnabled

func (n *NuclioResourceScaler) SetFunctionReadinessVerificationEnabled(enable bool)

func (*NuclioResourceScaler) SetHTTPClient

func (n *NuclioResourceScaler) SetHTTPClient(httpClient *http.Client)

SetHTTPClient sets the http client for testing purposes

func (*NuclioResourceScaler) SetScale

func (n *NuclioResourceScaler) SetScale(resources []scalertypes.Resource, scale int) error

func (*NuclioResourceScaler) SetScaleCtx

func (n *NuclioResourceScaler) SetScaleCtx(ctx context.Context, resources []scalertypes.Resource, scale int) error