daemon

Documentation

Overview

Package daemon implements the Encore daemon gRPC server.

Index

• type Server
  • func New(appsMgr *apps.Manager, mgr *run.Manager, cm *sqldb.ClusterManager, ...) *Server
  • func (s *Server) Check(req *daemonpb.CheckRequest, stream daemonpb.Daemon_CheckServer) error
  • func (s *Server) CreateApp(ctx context.Context, req *daemonpb.CreateAppRequest) (*daemonpb.CreateAppResponse, error)
  • func (s *Server) CreateNamespace(ctx context.Context, req *daemonpb.CreateNamespaceRequest) (*daemonpb.Namespace, error)
  • func (s *Server) DBConnect(ctx context.Context, req *daemonpb.DBConnectRequest) (*daemonpb.DBConnectResponse, error)
  • func (s *Server) DBProxy(params *daemonpb.DBProxyRequest, stream daemonpb.Daemon_DBProxyServer) (err error)
  • func (s *Server) DBReset(req *daemonpb.DBResetRequest, stream daemonpb.Daemon_DBResetServer) error
  • func (s *Server) DeleteNamespace(ctx context.Context, req *daemonpb.DeleteNamespaceRequest) (*empty.Empty, error)
  • func (s *Server) DumpMeta(ctx context.Context, req *daemonpb.DumpMetaRequest) (*daemonpb.DumpMetaResponse, error)
  • func (s *Server) ExecScript(req *daemonpb.ExecScriptRequest, stream daemonpb.Daemon_ExecScriptServer) error
  • func (s *Server) Export(req *daemonpb.ExportRequest, stream daemonpb.Daemon_ExportServer) error
  • func (s *Server) GenClient(ctx context.Context, params *daemonpb.GenClientRequest) (*daemonpb.GenClientResponse, error)
  • func (s *Server) GenWrappers(ctx context.Context, req *daemonpb.GenWrappersRequest) (*daemonpb.GenWrappersResponse, error)
  • func (s *Server) ListNamespaces(ctx context.Context, req *daemonpb.ListNamespacesRequest) (*daemonpb.ListNamespacesResponse, error)
  • func (s *Server) OnCompileStart(r *run.Run)
  • func (s *Server) OnError(r *run.Run, err *errlist.List)
  • func (s *Server) OnReload(r *run.Run)
  • func (s *Server) OnStart(r *run.Run)
  • func (s *Server) OnStderr(r *run.Run, line []byte)
  • func (s *Server) OnStdout(r *run.Run, line []byte)
  • func (s *Server) OnStop(r *run.Run)
  • func (s *Server) Run(req *daemonpb.RunRequest, stream daemonpb.Daemon_RunServer) error
  • func (s *Server) SecretsRefresh(ctx context.Context, req *daemonpb.SecretsRefreshRequest) (*daemonpb.SecretsRefreshResponse, error)
  • func (s *Server) SwitchNamespace(ctx context.Context, req *daemonpb.SwitchNamespaceRequest) (*daemonpb.Namespace, error)
  • func (s *Server) Telemetry(ctx context.Context, req *daemonpb.TelemetryConfig) (*emptypb.Empty, error)
  • func (s *Server) Test(req *daemonpb.TestRequest, stream daemonpb.Daemon_TestServer) error
  • func (s *Server) TestSpec(ctx context.Context, req *daemonpb.TestSpecRequest) (resp *daemonpb.TestSpecResponse, err error)
  • func (s *Server) Version(context.Context, *empty.Empty) (*daemonpb.VersionResponse, error)

Types

type Server

type Server struct {
	daemonpb.UnimplementedDaemonServer
	// contains filtered or unexported fields
}

Server implements daemonpb.DaemonServer.

func New

func New(appsMgr *apps.Manager, mgr *run.Manager, cm *sqldb.ClusterManager, sm *secret.Manager, ns *namespace.Manager) *Server

New creates a new Server.

func (*Server) Check

func (s *Server) Check(req *daemonpb.CheckRequest, stream daemonpb.Daemon_CheckServer) error

Check checks the app for compilation errors.

func (*Server) CreateApp

func (s *Server) CreateApp(ctx context.Context, req *daemonpb.CreateAppRequest) (*daemonpb.CreateAppResponse, error)

CreateApp adds tracking for a new app

