eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-07-03 11:53:41 +02:00
Code Releases Activity

tools: rename redis prefix flag to just prefix.

Browse source
This commit is contained in:
Henrik Hautakoski 2024-02-02 16:52:31 +01:00
parent 569eefd07a
commit e93cc1d139
4 changed files with 13 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

6
cmd/tools/bench.go
View file

@ -26,7 +26,7 @@ var benchCmd = &cli.Command{
redisUserFlag, redisUserFlag,
redisPasswordFlag, redisPasswordFlag,
redisDbFlag, redisDbFlag,
redisPrefixFlag, prefixFlag,
chainIdFlag, chainIdFlag,
&cli.DurationFlag{ &cli.DurationFlag{
Name: "interval", Name: "interval",
@ -41,7 +41,7 @@ var benchCmd = &cli.Command{
log.WithFields(log.Fields{ log.WithFields(log.Fields{
"url": ctx.String("redis-url"), "url": ctx.String("redis-url"),
"prefix": ctx.String("redis-prefix"), "prefix": ctx.String("prefix"),
"chain_id": ctx.String("chain_id"), "chain_id": ctx.String("chain_id"),
"database": ctx.Int("redis-db"), "database": ctx.Int("redis-db"),
}).Info("Connecting to redis") }).Info("Connecting to redis")
@ -65,7 +65,7 @@ var benchCmd = &cli.Command{
}).Info("Starting benchmark") }).Info("Starting benchmark")
sub := api_redis.NewSubscriber(context.Background(), rdb, api_redis.Namespace{ sub := api_redis.NewSubscriber(context.Background(), rdb, api_redis.Namespace{
Prefix: ctx.String("redis-prefix"), Prefix: ctx.String("prefix"),
ChainID: ctx.String("chain_id"), ChainID: ctx.String("chain_id"),
}) })

10
cmd/tools/flags.go
View file

@ -4,11 +4,6 @@ import (
"github.com/urfave/cli/v2" "github.com/urfave/cli/v2"
) )
var redisPrefixFlag = &cli.StringFlag{
Name: "prefix",
Value: "ship",
}
var redisUrlFlag = &cli.StringFlag{ var redisUrlFlag = &cli.StringFlag{
Name: "redis-url", Name: "redis-url",
Value: "127.0.0.1:6379", Value: "127.0.0.1:6379",
@ -31,6 +26,11 @@ var redisDbFlag = &cli.IntFlag{
Usage: "What redis database we should connect to.", Usage: "What redis database we should connect to.",
} }
var prefixFlag = &cli.StringFlag{
Name: "prefix",
Value: "ship",
}
var chainIdFlag = &cli.StringFlag{ var chainIdFlag = &cli.StringFlag{
Name: "chain_id", Name: "chain_id",
Value: "1064487b3cd1a897ce03ae5b6a865651747e2e152090f99c1d19d44e01aea5a4", Value: "1064487b3cd1a897ce03ae5b6a865651747e2e152090f99c1d19d44e01aea5a4",

4
cmd/tools/mock_publisher.go
View file

@ -23,7 +23,7 @@ var MockPublisherCmd = &cli.Command{
redisUserFlag, redisUserFlag,
redisPasswordFlag, redisPasswordFlag,
redisDbFlag, redisDbFlag,
redisPrefixFlag, prefixFlag,
chainIdFlag, chainIdFlag,
&cli.StringFlag{ &cli.StringFlag{
Name: "codec", Name: "codec",
@ -45,7 +45,7 @@ var MockPublisherCmd = &cli.Command{
} }
ns := api_redis.Namespace{ ns := api_redis.Namespace{
Prefix: ctx.String("redis-prefix"), Prefix: ctx.String("prefix"),
ChainID: ctx.String("chain_id"), ChainID: ctx.String("chain_id"),
} }
publisher := redis_driver.NewPublisher(context.Background(), rdb, ns) publisher := redis_driver.NewPublisher(context.Background(), rdb, ns)

6
cmd/tools/validate.go
View file

@ -55,7 +55,7 @@ var validateCmd = &cli.Command{
Flags: []cli.Flag{ Flags: []cli.Flag{
redisUrlFlag, redisUrlFlag,
redisDbFlag, redisDbFlag,
redisPrefixFlag, prefixFlag,
chainIdFlag, chainIdFlag,
}, },
Action: func(ctx *cli.Context) error { Action: func(ctx *cli.Context) error {
@ -64,7 +64,7 @@ var validateCmd = &cli.Command{
log.WithFields(log.Fields{ log.WithFields(log.Fields{
"url": ctx.String("redis-url"), "url": ctx.String("redis-url"),
"prefix": ctx.String("redis-prefix"), "prefix": ctx.String("prefix"),
"chain_id": ctx.String("chain_id"), "chain_id": ctx.String("chain_id"),
"database": ctx.Int("redis-db"), "database": ctx.Int("redis-db"),
}).Info("Connecting to redis") }).Info("Connecting to redis")
@ -84,7 +84,7 @@ var validateCmd = &cli.Command{
log.Info("Starting validation, following the stream") log.Info("Starting validation, following the stream")
sub := api_redis.NewSubscriber(context.Background(), rdb, api_redis.Namespace{ sub := api_redis.NewSubscriber(context.Background(), rdb, api_redis.Namespace{
Prefix: ctx.String("redis-prefix"), Prefix: ctx.String("prefix"),
ChainID: ctx.String("chain_id"), ChainID: ctx.String("chain_id"),
}) })