shardstreams

Documentation

Index

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

Types

type Config

type Config struct {
	Enabled bool `` /* 163-byte string literal not displayed */

	LoggingEnabled bool `` /* 157-byte string literal not displayed */

	// DesiredRate is the threshold used to shard the stream into smaller pieces.
	// Expected to be in bytes.
	DesiredRate flagext.ByteSize `` /* 181-byte string literal not displayed */
}

func (*Config) RegisterFlagsWithPrefix

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