Documentation
¶
Index ¶
- Constants
- type AdminConfig
- type ApiConfig
- type ClusterConfig
- type 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
- type ShardingDefinition
- type StorageConfig
- type TomlConfiguration
- type WalConfig
Constants ¶
View Source
const ( ONE_MEGABYTE = 1024 * 1024 ONE_GIGABYTE = 1024 * ONE_MEGABYTE )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AdminConfig ¶ added in v0.4.0
type ClusterConfig ¶ added in v0.4.0
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 ¶ added in v0.4.1
func (self *Configuration) ApiHttpSslPortString() string
func (*Configuration) GraphitePortString ¶ added in v0.5.0
func (self *Configuration) GraphitePortString() string
func (*Configuration) HostnameOrDetect ¶ added in v0.4.0
func (self *Configuration) HostnameOrDetect() string
func (*Configuration) ProtobufConnectionString ¶ added in v0.4.0
func (self *Configuration) ProtobufConnectionString() string
func (*Configuration) ProtobufPortString ¶ added in v0.4.0
func (self *Configuration) ProtobufPortString() string
type GraphiteConfig ¶ added in v0.5.0
type InputPlugins ¶ added in v0.5.0
type InputPlugins struct {
Graphite GraphiteConfig `toml:"graphite"`
}
type LevelDbConfiguration ¶ added in v0.4.4
type LoggingConfig ¶ added in v0.4.0
type RaftConfig ¶ added in v0.4.0
type ShardConfiguration ¶ added in v0.5.0
type ShardConfiguration struct {
Duration string
Split int
SplitRandom string `toml:"split-random"`
// contains filtered or unexported fields
}
func (*ShardConfiguration) HasRandomSplit ¶ added in v0.5.0
func (self *ShardConfiguration) HasRandomSplit() bool
func (*ShardConfiguration) ParseAndValidate ¶ added in v0.5.0
func (self *ShardConfiguration) ParseAndValidate(defaultShardDuration time.Duration) error
func (*ShardConfiguration) ParsedDuration ¶ added in v0.5.0
func (self *ShardConfiguration) ParsedDuration() *time.Duration
func (*ShardConfiguration) SplitRegex ¶ added in v0.5.0
func (self *ShardConfiguration) SplitRegex() *regexp.Regexp
type ShardingDefinition ¶ added in v0.5.0
type ShardingDefinition struct {
ReplicationFactor int `toml:"replication-factor"`
ShortTerm ShardConfiguration `toml:"short-term"`
LongTerm ShardConfiguration `toml:"long-term"`
}
type StorageConfig ¶ added in v0.4.0
type TomlConfiguration ¶ added in v0.4.0
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"`
}
Click to show internal directories.
Click to hide internal directories.