run

Apr 12, 2024

Changes in this version

type Run

+ Builder builder.Impl

Mar 14, 2024

Changes in this version

type Manager

+ func (mgr *Manager) TestSpec(ctx context.Context, params TestSpecParams) (*TestSpecResponse, error)

+ type TestSpecParams struct

+ App *apps.Instance

+ Args []string

+ CodegenDebug bool

+ Environ []string

+ NS *namespace.Namespace

+ Secrets *secret.LoadResult

+ WorkingDir string

+ type TestSpecResponse struct

+ Args []string

+ Command string

+ Environ []string

Mar 7, 2024

Changes in this version

+ type GatewayConfig struct

+ BaseURL string

+ Hostnames []string

+ type ProcConfig struct

+ ExtraEnv []string

+ ListenAddr netip.AddrPort

+ Runtime option.Option[*runtimev1.RuntimeConfig]

type ProcGroup

+ ConfigGen *RuntimeConfigGenerator

+ Gateways map[string]*Proc

+ func (pg *ProcGroup) ProxyReq(w http.ResponseWriter, req *http.Request)

+ type RuntimeConfigGenerator struct

+ AppID option.Option[string]

+ AuthKey config.EncoreAuthKey

+ DefinedSecrets map[string]string

+ DeployID option.Option[string]

+ EnvCloud option.Option[runtimev1.Environment_Cloud]

+ EnvID option.Option[string]

+ EnvName option.Option[string]

+ EnvType option.Option[runtimev1.Environment_Type]

+ Gateways map[string]GatewayConfig

+ IncludeMetaEnv bool

+ SvcConfigs map[string]string

+ TraceEndpoint option.Option[string]

+ func (g *RuntimeConfigGenerator) AllInOneProc() (*ProcConfig, error)

+ func (g *RuntimeConfigGenerator) ForTests(newRuntimeConf bool) (env []string, err error)

+ func (g *RuntimeConfigGenerator) MissingSecrets() []string

+ func (g *RuntimeConfigGenerator) ProcEnvs(proc *ProcConfig, useRuntimeConfigV2 bool) ([]string, error)

+ func (g *RuntimeConfigGenerator) ProcPerService(proxy *svcproxy.SvcProxy) (services, gateways map[string]*ProcConfig, err error)

+ func (g *RuntimeConfigGenerator) ProcPerServiceWithNewRuntimeConfig(proxy *svcproxy.SvcProxy) (conf *runtimev1.RuntimeConfig, services, gateways map[string]*ProcConfig, ...)

type StartProcGroupParams

+ Outputs []builder.BuildOutput

type TestParams

+ PrepareOnly bool

Jan 25, 2024

Changes in this version

type EventListener

+ OnCompileStart func(r *Run)

Aug 29, 2023

Changes in this version

+ type BrowserMode int

+ const BrowserModeAlways

+ const BrowserModeAuto

+ const BrowserModeNever

+ func BrowserModeFromProto(b daemonpb.RunRequest_BrowserMode) BrowserMode

type Run

+ Params *StartParams

type StartParams

+ Browser BrowserMode

Aug 17, 2023

Changes in this version

type StartProcGroupParams

+ IsReload bool

Aug 2, 2023

Changes in this version

type ExecScriptParams

+ NS *namespace.Namespace

type Manager

+ func (m *Manager) CanDeleteNamespace(ctx context.Context, app *apps.Instance, ns *namespace.Namespace) error

+ func (m *Manager) DeleteNamespace(ctx context.Context, app *apps.Instance, ns *namespace.Namespace) error

type Run

+ NS *namespace.Namespace

type RuntimeEnvGenerator

+ GracefulShutdownTime option.Option[time.Duration]

+ HandlersGrace option.Option[time.Duration]

+ ShutdownHooksGrace option.Option[time.Duration]

type StartParams

+ NS *namespace.Namespace

type TestParams

+ NS *namespace.Namespace

Jul 13, 2023

Changes in this version

type TestParams

+ CodegenDebug bool

Jul 6, 2023

Changes in this version

type RuntimeEnvGenerator

+ func (g *RuntimeEnvGenerator) ForAllInOne(listenAddr netip.AddrPort) ([]string, error)

Jul 5, 2023

Changes in this version

+ type ListenAddresses struct

+ Gateway SvcNetCfg

+ Services map[string]SvcNetCfg

+ func GenerateListenAddresses(proxy *svcproxy.SvcProxy, serviceList []*meta.Service) (*ListenAddresses, error)

+ func (la *ListenAddresses) GenerateServiceDiscoveryMap(serviceList []*meta.Service, authMethod string) (map[string]config.Service, error)

+ type NewProcParams struct

+ BinPath string

+ Environ []string

type Proc

