Skip to content

Commit 5315fb4

Browse files
removed leftover prints
1 parent 5ec62b6 commit 5315fb4

File tree

3 files changed

+0
-6
lines changed

3 files changed

+0
-6
lines changed

internal/routing/policy.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,5 @@ func (p *CommandPolicy) CanBeUsedInPipeline() bool {
140140

141141
func (p *CommandPolicy) IsReadOnly() bool {
142142
_, readOnly := p.Tips[ReadOnlyCMD]
143-
fmt.Println(readOnly)
144143
return readOnly
145144
}

osscluster_router.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -50,10 +50,7 @@ func (c *ClusterClient) executeDefault(ctx context.Context, cmd Cmder, policy *r
5050
return node.Client.Process(ctx, cmd)
5151
}
5252
if policy != nil {
53-
54-
fmt.Println(policy.Tips)
5553
if c.readOnlyEnabled() && policy.IsReadOnly() {
56-
fmt.Println("will execute on arbitrary node")
5754
return c.executeOnArbitraryNode(ctx, cmd)
5855
}
5956
}

osscluster_test.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@ import (
66
"errors"
77
"fmt"
88
"net"
9-
"reflect"
109
"slices"
1110
"strconv"
1211
"strings"
@@ -1602,7 +1601,6 @@ var _ = Describe("ClusterClient timeout", func() {
16021601
return nil
16031602
})
16041603
Expect(err).To(HaveOccurred())
1605-
fmt.Println("qko greshki male", reflect.TypeOf(err).String(), reflect.TypeOf(err).Kind().String())
16061604
Expect(err.(net.Error).Timeout()).To(BeTrue())
16071605
})
16081606

0 commit comments

Comments
 (0)