k8sscaling

package
v0.391.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateClientSet added in v0.364.1

func CreateClientSet() (*kubernetes.Clientset, error)

func CreateIstioClientSet added in v0.375.0

func CreateIstioClientSet() (*istioclient.Clientset, error)

func GetCurrentNamespace added in v0.364.1

func GetCurrentNamespace() (string, error)

func NewK8sScaling

func NewK8sScaling(disableIstio bool) scaling.RunnerScaling

Types

type DeploymentProvisioner

type DeploymentProvisioner struct {
	Client           *kubernetes.Clientset
	MyDeploymentName string
	Namespace        string
	// Map of known deployments
	KnownDeployments *xsync.Map
	FTLEndpoint      string
	IstioSecurity    optional.Option[istioclient.Clientset]
}

DeploymentProvisioner reconciles a Foo object

func (*DeploymentProvisioner) HandleSchemaChange

func (r *DeploymentProvisioner) HandleSchemaChange(ctx context.Context, msg *ftlv1.PullSchemaResponse) error

Jump to

Keyboard shortcuts

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