+ func (p *Proc) ProxyReq(w http.ResponseWriter, req *http.Request)

type ProcGroup

+ EnvGenerator *RuntimeEnvGenerator

+ Services map[string]*Proc

+ func (pg *ProcGroup) Kill()

+ func (pg *ProcGroup) NewProcForGateway(listenAddr netip.AddrPort, params *NewProcParams) error

+ func (pg *ProcGroup) NewProcForService(service *meta.Service, listenAddr netip.AddrPort, params *NewProcParams) error

+ func (pg *ProcGroup) Start() (err error)

+ func (pg *ProcGroup) Warnings() (rtn []warning)

type Run

+ SvcProxy *svcproxy.SvcProxy

+ func (r *Run) Close()

+ type RuntimeEnvGenerator struct

+ App interface{ ... }

+ AppID option.Option[string]

+ AuthKey option.Option[config.EncoreAuthKey]

+ CloudType option.Option[encore.CloudProvider]

+ DaemonProxyAddr option.Option[netip.AddrPort]

+ EnvID option.Option[string]

+ EnvName option.Option[string]

+ EnvType option.Option[encore.EnvironmentType]

+ InfraManager interface{ ... }

+ ListenAddresses *ListenAddresses

+ Meta *meta.Data

+ MetricsConfig option.Option[*config.Metrics]

+ Secrets map[string]string

+ ServiceAuthType option.Option[string]

+ SvcConfigs map[string]string

+ TraceEndpoint option.Option[string]

+ func (g *RuntimeEnvGenerator) ForGateway(listenAddr netip.AddrPort, hostNames ...string) ([]string, error)

+ func (g *RuntimeEnvGenerator) ForServices(listenAddr netip.AddrPort, services ...*meta.Service) ([]string, error)

+ type SvcNetCfg struct

+ BaseURL string

+ ListenAddr netip.AddrPort

Jun 29, 2023

Changes in this version

type Proc

+ StartedAt time.Time

+ func (p *Proc) Kill()

+ func (p *Proc) Start() error

+ type ProcGroup struct

+ Experiments *experiments.Set

+ Gateway *Proc

+ ID string

+ Meta *meta.Data

+ Run *Run

+ func (pg *ProcGroup) Close()

+ func (pg *ProcGroup) Done() <-chan struct{}

+ func (pg *ProcGroup) NewAllInOneProc(binPath string, environ []string, secrets map[string]string, ...) error

+ func (pg *ProcGroup) SymTable(ctx context.Context) (*sym.Table, error)

type Run

+ func (r *Run) ProcGroup() *ProcGroup

+ func (r *Run) StartProcGroup(params *StartProcGroupParams) (p *ProcGroup, err error)

+ type StartProcGroupParams struct

+ BinPath string

+ BuildDir string

+ Ctx context.Context

+ DBProxyPort int

+ Environ []string

+ Experiments *experiments.Set

+ Logger RunLogger

+ Meta *meta.Data

+ RuntimePort int

+ Secrets map[string]string

+ ServiceConfigs map[string]string

+ WorkingDir string

Jun 26, 2023

Changes in this version

+ func AsErrorList(err error) *errlist.List

May 5, 2023

Changes in this version

type StartProcParams

+ WorkingDir string

Apr 21, 2023

Changes in this version

type Run

+ ResourceManager *infra.ResourceManager

Apr 4, 2023

Changes in this version

+ type CheckParams struct

+ App *apps.Instance

+ CodegenDebug bool

+ Environ []string

+ Tests bool

+ WorkingDir string

type ExecScriptParams

+ MainPkg paths.Pkg

type StartParams

+ Debug bool

Jan 26, 2023

Changes in this version

type TestParams

+ Secrets *secret.LoadResult

Dec 8, 2022

Changes in this version

+ func IgnoreEvents(events []watcher.Event) bool

+ type AsyncBuildJobs struct

+ func NewAsyncBuildJobs(ctx context.Context, appID string, tracker *optracker.OpTracker) *AsyncBuildJobs

+ func (a *AsyncBuildJobs) Go(description string, track bool, minDuration time.Duration, ...)

+ func (a *AsyncBuildJobs) Wait() error

+ type ExecScriptParams struct

+ App *apps.Instance

+ Environ []string

+ OpTracker *optracker.OpTracker

+ ScriptArgs []string

+ ScriptRelPath string

+ Stderr io.Writer

+ Stdout io.Writer

+ WorkingDir string

type Manager

+ func (mgr *Manager) ExecScript(ctx context.Context, p ExecScriptParams) (err error)

type ResourceServices

+ func NewResourceServices(app *apps.Instance, sqlMgr *sqldb.ClusterManager) *ResourceServices

type Run

+ Mgr *Manager

Nov 4, 2022

Changes in this version

type Proc

