From fff5c2f7180647aa00096f84bb95d27a400b0fc5 Mon Sep 17 00:00:00 2001 From: Aaron Alpar <55999015+aaron-kasten@users.noreply.github.com> Date: Wed, 9 Oct 2024 09:26:17 -0700 Subject: [PATCH 1/2] Update pkg/kanx/client.go Co-authored-by: Denis Voytyuk <5462781+denisvmedia@users.noreply.github.com> --- pkg/kanx/client.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/kanx/client.go b/pkg/kanx/client.go index 80f996aaf8..019d4da270 100644 --- a/pkg/kanx/client.go +++ b/pkg/kanx/client.go @@ -13,6 +13,7 @@ import ( func unixDialer(ctx context.Context, addr string) (net.Conn, error) { return net.Dial("unix", addr) } + func newGRPCConnection(addr string) (*grpc.ClientConn, error) { var opts []grpc.DialOption opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials())) From ecd0b75afcb7319270a0a3c3080433d6ca72312d Mon Sep 17 00:00:00 2001 From: Aaron Alpar <55999015+aaron-kasten@users.noreply.github.com> Date: Wed, 9 Oct 2024 09:26:29 -0700 Subject: [PATCH 2/2] Update pkg/kanx/client.go Co-authored-by: Denis Voytyuk <5462781+denisvmedia@users.noreply.github.com> --- pkg/kanx/client.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/pkg/kanx/client.go b/pkg/kanx/client.go index 019d4da270..d19b8f4656 100644 --- a/pkg/kanx/client.go +++ b/pkg/kanx/client.go @@ -47,8 +47,7 @@ func ListProcesses(ctx context.Context, addr string) ([]*Process, error) { } defer conn.Close() c := NewProcessServiceClient(conn) - in := &ListProcessesRequest{} - lpc, err := c.ListProcesses(ctx, in) + lpc, err := c.ListProcesses(ctx, &ListProcessesRequest{}) if err != nil { return nil, err }