rpc

package

v0.0.0-...-f49f4f7 Latest Latest Go to latest Published: Nov 24, 2025 License: MPL-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type RunnerEndpoint struct {
	// contains filtered or unexported fields
}

func (r *RunnerEndpoint) JobLogsBatch(
	req *intrpc.RunnerLogsBatchReq,
	reply *intrpc.RunnerLogsBatchResp,
) error

JobLogsBatch receives a batch of log lines from a runner and writes them to disk

func (r *RunnerEndpoint) JobUpdate(
	req *intrpc.RunnerJobUpdateReq,
	reply *intrpc.RunnerJobUpdateResp,
) error

type Server struct {
	// contains filtered or unexported fields
}

func NewServer(req *ServerReq) (*Server, error)

func (s *Server) Start()

func (s *Server) Stop()

type ServerReq struct {
	Coordinator *coordinator.Coordinator
	Logger      *zap.Logger
	RPCAddr     string
	State       state.State
}