k8sscaling

Documentation

Index

• func CreateClientSet() (*kubernetes.Clientset, error)
• func CreateIstioClientSet() (*istioclient.Clientset, error)
• func GetCurrentNamespace() (string, error)
• func NewK8sScaling(disableIstio bool) scaling.RunnerScaling
• type DeploymentProvisioner
  • func (r *DeploymentProvisioner) HandleSchemaChange(ctx context.Context, msg *ftlv1.PullSchemaResponse) error

Functions

func CreateClientSet

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

func CreateIstioClientSet

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

func GetCurrentNamespace

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