provisioner

package
v0.383.1 Latest Latest
Warning

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

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

README

FTL Provisioner

FTL Provisioner will be responsible for creating any infrastructure required by deployments, as well as orchestrating deployments, and keeping track of the state of the underlying infrastructure.

This is still a WIP and should not be used yet.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Start 

func Start(ctx context.Context, config Config, registry *ProvisionerRegistry, controllerClient ftlv1connect.ControllerServiceClient) error

Start the Provisioner. Blocks until the context is cancelled.

Types

type CommonProvisionerConfig added in v0.376.0 

type CommonProvisionerConfig struct {
	PluginConfigFile *os.File `name:"provisioner-plugin-config" help:"Path to the plugin configuration file." env:"FTL_PROVISIONER_PLUGIN_CONFIG_FILE"`
}

CommonProvisionerConfig is shared config between the production controller and development server.

type Config 

type Config struct {
	Bind               *url.URL `help:"Socket to bind to." default:"http://127.0.0.1:8893" env:"FTL_PROVISIONER_BIND"`
	ControllerEndpoint *url.URL `name:"ftl-endpoint" help:"Controller endpoint." env:"FTL_ENDPOINT" default:"http://127.0.0.1:8892"`
	CommonProvisionerConfig
}

func (*Config) SetDefaults 

func (c *Config) SetDefaults()

type Deployment added in v0.377.0 

type Deployment struct {
	Module string
	Tasks  []*Task
}

Deployment is a single deployment of resources for a single module

func (*Deployment) Progress added in v0.377.0 

func (d *Deployment) Progress(ctx context.Context) (bool, error)

Progress the deployment. Returns true if there are still tasks running or pending.

func (*Deployment) State added in v0.377.0 

func (d *Deployment) State() *DeploymentState

type DeploymentState added in v0.377.0 

type DeploymentState struct {
	Pending []*Task
	Running *Task
	Failed  *Task
	Done    []*Task
}

type InMemProvisioner added in v0.377.0 

type InMemProvisioner struct {
	// contains filtered or unexported fields
}

InMemProvisioner for running an in memory provisioner, constructing all resources concurrently

It spawns a separate goroutine for each resource to be provisioned, and finishes the task when all resources are provisioned or an error occurs.

func NewControllerProvisioner added in v0.377.0 

func NewControllerProvisioner(client ftlv1connect.ControllerServiceClient) *InMemProvisioner

NewControllerProvisioner creates a new provisioner that uses the FTL controller to provision modules

func NewDevProvisioner added in v0.377.0 

func NewDevProvisioner(postgresPort int) *InMemProvisioner

NewDevProvisioner creates a new provisioner that provisions resources locally when running FTL in dev mode

func NewEmbeddedProvisioner added in v0.377.0 

func NewEmbeddedProvisioner(handlers map[ResourceType]InMemResourceProvisionerFn) *InMemProvisioner

func (*InMemProvisioner) Ping added in v0.377.0 

func (d *InMemProvisioner) Ping(context.Context, *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*InMemProvisioner) Plan added in v0.377.0 

func (d *InMemProvisioner) Plan(context.Context, *connect.Request[provisioner.PlanRequest]) (*connect.Response[provisioner.PlanResponse], error)

func (*InMemProvisioner) Provision added in v0.377.0 

func (d *InMemProvisioner) Provision(ctx context.Context, req *connect.Request[provisioner.ProvisionRequest]) (*connect.Response[provisioner.ProvisionResponse], error)

func (*InMemProvisioner) Status added in v0.377.0 

func (d *InMemProvisioner) Status(ctx context.Context, req *connect.Request[provisioner.StatusRequest]) (*connect.Response[provisioner.StatusResponse], error)

type InMemResourceProvisionerFn added in v0.377.0 

type InMemResourceProvisionerFn func(context.Context, *provisioner.ResourceContext, string, string) (*provisioner.Resource, error)

InMemResourceProvisionerFn is a function that provisions a resource

type NoopProvisioner added in v0.377.0 

type NoopProvisioner struct{}

NoopProvisioner is a provisioner that does nothing

func (*NoopProvisioner) Ping added in v0.377.0 

func (d *NoopProvisioner) Ping(context.Context, *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*NoopProvisioner) Plan added in v0.377.0 

func (d *NoopProvisioner) Plan(context.Context, *connect.Request[provisioner.PlanRequest]) (*connect.Response[provisioner.PlanResponse], error)

func (*NoopProvisioner) Provision added in v0.377.0 

func (d *NoopProvisioner) Provision(context.Context, *connect.Request[provisioner.ProvisionRequest]) (*connect.Response[provisioner.ProvisionResponse], error)

func (*NoopProvisioner) Status added in v0.377.0 

func (d *NoopProvisioner) Status(context.Context, *connect.Request[provisioner.StatusRequest]) (*connect.Response[provisioner.StatusResponse], error)

type ProvisionerBinding added in v0.377.0 

type ProvisionerBinding struct {
	Provisioner provisionerconnect.ProvisionerPluginServiceClient
	Types       []ResourceType
}

ProvisionerBinding is a Provisioner and the types it supports

type ProvisionerRegistry added in v0.377.0 

type ProvisionerRegistry struct {
	Default      provisionerconnect.ProvisionerPluginServiceClient
	Provisioners []*ProvisionerBinding
}

ProvisionerRegistry contains all known resource handlers in the order they should be executed

func RegistryFromConfigFile added in v0.377.0 

func RegistryFromConfigFile(ctx context.Context, file *os.File, controller ftlv1connect.ControllerServiceClient) (*ProvisionerRegistry, error)

func (*ProvisionerRegistry) CreateDeployment added in v0.377.0 

