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) 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) 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, params *daemonpb.GenWrappersRequest) (*daemonpb.GenWrappersResponse, error)
  • 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) Test(req *daemonpb.TestRequest, stream daemonpb.Daemon_TestServer) 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) *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) 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) 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, params *daemonpb.GenWrappersRequest) (*daemonpb.GenWrappersResponse, error)

GenWrappers generates Encore wrappers.

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) Test

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

Test runs tests.

func (*Server) Version

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

Version reports the daemon version.