Skip to content

Commit 65580d4

Browse files
committed
clickhouse: sort maddrs upon insert
1 parent f29bc22 commit 65580d4

File tree

1 file changed

+14
-4
lines changed

1 file changed

+14
-4
lines changed

db/ch.go

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -598,15 +598,25 @@ func (c *ClickHouseClient) InsertVisit(ctx context.Context, args *VisitArgs) err
598598
args.Properties = json.RawMessage("{}")
599599
}
600600

601+
dialMaddrs := utils.MaddrsToAddrs(args.DialMaddrs)
602+
filteredMaddrs := utils.MaddrsToAddrs(args.FilteredMaddrs)
603+
extraMaddrs := utils.MaddrsToAddrs(args.ExtraMaddrs)
604+
listenMaddrs := utils.MaddrsToAddrs(args.ListenMaddrs)
605+
606+
sort.Strings(dialMaddrs)
607+
sort.Strings(filteredMaddrs)
608+
sort.Strings(extraMaddrs)
609+
sort.Strings(listenMaddrs)
610+
601611
visit := &ClickHouseVisit{
602612
CrawlID: crawlID,
603613
PeerID: args.PeerID.String(),
604614
AgentVersion: av,
605615
Protocols: args.Protocols,
606-
DialMaddrs: utils.MaddrsToAddrs(args.DialMaddrs),
607-
FilteredMaddrs: utils.MaddrsToAddrs(args.FilteredMaddrs),
608-
ExtraMaddrs: utils.MaddrsToAddrs(args.ExtraMaddrs),
609-
ListenMaddrs: utils.MaddrsToAddrs(args.ListenMaddrs),
616+
DialMaddrs: dialMaddrs,
617+
FilteredMaddrs: filteredMaddrs,
618+
ExtraMaddrs: extraMaddrs,
619+
ListenMaddrs: listenMaddrs,
610620
ConnectMaddr: connMaddrStr,
611621
DialErrors: args.DialErrors,
612622
CrawlError: crawlErrStr,

0 commit comments

Comments
 (0)