func (*Server) CreateNamespace

func (s *Server) CreateNamespace(ctx context.Context, req *daemonpb.CreateNamespaceRequest) (*daemonpb.Namespace, error)

func (*Server) DBConnect

func (s *Server) DBConnect(ctx context.Context, req *daemonpb.DBConnectRequest) (*daemonpb.DBConnectResponse, error)

DBConnect starts the database and returns the DSN for connecting to it.

func (*Server) DBProxy

func (s *Server) DBProxy(params *daemonpb.DBProxyRequest, stream daemonpb.Daemon_DBProxyServer) (err error)

DBProxy starts a local database proxy for connecting to remote databases on the encore.dev platform.

func (*Server) DBReset

func (s *Server) DBReset(req *daemonpb.DBResetRequest, stream daemonpb.Daemon_DBResetServer) error

DBReset resets the given databases, recreating them from scratch.

func (*Server) DeleteNamespace

func (s *Server) DeleteNamespace(ctx context.Context, req *daemonpb.DeleteNamespaceRequest) (*empty.Empty, error)

func (*Server) DumpMeta

func (s *Server) DumpMeta(ctx context.Context, req *daemonpb.DumpMetaRequest) (*daemonpb.DumpMetaResponse, error)

func (*Server) ExecScript

func (s *Server) ExecScript(req *daemonpb.ExecScriptRequest, stream daemonpb.Daemon_ExecScriptServer) error

ExecScript executes a one-off script.

func (*Server) Export

func (s *Server) Export(req *daemonpb.ExportRequest, stream daemonpb.Daemon_ExportServer) error

Export exports the app.

func (*Server) GenClient

func (s *Server) GenClient(ctx context.Context, params *daemonpb.GenClientRequest) (*daemonpb.GenClientResponse, error)

GenClient generates a client based on the app's API.

func (*Server) GenWrappers

func (s *Server) GenWrappers(ctx context.Context, req *daemonpb.GenWrappersRequest) (*daemonpb.GenWrappersResponse, error)

GenWrappers generates Encore wrappers.

func (*Server) ListNamespaces

func (s *Server) ListNamespaces(ctx context.Context, req *daemonpb.ListNamespacesRequest) (*daemonpb.ListNamespacesResponse, error)

func (*Server) OnCompileStart

func (s *Server) OnCompileStart(r *run.Run)

func (*Server) OnError

func (s *Server) OnError(r *run.Run, err *errlist.List)

func (*Server) OnReload

func (s *Server) OnReload(r *run.Run)

OnReload implements run.EventListener.

func (*Server) OnStart

func (s *Server) OnStart(r *run.Run)

OnStart implements run.EventListener.

func (*Server) OnStderr

func (s *Server) OnStderr(r *run.Run, line []byte)

OnStderr implements run.EventListener.

func (*Server) OnStdout

func (s *Server) OnStdout(r *run.Run, line []byte)

OnStdout implements run.EventListener.

func (*Server) OnStop

func (s *Server) OnStop(r *run.Run)

OnStop implements run.EventListener.

func (*Server) Run

func (s *Server) Run(req *daemonpb.RunRequest, stream daemonpb.Daemon_RunServer) error

Run runs the application.

func (*Server) SecretsRefresh

func (s *Server) SecretsRefresh(ctx context.Context, req *daemonpb.SecretsRefreshRequest) (*daemonpb.SecretsRefreshResponse, error)

func (*Server) SwitchNamespace

func (s *Server) SwitchNamespace(ctx context.Context, req *daemonpb.SwitchNamespaceRequest) (*daemonpb.Namespace, error)

func (*Server) Telemetry

func (s *Server) Telemetry(ctx context.Context, req *daemonpb.TelemetryConfig) (*emptypb.Empty, error)

func (*Server) Test

func (s *Server) Test(req *daemonpb.TestRequest, stream daemonpb.Daemon_TestServer) error

Test runs tests.

func (*Server) TestSpec

func (s *Server) TestSpec(ctx context.Context, req *daemonpb.TestSpecRequest) (resp *daemonpb.TestSpecResponse, err error)

TestSpec runs tests.

func (*Server) Version

func (s *Server) Version(context.Context, *empty.Empty) (*daemonpb.VersionResponse, error)

Version reports the daemon version.