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 modules to known deployments
	// This needs to be re-done when we have proper rolling deployments
	KnownModules map[string]string
	FTLEndpoint  string
}

DeploymentProvisioner reconciles a Foo object

func (*DeploymentProvisioner) HandleSchemaChange

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