grpc

package

v0.0.1 Latest Latest Go to latest Published: Jan 1, 2026 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CommandInfo struct {
	Cmd        *exec.Cmd
	Cancel     context.CancelFunc
	StartTime  time.Time
	Status     string
	Continuous bool
}

type CommandSrv struct {
	Commands map[string]*CommandInfo
	pb.UnimplementedCommandServer
	// contains filtered or unexported fields
}

func (s *CommandSrv) ExecCommand(req *pb.ExecCommandReq, stream pb.Command_ExecCommandServer) error

func (s *CommandSrv) ExecCommandSignal(ctx context.Context, req *pb.ExecCommandSignalReq) (*pb.ExecCommandSignalResp, error)

func (s *CommandSrv) GetCommandStatus(ctx context.Context, req *pb.GetCommandStatusReq) (*pb.GetCommandStatusResp, error)

New method to get the status of a command

type LuaSrv struct {
	pb.UnimplementedLuaServer
}

func (s *LuaSrv) ExecLuaScript(ctx context.Context, req *pb.ExecLuaScriptReq) (*pb.ExecLuaScriptResp, error)

type PackageSrv struct {
	pb.UnimplementedPackageServer
	// contains filtered or unexported fields
}

func NewPackageSrv(pm *packages.PackageManager) *PackageSrv

func (s *PackageSrv) ApplyConfigs(ctx context.Context, req *pb.ApplyConfigsReq) (*pb.ApplyConfigsResp, error)

func (s *PackageSrv) GetConfigs(ctx context.Context, req *pb.GetConfigsReq) (*pb.GetConfigsResp, error)

	return &pb.StatusResp{
		IsRunning: isRunning,
	}, nil
}

func (s *PackageSrv) GetRecentLogs(ctx context.Context, req *pb.GetRecentLogsReq) (*pb.GetRecentLogsResp, error)

func (s *PackageSrv) PackageList(ctx context.Context, _ *emptypb.Empty) (*pb.PackageListResp, error)

func (s *PackageSrv) Restart(ctx context.Context, req *pb.RestartReq) (*emptypb.Empty, error)

func (s *PackageSrv) Start(ctx context.Context, req *pb.StartReq) (*emptypb.Empty, error)

func (s *PackageSrv) Stop(ctx context.Context, req *pb.StopReq) (*emptypb.Empty, error)