k8sscaling

Documentation

Index

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

Functions

func CreateClientSet

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

func GetCurrentNamespace

func GetCurrentNamespace() (string, error)

func NewK8sScaling

func NewK8sScaling() scaling.RunnerScaling

Types

type DeploymentProvisioner

type DeploymentProvisioner struct {
	Client           *kubernetes.Clientset
	MyDeploymentName string
	Namespace        string
	// Map of known deployments
	KnownDeployments map[string]bool
	FTLEndpoint      string
}

DeploymentProvisioner reconciles a Foo object

func (*DeploymentProvisioner) HandleSchemaChange

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