keda

package

v0.49.0 Latest Latest Go to latest Published: May 1, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/knative/func

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewHTTPScaledObjectClientset() (*httpv1alpha1.Clientset, error)
func NewLister(verbose bool) fn.Lister
func UsesKedaDeployer(annotations map[string]string) bool
func WaitForHTTPScaledObjectAvailable(ctx context.Context, clientset *versioned.Clientset, namespace string, ...) error
type Deployer
- func NewDeployer(opts ...DeployerOpt) *Deployer
- func (d *Deployer) Deploy(ctx context.Context, f fn.Function) (fn.DeploymentResult, error)
type DeployerOpt
- func WithDeployerDecorator(decorator deployer.DeployDecorator) DeployerOpt
- func WithDeployerVerbose(verbose bool) DeployerOpt
type Describer
- func NewDescriber(verbose bool, opts ...DescriberOpt) *Describer
- func (d *Describer) Describe(ctx context.Context, name, namespace string) (fn.Instance, error)
type DescriberOpt
- func WithDescriberTransport(transport http.RoundTripper) DescriberOpt
type Lister
- func (l *Lister) List(ctx context.Context, namespace string) ([]fn.ListItem, error)
type Remover
- func NewRemover(verbose bool) *Remover
- func (remover *Remover) Remove(ctx context.Context, name, ns string) error

Constants ¶

View Source

const (
	KedaDeployerName = "keda"
)

Variables ¶

This section is empty.

Functions ¶

func NewHTTPScaledObjectClientset ¶

func NewHTTPScaledObjectClientset() (*httpv1alpha1.Clientset, error)

func NewLister ¶

func NewLister(verbose bool) fn.Lister

func UsesKedaDeployer ¶

func UsesKedaDeployer(annotations map[string]string) bool

func WaitForHTTPScaledObjectAvailable ¶

func WaitForHTTPScaledObjectAvailable(ctx context.Context, clientset *versioned.Clientset, namespace string, name string, timeout time.Duration) error

Types ¶

type Deployer ¶

type Deployer struct {
	k8s.Deployer
	// contains filtered or unexported fields
}

func NewDeployer ¶

func NewDeployer(opts ...DeployerOpt) *Deployer

func (*Deployer) Deploy ¶

func (d *Deployer) Deploy(ctx context.Context, f fn.Function) (fn.DeploymentResult, error)

type DeployerOpt ¶

type DeployerOpt func(*Deployer)

func WithDeployerDecorator ¶

func WithDeployerDecorator(decorator deployer.DeployDecorator) DeployerOpt

func WithDeployerVerbose ¶

func WithDeployerVerbose(verbose bool) DeployerOpt

type Describer ¶

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

func NewDescriber ¶

func NewDescriber(verbose bool, opts ...DescriberOpt) *Describer

func (*Describer) Describe ¶

func (d *Describer) Describe(ctx context.Context, name, namespace string) (fn.Instance, error)

Describe a function by name.

type DescriberOpt ¶

type DescriberOpt func(*Describer)

func WithDescriberTransport ¶

func WithDescriberTransport(transport http.RoundTripper) DescriberOpt

type Lister ¶

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

func (*Lister) List ¶

func (l *Lister) List(ctx context.Context, namespace string) ([]fn.ListItem, error)

type Remover ¶

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

func NewRemover ¶

func NewRemover(verbose bool) *Remover

func (*Remover) Remove ¶

func (remover *Remover) Remove(ctx context.Context, name, ns string) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL