mirror of
https://github.com/eosswedenorg/thalos
synced 2026-06-16 04:24:56 +02:00
59 lines
2.4 KiB
Go
59 lines
2.4 KiB
Go
package config
|
|
|
|
import (
|
|
"time"
|
|
|
|
shipclient "github.com/eosswedenorg-go/antelope-ship-client"
|
|
"github.com/spf13/pflag"
|
|
)
|
|
|
|
// Get a flag set with all flags mapping to a config value.
|
|
func GetFlags() *pflag.FlagSet {
|
|
flags := pflag.FlagSet{}
|
|
|
|
// Generic
|
|
flags.StringP("url", "u", "", "Url to antelope api")
|
|
flags.String("codec", "json", "Codec used to send messages")
|
|
|
|
// Redis
|
|
flags.String("redis-addr", "127.0.0.1:6379", "host:port to redis server")
|
|
flags.String("redis-user", "", "Redis username")
|
|
flags.String("redis-password", "", "Redis password")
|
|
flags.Int("redis-db", 0, "Redis database")
|
|
flags.String("redis-prefix", "ship", "Redis channel prefix")
|
|
|
|
// Telegram
|
|
flags.String("telegram-id", "", "Id of telegram bot")
|
|
flags.Int64("telegram-channel", 0, "Telegram channel to send notifications to")
|
|
|
|
// Cache
|
|
flags.String("cache", "redis", "What cache driver to use")
|
|
|
|
// AbiCache
|
|
flags.Duration("abi-cache-api-timeout", time.Second, "Duration before the api call times out when the ABI cache requests an abi.")
|
|
|
|
// Log
|
|
flags.StringP("log", "l", "", "Path to log file (default: print to stdout/stderr)")
|
|
flags.String("log-max-filesize", "10mb", "Max filesize for logfile to rotate")
|
|
flags.Duration("log-max-time", time.Hour*24, "Max time for logfile to rotate")
|
|
flags.String("log-file-timestamp", "2006-01-02_150405", "Timestamp format to use when rotating log files")
|
|
|
|
// Ship
|
|
flags.String("ship-url", "ws://127.0.0.1:8080", "Url to ship node")
|
|
flags.Uint32("start-block", shipclient.NULL_BLOCK_NUMBER, "Start to stream from this block")
|
|
flags.Uint32("end-block", shipclient.NULL_BLOCK_NUMBER, "Stop streaming when this block is reached")
|
|
|
|
flags.Lookup("start-block").DefValue = "Config value, cache, head from api"
|
|
flags.Lookup("end-block").DefValue = "none"
|
|
|
|
flags.Bool("table-deltas", true, "True if thalos should receive and process table deltas from ship.")
|
|
|
|
flags.Bool("irreversible-only", false, "Only stream irreversible blocks from ship")
|
|
flags.Int("max-msg-in-flight", 10, "Maximum messages that can be sent from SHIP without acknowledgement")
|
|
flags.String("chain", "", "ChainID used in channel namespace, can be any string (default from api)")
|
|
|
|
flags.StringSlice("blacklist", []string{}, "Define a list of 'contract:action' pairs that will be blacklisted (Thalos will not process those actions)")
|
|
flags.Bool("blacklist-is-whitelist", false, "Thalos will treat the blacklist as a whitelist")
|
|
|
|
return &flags
|
|
}
|