config

Documentation

Index

• Constants
• type CfgLogLevel
  • func (d *CfgLogLevel) UnmarshalText(data []byte) (err error)
• type Config
  • func NewConfig(filename string) (*Config, error)
  • func (c *Config) LoadEnv() *Config
  • func (c *Config) SetDefaults() *Config
• type Etcd
• type EtcdDiscovery
• type EtcdURLs
• type Global
• type Logging
• type SecurityConfig
• type ServingInfo
• type Storage
• type StorageDriver
  • func (s StorageDriver) Name() string
  • func (s StorageDriver) Parameters() storage.StorageDriverParameters
• type Topic

Constants

const (
	AppConfigContextVar = "app.config"
)

Types

type CfgLogLevel

type CfgLogLevel struct {
	logrus.Level
}

func (*CfgLogLevel) UnmarshalText

func (d *CfgLogLevel) UnmarshalText(data []byte) (err error)

type Config

type Config struct {
	Global  Global
	Logging Logging
	Topic   Topic
	Storage Storage
	Etcd    Etcd
}

func NewConfig

func NewConfig(filename string) (*Config, error)

func (*Config) LoadEnv

func (c *Config) LoadEnv() *Config

func (*Config) SetDefaults

func (c *Config) SetDefaults() *Config

SetDefaults applies default values to config structure.

type Etcd

type Etcd struct {
	// NoServer suppresses startup of etcd server
	NoServer bool `yaml:"no-server"`

	// StorageDir indicates where to save the etcd data
	StorageDir string `yaml:"storage-dir"`

	MinConnections int64
	MaxConnections int64

	Name                *string `yaml:"name"`
	InitialCluster      *string `yaml:"initial-cluster"`
	InitialClusterToken *string `yaml:"initial-cluster-token"`
	ClusterState        *string `yaml:"initial-cluster-state"`

	Client ServingInfo `yaml:"client"`
	Peer   ServingInfo `yaml:"peer"`

	AdvertiseClient EtcdURLs `yaml:"advertise-client"`
	AdvertisePeer   EtcdURLs `yaml:"advertise-peer"`

	Discovery EtcdDiscovery `yaml:",inline"`
}

type EtcdDiscovery

type EtcdDiscovery struct {
	DNSCluster *string `yaml:"discovery-srv"`
	Dproxy     *string `yaml:"discovery-proxy"`
	Durl       *string `yaml:"discovery"`
}

type EtcdURLs

type EtcdURLs struct {
	// URLs are the URLs for etcd
	URLs []string
}

type Global

type Global struct {
	// Address is the advertised host:port for client connections
	Address string
	// Logfile specifies logfile location
	Logfile string
	// Hostname specifies the node name
	Hostname string
	// Group specifies the name of the group
	Group string
	// FIXME
	Port int
}

type Logging

type Logging struct {
	Level            CfgLogLevel
	DisableColors    bool
	DisableTimestamp bool
	FullTimestamp    bool
	DisableSorting   bool
}

type SecurityConfig

type SecurityConfig struct {
	CertFile      string `yaml:"cert-file"`
	KeyFile       string `yaml:"key-file"`
	CertAuth      bool   `yaml:"client-cert-auth"`
	TrustedCAFile string `yaml:"trusted-ca-file"`
	AutoTLS       bool   `yaml:"auto-tls"`
}

type ServingInfo

type ServingInfo struct {
	EtcdURLs       `yaml:",inline"`
	SecurityConfig `yaml:",inline"`
}

type Storage

type Storage struct {
	// SyncPool specifies the number of concurrent processes synchronization chunks from other servers.
	SyncPool int
	// Driver
	Driver StorageDriver
	// CleanupPeriod sets time period between cleanup iterations.
	CleanupPeriod time.Duration `yaml:"cleanup-period"`
}

type StorageDriver

type StorageDriver map[string]storage.StorageDriverParameters

func (StorageDriver) Name

func (s StorageDriver) Name() string

func (StorageDriver) Parameters

func (s StorageDriver) Parameters() storage.StorageDriverParameters

type Topic

type Topic struct {
	// AllowTopicsCreation enables auto creation of topic on the server
	AllowTopicsCreation bool `yaml:"allow-topics-creation"`
	// WriteConcern describes the number of groups, which should confirm write of each block.
	// This value should not be more than the number of nodes in the cluster.
	WriteConcern int64 `yaml:"write-concern"`
	// MessageRetentionPeriod defines the maximum time we will retain a message.
	MessageRetentionPeriod time.Duration `yaml:"message-retention-period"`
	// PartitionSize defines maximum partition size.
	MaxPartitionSize int64 `yaml:"max-partition-size"`
	// MaxMessageSize defines maximum size of incoming message. Set 0 to disable.
	MaxMessageSize int64 `yaml:"max-message-size"`
	// ChunkSize defines maximum size of a block on which is divided the incoming message.
	MaxChunkSize int64 `yaml:"max-chunk-size"`
	// CleanupPeriod sets time period between cleanup iterations.
	CleanupPeriod time.Duration `yaml:"cleanup-period"`
}