Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
Signed-off-by: kpango <kpango@vdaas.org>
  • Loading branch information
kpango committed May 25, 2021
1 parent d54a653 commit e8cea2e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
3 changes: 2 additions & 1 deletion internal/client/v1/client/agent/core/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,8 @@ func NewAgentClient(cc *grpc.ClientConn) interface {
} {
return &singleAgentClient{
Client: vald.NewValdClient(cc),
ac: agent.NewAgentClient(cc)}
ac: agent.NewAgentClient(cc),
}
}

func (c *agentClient) CreateIndex(
Expand Down
2 changes: 0 additions & 2 deletions internal/client/v1/client/vald/vald.go
Original file line number Diff line number Diff line change
Expand Up @@ -640,7 +640,6 @@ func (c *singleClient) StreamUpsert(ctx context.Context, opts ...grpc.CallOption
}
}()
return c.vc.StreamUpsert(ctx, opts...)

}

func (c *singleClient) MultiUpsert(ctx context.Context, in *payload.Upsert_MultiRequest, opts ...grpc.CallOption) (res *payload.Object_Locations, err error) {
Expand Down Expand Up @@ -671,7 +670,6 @@ func (c *singleClient) StreamRemove(ctx context.Context, opts ...grpc.CallOption
}
}()
return c.vc.StreamRemove(ctx, opts...)

}

func (c *singleClient) MultiRemove(ctx context.Context, in *payload.Remove_MultiRequest, opts ...grpc.CallOption) (res *payload.Object_Locations, err error) {
Expand Down

0 comments on commit e8cea2e

Please sign in to comment.