+ Experiments *experiments.Set

type StartProcParams

+ Experiments *experiments.Set

Nov 3, 2022

Changes in this version

+ const TestHeaderDisablePlatformAuth

+ type RunLogger interface

+ RunStderr func(r *Run, line []byte)

+ RunStdout func(r *Run, line []byte)

Oct 13, 2022

Changes in this version

+ func GenID() string

type EventListener

+ OnError func(r *Run, err *errlist.List)

type Manager

+ func (mgr *Manager) RunError(r *Run, err *errlist.List)

+ func (mgr *Manager) RunStderr(r *Run, out []byte)

+ func (mgr *Manager) RunStdout(r *Run, out []byte)

type Proc

+ Client *yamux.Session

+ func (p *Proc) Close()

type Run

+ func (r *Run) StartProc(params *StartProcParams) (p *Proc, err error)

+ func (r *Run) StoreProc(p *Proc)

+ type StartProcParams struct

+ BinPath string

+ BuildDir string

+ Ctx context.Context

+ DBProxyPort int

+ Environ []string

+ Logger runLogger

+ Meta *meta.Data

+ NSQDaemon *pubsub.NSQDaemon

+ Redis *redis.Server

+ RuntimePort int

+ SQLDBCluster *sqldb.Cluster

+ Secrets map[string]string

+ ServiceConfigs map[string]string

Sep 21, 2022

Changes in this version

type ResourceServices

+ func (rs *ResourceServices) GetRedis() *redis.Server

+ func (rs *ResourceServices) StartRedis(ctx context.Context) error

Jul 12, 2022

Changes in this version

type Manager

+ ClusterMgr *sqldb.ClusterManager

+ type ResourceServer interface

+ Stop func()

+ type ResourceServices struct

+ func (rs *ResourceServices) GetPubSub() *pubsub.NSQDaemon

+ func (rs *ResourceServices) GetSQLCluster() *sqldb.Cluster

+ func (rs *ResourceServices) StartPubSub(ctx context.Context) error

+ func (rs *ResourceServices) StartRequiredServices(a *asyncBuildJobs, parse *parser.Result) error

+ func (rs *ResourceServices) StartSQLCluster(a *asyncBuildJobs, parse *parser.Result) func(ctx context.Context) error

+ func (rs *ResourceServices) StopAll()

type Run

+ App *apps.Instance

+ ResourceServers *ResourceServices

type StartParams

+ App *apps.Instance

+ OpsTracker *optracker.OpTracker

type TestParams

+ App *apps.Instance

+ SQLDBCluster *sqldb.Cluster

Apr 26, 2022

Changes in this version

type StartParams

+ Environ []string

type TestParams

+ Environ []string

Sep 20, 2021

Changes in this version

type Run

+ ListenAddr string

type StartParams

+ ListenAddr string

+ Listener net.Listener

Jul 8, 2021

Changes in this version

type Proc

+ func (p *Proc) SymTable(ctx context.Context) (*sym.Table, error)

Apr 12, 2021

Changes in this version

+ const BasePort

+ type EventListener interface

+ OnReload func(r *Run)

+ OnStart func(r *Run)

+ OnStderr func(r *Run, out []byte)

+ OnStdout func(r *Run, out []byte)

+ OnStop func(r *Run)

+ type Manager struct

+ DBProxyPort int

+ DashPort int

+ RuntimePort int

+ Secret *secret.Manager

+ func (mgr *Manager) AddListener(ln EventListener)

+ func (mgr *Manager) Check(ctx context.Context, appRoot, relwd string) error

+ func (mgr *Manager) FindProc(procID string) *Proc

+ func (mgr *Manager) FindRunByAppID(appID string) *Run

+ func (mgr *Manager) ListRuns() []*Run

+ func (mgr *Manager) Start(ctx context.Context, params StartParams) (run *Run, err error)

+ func (mgr *Manager) Test(ctx context.Context, params TestParams) (err error)

+ type Proc struct

+ ID string

+ Meta *meta.Data

+ Pid int

+ Run *Run

+ Started time.Time

+ func (p *Proc) Done() <-chan struct{}

+ type Run struct

+ AppID string

+ AppSlug string

+ ID string

+ Port int

+ Root string

+ func (r *Run) Done() <-chan struct{}

+ func (r *Run) Proc() *Proc

+ func (r *Run) Reload() (*Proc, error)

+ func (r *Run) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type StartParams struct

+ AppID string

+ AppRoot string

+ DBClusterID string

+ Parse *parser.Result

+ Watch bool

+ WorkingDir string

+ type TestParams struct

+ AppID string

+ AppRoot string

+ Args []string

+ DBClusterID string

+ Parse *parser.Result

+ Stderr io.Writer

+ Stdout io.Writer

+ WorkingDir string