shardstreams

Documentation

Index

• type Config
  • func (cfg *Config) RegisterFlagsWithPrefix(prefix string, fs *flag.FlagSet)

Types

type Config

type Config struct {
	Enabled        bool `yaml:"enabled" json:"enabled"`
	LoggingEnabled bool `yaml:"logging_enabled" json:"logging_enabled"`

	// DesiredRate is the threshold used to shard the stream into smaller pieces.
	// Expected to be in bytes.
	DesiredRate flagext.ByteSize `yaml:"desired_rate" json:"desired_rate"`
}

func (*Config) RegisterFlagsWithPrefix

func (cfg *Config) RegisterFlagsWithPrefix(prefix string, fs *flag.FlagSet)