configuration

Documentation

Index

• Constants
• type AdminConfig
• type ApiConfig
• type ClusterConfig
• type Configuration
  • func LoadConfiguration(fileName string) *Configuration
  • func (self *Configuration) AdminHttpPortString() string
  • func (self *Configuration) ApiHttpPortString() string
  • func (self *Configuration) ApiHttpSslPortString() string
  • func (self *Configuration) GraphitePortString() string
  • func (self *Configuration) HostnameOrDetect() string
  • func (self *Configuration) ProtobufConnectionString() string
  • func (self *Configuration) ProtobufPortString() string
• type GraphiteConfig
• type InputPlugins
• type LevelDbConfiguration
• type LoggingConfig
• type RaftConfig
• type ShardConfiguration
  • func (self *ShardConfiguration) HasRandomSplit() bool
  • func (self *ShardConfiguration) ParseAndValidate(defaultShardDuration time.Duration) error
  • func (self *ShardConfiguration) ParsedDuration() *time.Duration
  • func (self *ShardConfiguration) SplitRegex() *regexp.Regexp
• type ShardingDefinition
• type StorageConfig
• type TomlConfiguration
• type WalConfig

Constants

const (
	ONE_MEGABYTE = 1024 * 1024
	ONE_GIGABYTE = 1024 * ONE_MEGABYTE
)

Types

type AdminConfig

type AdminConfig struct {
	Port   int
	Assets string
}

type ApiConfig

type ApiConfig struct {
	SslPort     int    `toml:"ssl-port"`
	SslCertPath string `toml:"ssl-cert"`
	Port        int
	ReadTimeout duration `toml:"read-timeout"`
}

type ClusterConfig

type ClusterConfig struct {
	SeedServers               []string `toml:"seed-servers"`
	ProtobufPort              int      `toml:"protobuf_port"`
	ProtobufTimeout           duration `toml:"protobuf_timeout"`
	ProtobufHeartbeatInterval duration `toml:"protobuf_heartbeat"`
	MinBackoff                duration `toml:"protobuf_min_backoff"`
	MaxBackoff                duration `toml:"protobuf_max_backoff"`
	WriteBufferSize           int      `toml:"write-buffer-size"`
	ConcurrentShardQueryLimit int      `toml:"concurrent-shard-query-limit"`
	MaxResponseBufferSize     int      `toml:"max-response-buffer-size"`
}

type Configuration

type Configuration struct {
	AdminHttpPort                int
	AdminAssetsDir               string
	ApiHttpSslPort               int
	ApiHttpCertPath              string
	ApiHttpPort                  int
	ApiReadTimeout               time.Duration
	GraphiteEnabled              bool
	GraphitePort                 int
	GraphiteDatabase             string
	RaftServerPort               int
	RaftTimeout                  duration
	SeedServers                  []string
	DataDir                      string
	RaftDir                      string
	ProtobufPort                 int
	ProtobufTimeout              duration
	ProtobufHeartbeatInterval    duration
	ProtobufMinBackoff           duration
	ProtobufMaxBackoff           duration
	Hostname                     string
	LogFile                      string
	LogLevel                     string
	BindAddress                  string
	LevelDbMaxOpenFiles          int
	LevelDbLruCacheSize          int
	LevelDbMaxOpenShards         int
	LevelDbPointBatchSize        int
	ShortTermShard               *ShardConfiguration
	LongTermShard                *ShardConfiguration
	ReplicationFactor            int
	WalDir                       string
	WalFlushAfterRequests        int
	WalBookmarkAfterRequests     int
	WalIndexAfterRequests        int
	WalRequestsPerLogFile        int
	LocalStoreWriteBufferSize    int
	PerServerWriteBufferSize     int
	ClusterMaxResponseBufferSize int
	ConcurrentShardQueryLimit    int
}

func LoadConfiguration

func LoadConfiguration(fileName string) *Configuration

func (*Configuration) AdminHttpPortString

func (self *Configuration) AdminHttpPortString() string

func (*Configuration) ApiHttpPortString

func (self *Configuration) ApiHttpPortString() string

func (*Configuration) ApiHttpSslPortString

func (self *Configuration) ApiHttpSslPortString() string

func (*Configuration) GraphitePortString

func (self *Configuration) GraphitePortString() string

func (*Configuration) HostnameOrDetect

func (self *Configuration) HostnameOrDetect() string

func (*Configuration) ProtobufConnectionString

func (self *Configuration) ProtobufConnectionString() string

func (*Configuration) ProtobufPortString

func (self *Configuration) ProtobufPortString() string

type GraphiteConfig

type GraphiteConfig struct {
	Enabled  bool
	Port     int
	Database string
}

type InputPlugins

type InputPlugins struct {
	Graphite GraphiteConfig `toml:"graphite"`
}

type LevelDbConfiguration

type LevelDbConfiguration struct {
	MaxOpenFiles   int  `toml:"max-open-files"`
	LruCacheSize   size `toml:"lru-cache-size"`
	MaxOpenShards  int  `toml:"max-open-shards"`
	PointBatchSize int  `toml:"point-batch-size"`
}

type LoggingConfig

type LoggingConfig struct {
	File  string
	Level string
}

type RaftConfig

type RaftConfig struct {
	Port    int
	Dir     string
	Timeout duration `toml:"election-timeout"`
}

type ShardConfiguration

type ShardConfiguration struct {
	Duration string

	Split       int
	SplitRandom string `toml:"split-random"`
	// contains filtered or unexported fields
}

func (*ShardConfiguration) HasRandomSplit

func (self *ShardConfiguration) HasRandomSplit() bool

func (*ShardConfiguration) ParseAndValidate

func (self *ShardConfiguration) ParseAndValidate(defaultShardDuration time.Duration) error

func (*ShardConfiguration) ParsedDuration

func (self *ShardConfiguration) ParsedDuration() *time.Duration

func (*ShardConfiguration) SplitRegex

func (self *ShardConfiguration) SplitRegex() *regexp.Regexp

type ShardingDefinition

type ShardingDefinition struct {
	ReplicationFactor int                `toml:"replication-factor"`
	ShortTerm         ShardConfiguration `toml:"short-term"`
	LongTerm          ShardConfiguration `toml:"long-term"`
}

type StorageConfig

type StorageConfig struct {
	Dir             string
	WriteBufferSize int `toml:"write-buffer-size"`
}

type TomlConfiguration

type TomlConfiguration struct {
	Admin        AdminConfig
	HttpApi      ApiConfig    `toml:"api"`
	InputPlugins InputPlugins `toml:"input_plugins"`
	Raft         RaftConfig
	Storage      StorageConfig
	Cluster      ClusterConfig
	Logging      LoggingConfig
	LevelDb      LevelDbConfiguration
	Hostname     string
	BindAddress  string             `toml:"bind-address"`
	Sharding     ShardingDefinition `toml:"sharding"`
	WalConfig    WalConfig          `toml:"wal"`
}

type WalConfig

type WalConfig struct {
	Dir                   string `toml:"dir"`
	FlushAfterRequests    int    `toml:"flush-after"`
	BookmarkAfterRequests int    `toml:"bookmark-after"`
	IndexAfterRequests    int    `toml:"index-after"`
	RequestsPerLogFile    int    `toml:"requests-per-log-file"`
}