Skip to content

Commit

Permalink
feat: Added the right way to decipher from and to vertex (#78)
Browse files Browse the repository at this point in the history
Signed-off-by: Krithika Vijayakumar <krithika_vijayakumar@intuit.com>

Co-authored-by: Krithika Vijayakumar <krithika_vijayakumar@intuit.com>
Signed-off-by: Derek Wang <whynowy@gmail.com>
  • Loading branch information
2 people authored and whynowy committed Jul 8, 2022
1 parent f9177d9 commit 06a3df2
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions pkg/daemon/server/service/isbs_query_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,11 +4,12 @@ import (
"context"
"fmt"

"k8s.io/utils/pointer"

"github.com/numaproj/numaflow/pkg/apis/numaflow/v1alpha1"
"github.com/numaproj/numaflow/pkg/apis/proto/daemon"
"github.com/numaproj/numaflow/pkg/isbsvc"
"github.com/numaproj/numaflow/pkg/shared/logging"
"k8s.io/utils/pointer"
)

type isbSvcQueryService struct {
Expand Down Expand Up @@ -43,8 +44,8 @@ func (is *isbSvcQueryService) ListBuffers(ctx context.Context, req *daemon.ListB
}
b := &daemon.BufferInfo{
Pipeline: &is.pipeline.Name,
FromVertex: &edge.From,
ToVertex: &edge.To,
FromVertex: pointer.String(fmt.Sprintf("%v", edge.From)),
ToVertex: pointer.String(fmt.Sprintf("%v", edge.To)),
BufferName: pointer.String(fmt.Sprintf("%v", buffer)),
PendingCount: &bufferInfo.PendingCount,
AckPendingCount: &bufferInfo.AckPendingCount,
Expand Down

0 comments on commit 06a3df2

Please sign in to comment.