diff --git a/internal/client/v1/client/agent/core/client.go b/internal/client/v1/client/agent/core/client.go index c38d36dc3a..3e8227059f 100644 --- a/internal/client/v1/client/agent/core/client.go +++ b/internal/client/v1/client/agent/core/client.go @@ -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( diff --git a/internal/client/v1/client/vald/vald.go b/internal/client/v1/client/vald/vald.go index 4ce7ce6cd1..285a203835 100644 --- a/internal/client/v1/client/vald/vald.go +++ b/internal/client/v1/client/vald/vald.go @@ -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) { @@ -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) {