From e93cc1d139791894cd2a4c42426fd40d9fdd0df8 Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Fri, 2 Feb 2024 16:52:31 +0100 Subject: [PATCH] tools: rename redis prefix flag to just prefix. --- cmd/tools/bench.go | 6 +++--- cmd/tools/flags.go | 10 +++++----- cmd/tools/mock_publisher.go | 4 ++-- cmd/tools/validate.go | 6 +++--- 4 files changed, 13 insertions(+), 13 deletions(-) diff --git a/cmd/tools/bench.go b/cmd/tools/bench.go index 5d4dcc2..ae23a55 100644 --- a/cmd/tools/bench.go +++ b/cmd/tools/bench.go @@ -26,7 +26,7 @@ var benchCmd = &cli.Command{ redisUserFlag, redisPasswordFlag, redisDbFlag, - redisPrefixFlag, + prefixFlag, chainIdFlag, &cli.DurationFlag{ Name: "interval", @@ -41,7 +41,7 @@ var benchCmd = &cli.Command{ log.WithFields(log.Fields{ "url": ctx.String("redis-url"), - "prefix": ctx.String("redis-prefix"), + "prefix": ctx.String("prefix"), "chain_id": ctx.String("chain_id"), "database": ctx.Int("redis-db"), }).Info("Connecting to redis") @@ -65,7 +65,7 @@ var benchCmd = &cli.Command{ }).Info("Starting benchmark") sub := api_redis.NewSubscriber(context.Background(), rdb, api_redis.Namespace{ - Prefix: ctx.String("redis-prefix"), + Prefix: ctx.String("prefix"), ChainID: ctx.String("chain_id"), }) diff --git a/cmd/tools/flags.go b/cmd/tools/flags.go index 30c5a94..24c0ee5 100644 --- a/cmd/tools/flags.go +++ b/cmd/tools/flags.go @@ -4,11 +4,6 @@ import ( "github.com/urfave/cli/v2" ) -var redisPrefixFlag = &cli.StringFlag{ - Name: "prefix", - Value: "ship", -} - var redisUrlFlag = &cli.StringFlag{ Name: "redis-url", Value: "127.0.0.1:6379", @@ -31,6 +26,11 @@ var redisDbFlag = &cli.IntFlag{ Usage: "What redis database we should connect to.", } +var prefixFlag = &cli.StringFlag{ + Name: "prefix", + Value: "ship", +} + var chainIdFlag = &cli.StringFlag{ Name: "chain_id", Value: "1064487b3cd1a897ce03ae5b6a865651747e2e152090f99c1d19d44e01aea5a4", diff --git a/cmd/tools/mock_publisher.go b/cmd/tools/mock_publisher.go index 7dcb05d..9920468 100644 --- a/cmd/tools/mock_publisher.go +++ b/cmd/tools/mock_publisher.go @@ -23,7 +23,7 @@ var MockPublisherCmd = &cli.Command{ redisUserFlag, redisPasswordFlag, redisDbFlag, - redisPrefixFlag, + prefixFlag, chainIdFlag, &cli.StringFlag{ Name: "codec", @@ -45,7 +45,7 @@ var MockPublisherCmd = &cli.Command{ } ns := api_redis.Namespace{ - Prefix: ctx.String("redis-prefix"), + Prefix: ctx.String("prefix"), ChainID: ctx.String("chain_id"), } publisher := redis_driver.NewPublisher(context.Background(), rdb, ns) diff --git a/cmd/tools/validate.go b/cmd/tools/validate.go index 1f2aa5b..061e35d 100644 --- a/cmd/tools/validate.go +++ b/cmd/tools/validate.go @@ -55,7 +55,7 @@ var validateCmd = &cli.Command{ Flags: []cli.Flag{ redisUrlFlag, redisDbFlag, - redisPrefixFlag, + prefixFlag, chainIdFlag, }, Action: func(ctx *cli.Context) error { @@ -64,7 +64,7 @@ var validateCmd = &cli.Command{ log.WithFields(log.Fields{ "url": ctx.String("redis-url"), - "prefix": ctx.String("redis-prefix"), + "prefix": ctx.String("prefix"), "chain_id": ctx.String("chain_id"), "database": ctx.Int("redis-db"), }).Info("Connecting to redis") @@ -84,7 +84,7 @@ var validateCmd = &cli.Command{ log.Info("Starting validation, following the stream") sub := api_redis.NewSubscriber(context.Background(), rdb, api_redis.Namespace{ - Prefix: ctx.String("redis-prefix"), + Prefix: ctx.String("prefix"), ChainID: ctx.String("chain_id"), })