func (reg *ProvisionerRegistry) CreateDeployment(module string, desiredResources, existingResources *ResourceGraph) *Deployment

CreateDeployment to take the system to the desired state

func (*ProvisionerRegistry) Register added in v0.377.0 

func (reg *ProvisionerRegistry) Register(handler provisionerconnect.ProvisionerPluginServiceClient, types ...ResourceType)

Register to the registry, to be executed after all the previously added handlers

type ResourceEdge added in v0.377.0 

type ResourceEdge struct {
	// contains filtered or unexported fields
}

type ResourceGraph added in v0.377.0 

type ResourceGraph struct {
	// contains filtered or unexported fields
}

ResourceGraph is an in-memory graph of resources and their dependencies

func ExtractResources added in v0.377.0 

func ExtractResources(msg *ftlv1.CreateDeploymentRequest) (*ResourceGraph, error)

ExtractResources from a module schema

func (*ResourceGraph) AddEdge added in v0.377.0 

func (g *ResourceGraph) AddEdge(from, to *provisioner.Resource) *ResourceEdge

AddEdge between two nodes to the graph

func (*ResourceGraph) AddNode added in v0.377.0 

func (g *ResourceGraph) AddNode(n *provisioner.Resource) *provisioner.Resource

AddNode to the graph

func (*ResourceGraph) Dependencies added in v0.377.0 

func (g *ResourceGraph) Dependencies(n *provisioner.Resource) []*provisioner.Resource

Dependencies returns all downstream dependencies of a node

func (*ResourceGraph) In added in v0.377.0 

func (g *ResourceGraph) In(from *provisioner.Resource) []*ResourceEdge

In edges of a node

func (*ResourceGraph) Out added in v0.377.0 

func (g *ResourceGraph) Out(to *provisioner.Resource) []*ResourceEdge

Out edges of a node

func (*ResourceGraph) Resources added in v0.377.0 

func (g *ResourceGraph) Resources() []*provisioner.Resource

Resources returns all nodes in the graph

func (*ResourceGraph) Roots added in v0.377.0 

func (g *ResourceGraph) Roots() []*provisioner.Resource

Roots returns all nodes that have no incoming edges

func (*ResourceGraph) WithDirectDependencies added in v0.377.0 

func (g *ResourceGraph) WithDirectDependencies(roots []*provisioner.Resource) *ResourceGraph

WithDirectDependencies returns a subgraph of given nodes with their direct dependencies

type ResourceType added in v0.377.0 

type ResourceType string

ResourceType is a type of resource used to configure provisioners 

const (
	ResourceTypeUnknown  ResourceType = "unknown"
	ResourceTypePostgres ResourceType = "postgres"
	ResourceTypeMysql    ResourceType = "mysql"
	ResourceTypeModule   ResourceType = "module"
)

func TypeOf added in v0.377.0 

func TypeOf(r *provisioner.Resource) ResourceType

TypeOf returns the resource type of the given resource

type Service 

type Service struct {
	// contains filtered or unexported fields
}

func New 

func New(ctx context.Context, config Config, controllerClient ftlv1connect.ControllerServiceClient, registry *ProvisionerRegistry) (*Service, error)

func (*Service) CreateDeployment 

func (s *Service) CreateDeployment(ctx context.Context, req *connect.Request[ftlv1.CreateDeploymentRequest]) (*connect.Response[ftlv1.CreateDeploymentResponse], error)

func (*Service) GetArtefactDiffs added in v0.372.0 

func (s *Service) GetArtefactDiffs(ctx context.Context, req *connect.Request[ftlv1.GetArtefactDiffsRequest]) (*connect.Response[ftlv1.GetArtefactDiffsResponse], error)

func (*Service) GetSchema added in v0.372.0 

func (s *Service) GetSchema(ctx context.Context, req *connect.Request[ftlv1.GetSchemaRequest]) (*connect.Response[ftlv1.GetSchemaResponse], error)

func (*Service) Ping 

func (s *Service) Ping(context.Context, *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*Service) PullSchema added in v0.372.0 

func (s *Service) PullSchema(ctx context.Context, req *connect.Request[ftlv1.PullSchemaRequest], to *connect.ServerStream[ftlv1.PullSchemaResponse]) error

func (*Service) ReplaceDeploy added in v0.372.0 

func (s *Service) ReplaceDeploy(ctx context.Context, req *connect.Request[ftlv1.ReplaceDeployRequest]) (*connect.Response[ftlv1.ReplaceDeployResponse], error)

func (*Service) Status added in v0.372.0 

func (s *Service) Status(ctx context.Context, req *connect.Request[ftlv1.StatusRequest]) (*connect.Response[ftlv1.StatusResponse], error)

func (*Service) UpdateDeploy added in v0.372.0 

func (s *Service) UpdateDeploy(ctx context.Context, req *connect.Request[ftlv1.UpdateDeployRequest]) (*connect.Response[ftlv1.UpdateDeployResponse], error)

func (*Service) UploadArtefact added in v0.372.0 

func (s *Service) UploadArtefact(ctx context.Context, req *connect.Request[ftlv1.UploadArtefactRequest]) (*connect.Response[ftlv1.UploadArtefactResponse], error)

type Task added in v0.377.0 

type Task struct {
	// contains filtered or unexported fields
}

Task is a unit of work for a deployment

func (*Task) Progress added in v0.377.0 

func (t *Task) Progress(ctx context.Context) error

func (*Task) Start added in v0.377.0 

func (t *Task) Start(ctx context.Context) error

type TaskState added in v0.377.0 

type TaskState string
const (
	TaskStatePending TaskState = ""
	TaskStateRunning TaskState = "running"
	TaskStateDone    TaskState = "done"
	TaskStateFailed  TaskState = "failed"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.