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"`
	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
	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"`
}