fix

TarsCloud · Jun 17, 2023 · 8ad86ac · 8ad86ac
1 parent ad6f1ee
commit 8ad86ac
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/tars/registry/registry.go b/tars/registry/registry.go
@@ -25,5 +25,5 @@ type Registrar interface {
 	Deregister(ctx context.Context, servant *ServantInstance) error
 	// QueryServant service discovery
 	QueryServant(ctx context.Context, id string) (activeEp []endpointf.EndpointF, inactiveEp []endpointf.EndpointF, err error)
-	QueryServantBySet(ctx context.Context, id, setId string) (activeEp []endpointf.EndpointF, inactiveEp []endpointf.EndpointF, err error)
+	QueryServantBySet(ctx context.Context, id, set string) (activeEp []endpointf.EndpointF, inactiveEp []endpointf.EndpointF, err error)
 }
diff --git a/tars/registry/tars/registry.go b/tars/registry/tars/registry.go
@@ -36,13 +36,13 @@ func (t *tarsRegistry) QueryServant(ctx context.Context, id string) (activeEp []
 	return activeEp, inactiveEp, nil
 }
 
-func (t *tarsRegistry) QueryServantBySet(ctx context.Context, id, setId string) (activeEp []endpointf.EndpointF, inactiveEp []endpointf.EndpointF, err error) {
-	ret, err := t.query.FindObjectByIdInSameSetWithContext(ctx, id, setId, &activeEp, &inactiveEp)
+func (t *tarsRegistry) QueryServantBySet(ctx context.Context, id, set string) (activeEp []endpointf.EndpointF, inactiveEp []endpointf.EndpointF, err error) {
+	ret, err := t.query.FindObjectByIdInSameSetWithContext(ctx, id, set, &activeEp, &inactiveEp)
 	if err != nil {
 		return nil, nil, err
 	}
 	if ret != 0 {
-		return nil, nil, fmt.Errorf("QueryServantBySet id: %s, setId: %s fail, ret: %d", id, setId, ret)
+		return nil, nil, fmt.Errorf("QueryServantBySet id: %s, setId: %s fail, ret: %d", id, set, ret)
 	}
 	return activeEp, inactiveEp, nil
 }