buildengine

Oct 28, 2024

Changes in this version

type Engine

+ EngineUpdates *pubsub.Topic[EngineEvent]

+ type EngineEnded struct

+ ModuleErrors map[string]error

+ type EngineEvent interface

+ type EngineStarted struct

+ type ModuleAdded struct

+ Module string

+ type ModuleBuildFailed struct

+ Config moduleconfig.ModuleConfig

+ Error error

+ IsAutoRebuild bool

+ type ModuleBuildStarted struct

+ Config moduleconfig.ModuleConfig

+ IsAutoRebuild bool

+ type ModuleBuildSuccess struct

+ Config moduleconfig.ModuleConfig

+ IsAutoRebuild bool

+ type ModuleBuildWaiting struct

+ Config moduleconfig.ModuleConfig

+ type ModuleDeployFailed struct

+ Error error

+ Module string

+ type ModuleDeployStarted struct

+ Module string

+ type ModuleDeploySuccess struct

+ Module string

+ type ModuleRemoved struct

+ Module string

Oct 17, 2024

Changes in this version

+ type DependencyMode string

+ const AlwaysIncludeBuiltin

+ const Raw

Oct 11, 2024

Changes in this version

type Module

+ Deploy []string

+ func (m Module) CopyWithDeploy(files []string) Module

Oct 1, 2024

Changes in this version

+ type AutoRebuildEndedEvent struct

+ Module string

+ Result either.Either[BuildResult, error]

+ func (e AutoRebuildEndedEvent) ModuleName() string

+ type AutoRebuildStartedEvent struct

+ Module string

+ func (e AutoRebuildStartedEvent) ModuleName() string

+ type BuildResult struct

+ Errors []*schema.Error

+ Name string

+ Schema *schema.Module

+ StartTime time.Time

+ type LanguagePlugin interface

+ Build func(ctx context.Context, projectRoot string, config moduleconfig.ModuleConfig, ...) (BuildResult, error)

+ CreateModule func(ctx context.Context, projConfig projectconfig.Config, ...) error

+ GetCreateModuleFlags func(ctx context.Context) ([]*kong.Flag, error)

+ GetDependencies func(ctx context.Context) ([]string, error)

+ Kill func(ctx context.Context) error

+ Updates func() *pubsub.Topic[PluginEvent]

+ func PluginFromConfig(ctx context.Context, config moduleconfig.ModuleConfig, projectRoot string) (p LanguagePlugin, err error)

+ type PluginEvent interface

+ ModuleName func() string

type WatchEventModuleAdded

+ Config moduleconfig.ModuleConfig

type WatchEventModuleChanged

+ Config moduleconfig.ModuleConfig

type WatchEventModuleRemoved

+ Config moduleconfig.ModuleConfig

Sep 26, 2024

Changes in this version

type DeployClient

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

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

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

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

Sep 25, 2024

Changes in this version

type Option

+ func WithStartTime(startTime time.Time) Option

Sep 19, 2024

Changes in this version

type Option

+ func WithDevMode(devMode bool) Option

Sep 11, 2024

Changes in this version

type Option

+ func BuildEnv(env []string) Option

Aug 17, 2024

Changes in this version

+ const BuildLockTimeout

+ var ErrSkip = errors.New("skip directory")

+ func Build(ctx context.Context, projectRootDir string, sch *schema.Schema, module Module, ...) error

+ func CleanStubs(ctx context.Context, projectRoot string) error

+ func ComputeFileHash(baseDir, srcPath string, watch []string) (hash []byte, matched bool, err error)

+ func Deploy(ctx context.Context, module Module, replicas int32, waitForDeployOnline bool, ...) error

+ func FindFilesToDeploy(moduleConfig moduleconfig.AbsModuleConfig) ([]string, error)

+ func GenerateStubs(ctx context.Context, projectRoot string, modules []*schema.Module, ...) error

+ func SetPOMProperties(ctx context.Context, baseDir string) error

+ func SyncStubReferences(ctx context.Context, projectRoot string, moduleNames []string, ...) error

+ func TopologicalSort(graph map[string][]string) (groups [][]string, cycleError error)

+ func WalkDir(dir string, fn func(path string, d fs.DirEntry) error) error

+ type CompilerBuildError struct

+ func (e CompilerBuildError) Error() string

+ func (e CompilerBuildError) Unwrap() error

+ type DeployClient interface

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

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

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

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

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

+ type Engine struct

+ func New(ctx context.Context, client ftlv1connect.ControllerServiceClient, ...) (*Engine, error)

+ func (e *Engine) Build(ctx context.Context) error

+ func (e *Engine) BuildAndDeploy(ctx context.Context, replicas int32, waitForDeployOnline bool, ...) error

+ func (e *Engine) Close() error

+ func (e *Engine) Deploy(ctx context.Context, replicas int32, waitForDeployOnline bool) error

+ func (e *Engine) Dev(ctx context.Context, period time.Duration) error

+ func (e *Engine) Each(fn func(Module) error) (err error)

+ func (e *Engine) Graph(moduleNames ...string) (map[string][]string, error)

+ func (e *Engine) Import(ctx context.Context, schema *schema.Module)

+ func (e *Engine) Modules() []string

+ type FileChangeType rune

+ const FileAdded

+ const FileChanged

+ const FileRemoved

+ func CompareFileHashes(oldFiles, newFiles FileHashes) (FileChangeType, string, bool)

+ func (f FileChangeType) GoString() string

+ func (f FileChangeType) String() string

+ type FileHashes map[string][]byte

+ func ComputeFileHashes(module Module) (FileHashes, error)

+ type Listener interface

+ OnBuildFailed func(err error)

+ OnBuildStarted func(module Module)

+ OnBuildSuccess func()

+ type ModifyFilesTransaction interface

+ Begin func() error

+ End func() error

+ ModifiedFiles func(paths ...string) error

+ type Module struct

+ Config moduleconfig.ModuleConfig

+ Dependencies []string

+ func DiscoverModules(ctx context.Context, moduleDirs []string) ([]Module, error)

+ func LoadModule(dir string) (Module, error)

+ func UpdateDependencies(ctx context.Context, module Module) (Module, error)

+ func (m Module) CopyWithDependencies(dependencies []string) Module

+ type Option func(o *Engine)

+ func Parallelism(n int) Option

+ func WithListener(listener Listener) Option

+ type WatchEvent interface

+ type WatchEventModuleAdded struct

+ Module Module

+ type WatchEventModuleChanged struct

+ Change FileChangeType

+ Module Module

+ Path string

+ Time time.Time

+ type WatchEventModuleRemoved struct

+ Module Module

+ type Watcher struct

+ func NewWatcher() *Watcher

+ func (w *Watcher) GetTransaction(moduleDir string) ModifyFilesTransaction

+ func (w *Watcher) Watch(ctx context.Context, period time.Duration, moduleDirs []string) (*pubsub.Topic[WatchEvent], error)