provisioner

Nov 25, 2024

Changes in this version

+ func ProvisionMySQLForTest(ctx context.Context, module string, id string) (string, error)

+ func ProvisionPostgresForTest(ctx context.Context, module string, id string) (string, error)

+ func RunMySQLMigration(ctx context.Context, dsn string, moduleDir string, name string) error

+ func RunPostgresMigration(ctx context.Context, dsn string, moduleDir string, name string) error

type InMemProvisioner

+ func NewSQLMigrationProvisioner(registryConfig artefacts.RegistryConfig) *InMemProvisioner

type ResourceType

+ const ResourceTypeSQLMigration

Oct 29, 2024

Changes in this version

type Deployment

+ Graph *ResourceGraph

type ResourceGraph

+ func (g *ResourceGraph) ByIDs(ids map[string]bool) []*provisioner.Resource

+ func (g *ResourceGraph) Node(id string) *provisioner.Resource

+ func (g *ResourceGraph) Update(resources []*provisioner.Resource)

Oct 28, 2024

Changes in this version

type ProvisionerBinding

+ func (p ProvisionerBinding) String() string

Oct 28, 2024

Changes in this version

type ProvisionerBinding

+ ID string

Oct 11, 2024

Changes in this version

+ type Deployment struct

+ Module string

+ Tasks []*Task

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

+ func (d *Deployment) State() *DeploymentState

+ type DeploymentState struct

+ Done []*Task

+ Failed *Task

+ Pending []*Task

+ Running *Task

+ type InMemProvisioner struct

+ func NewControllerProvisioner(client ftlv1connect.ControllerServiceClient) *InMemProvisioner

+ func NewDevProvisioner(postgresPort int) *InMemProvisioner

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

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

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

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

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

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

+ type NoopProvisioner struct

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

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

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

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

+ type ProvisionerBinding struct

+ Provisioner provisionerconnect.ProvisionerPluginServiceClient

+ Types []ResourceType

+ type ProvisionerRegistry struct

+ Default provisionerconnect.ProvisionerPluginServiceClient

+ Provisioners []*ProvisionerBinding

+ func RegistryFromConfigFile(ctx context.Context, file *os.File, ...) (*ProvisionerRegistry, error)

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

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

+ type ResourceEdge struct

+ type ResourceGraph struct

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

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

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

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

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

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

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

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

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

+ type ResourceType string

+ const ResourceTypeModule

+ const ResourceTypeMysql

+ const ResourceTypePostgres

+ const ResourceTypeUnknown

+ func TypeOf(r *provisioner.Resource) ResourceType

+ type Task struct

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

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

+ type TaskState string

+ const TaskStateDone

+ const TaskStateFailed

+ const TaskStatePending

+ const TaskStateRunning

Oct 1, 2024

Changes in this version

+ type CommonProvisionerConfig struct

+ PluginConfigFile *os.File

Sep 26, 2024

Changes in this version

type Service

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

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

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

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

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

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

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

Sep 23, 2024

Changes in this version

+ func Start(ctx context.Context, config Config, devel bool) error

+ type Config struct

+ Advertise *url.URL

+ Bind *url.URL

+ ControllerEndpoint *url.URL

+ IngressBind *url.URL

+ func (c *Config) SetDefaults()

+ type Service struct

+ func New(ctx context.Context, config Config, ...) (*Service, error)

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

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