Documentation
¶
Overview ¶
Package serverlifecycle serves the ServerLifecycle RPC in front of the on-disk operation ledger in pkg/serverlifecycle.
Index ¶
- func FromRPC(v *server_v1alpha.Operation) *lifecycle.Operation
- func ToRPC(op *lifecycle.Operation) *server_v1alpha.Operation
- type Server
- func (s *Server) ForRunner() *Server
- func (s *Server) Get(_ context.Context, state *server_v1alpha.ServerLifecycleGet) error
- func (s *Server) List(_ context.Context, state *server_v1alpha.ServerLifecycleList) error
- func (s *Server) Start(ctx context.Context, state *server_v1alpha.ServerLifecycleStart) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FromRPC ¶
func FromRPC(v *server_v1alpha.Operation) *lifecycle.Operation
FromRPC converts a wire record back to the stored shape, for clients that want to reuse the store's own helpers (Done, Succeeded) on what they fetched. The verbatim record is preferred when the server sent one, so fields this schema does not name still arrive; the typed fields are the fallback.
Types ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server answers ServerLifecycle calls. Reads go straight to the file store: the executor writes there from its own process, so the files are the truth even while this server is the one being replaced.
func (*Server) Get ¶
func (s *Server) Get(_ context.Context, state *server_v1alpha.ServerLifecycleGet) error
func (*Server) List ¶
func (s *Server) List(_ context.Context, state *server_v1alpha.ServerLifecycleList) error
func (*Server) Start ¶
func (s *Server) Start(ctx context.Context, state *server_v1alpha.ServerLifecycleStart) error
Click to show internal directories.
Click to hide internal directories.