k8sscaling

Documentation

Index

• func NewK8sScaling(ctx context.Context, controller url.URL, leaser leases.Leaser) error
• type DeploymentProvisioner
  • func (r *DeploymentProvisioner) HandleSchemaChange(ctx context.Context, msg *ftlv1.PullSchemaResponse) error

Functions

func NewK8sScaling

func NewK8sScaling(ctx context.Context, controller url.URL, leaser leases.Leaser) error

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