Skip to content

Commit

Permalink
fix: G: remove variable for unused context parameter (#3333)
Browse files Browse the repository at this point in the history
Signed-off-by: Aaron Alpar <[email protected]>
Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
  • Loading branch information
aaron-kasten and mergify[bot] authored Jan 18, 2025
1 parent 5f653cb commit 4ca609e
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions pkg/kanx/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,6 @@ func (s *processServiceServer) CreateProcess(_ context.Context, cpr *CreateProce
if err != nil {
return nil, err
}

s.storeProcess(int64(cmd.Process.Pid), p)
fields := field.M{"pid": cmd.Process.Pid, "stdout": stdoutfd.Name(), "stderr": stderrfd.Name()}
stdoutLogWriter.SetFields(fields)
Expand Down Expand Up @@ -139,15 +138,15 @@ func (s *processServiceServer) storeProcess(pid int64, p *process) {
s.processes.Store(pid, p)
}

func (s *processServiceServer) GetProcess(ctx context.Context, grp *ProcessPidRequest) (*Process, error) {
func (s *processServiceServer) GetProcess(_ context.Context, grp *ProcessPidRequest) (*Process, error) {
p, ok := s.loadProcess(grp.GetPid())
if !ok {
return nil, errkit.WithStack(errProcessNotFound)
}
return processToProtoWithLock(p), nil
}

func (s *processServiceServer) SignalProcess(ctx context.Context, grp *SignalProcessRequest) (*Process, error) {
func (s *processServiceServer) SignalProcess(_ context.Context, grp *SignalProcessRequest) (*Process, error) {
p, ok := s.loadProcess(grp.GetPid())
if !ok {
return nil, errkit.WithStack(errProcessNotFound)
Expand All @@ -164,7 +163,7 @@ func (s *processServiceServer) SignalProcess(ctx context.Context, grp *SignalPro
return processToProto(p), err
}

func (s *processServiceServer) ListProcesses(lpr *ListProcessesRequest, lps ProcessService_ListProcessesServer) error {
func (s *processServiceServer) ListProcesses(_ *ListProcessesRequest, lps ProcessService_ListProcessesServer) error {
var err error
s.processes.Range(func(key, value any) bool {
err = lps.Send(processToProtoWithLock(value.(*process)))
Expand Down

0 comments on commit 4ca609e

Please sign in to comment.