slight refactor

Author: htemelski-redis

command_policy_resolver.go

@@ -118,17 +118,17 @@ var defaultPolicies = map[module]map[commandName]*routing.CommandPolicy{
 }
 
 type CommandInfoResolver interface {
-	getCommandPolicy(ctx context.Context, cmdName string) *routing.CommandPolicy
-	setFallbackResolver(fallback CommandInfoResolver)
+	GetCommandPolicy(ctx context.Context, cmdName string) *routing.CommandPolicy
+	SetFallbackResolver(fallback CommandInfoResolver)
 }
 
-type resolver struct {
+type internalCommandInfoResolver struct {
 	resolve          func(ctx context.Context, cmdName string) *routing.CommandPolicy
 	fallBackResolver CommandInfoResolver
 }
 
-func NewDefaultCommandPolicyResolver() *resolver {
-	return &resolver{
+func NewDefaultCommandPolicyResolver() *internalCommandInfoResolver {
+	return &internalCommandInfoResolver{
 		resolve: func(ctx context.Context, cmdName string) *routing.CommandPolicy {
 			module := "core"
 			command := cmdName
@@ -147,19 +147,19 @@ func NewDefaultCommandPolicyResolver() *resolver {
 	}
 }
 
-func (r *resolver) getCommandPolicy(ctx context.Context, cmdName string) *routing.CommandPolicy {
+func (r *internalCommandInfoResolver) GetCommandPolicy(ctx context.Context, cmdName string) *routing.CommandPolicy {
 	policy := r.resolve(ctx, cmdName)
 	if policy != nil {
 		return policy
 	}
 
 	if r.fallBackResolver != nil {
-		return r.fallBackResolver.getCommandPolicy(ctx, cmdName)
+		return r.fallBackResolver.GetCommandPolicy(ctx, cmdName)
 	}
 
 	return nil
 }
 
-func (r *resolver) setFallbackResolver(fallbackResolver CommandInfoResolver) {
+func (r *internalCommandInfoResolver) SetFallbackResolver(fallbackResolver CommandInfoResolver) {
 	r.fallBackResolver = fallbackResolver
 }

osscluster.go

@@ -1998,7 +1998,7 @@ func (c *ClusterClient) extractCommandInfo(ctx context.Context, cmdName string)
 }
 
 func (c *ClusterClient) NewDynamicResolver() CommandInfoResolver {
-	return &resolver{
+	return &internalCommandInfoResolver{
 		resolve: c.extractCommandInfo,
 	}
 }

osscluster_router.go

@@ -21,7 +21,7 @@ type slotResult struct {
 
 // routeAndRun routes a command to the appropriate cluster nodes and executes it
 func (c *ClusterClient) routeAndRun(ctx context.Context, cmd Cmder, node *clusterNode) error {
-	policy := c.cmdInfoResolver.getCommandPolicy(ctx, cmd.Name())
+	policy := c.cmdInfoResolver.GetCommandPolicy(ctx, cmd.Name())
 	if policy == nil {
 		return c.executeDefault(ctx, cmd, node)
 	}