Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockResponse ¶
BlockResponse defines response for block operations(recv, flush)
type Config ¶
type Config struct { K int M int BlockSize int // size of each block, used as hint for the flusher buffer size ListenAddr string FlushSize int FlushTime int PrivKey string HexNonce string ConfigPath string // config file path AggMq *aggmq.MQ }
Config used for creating the tlogserver
func DefaultConfig ¶
func DefaultConfig() *Config
DefaultConfig creates a new config, using sane defaults
func (*Config) RequiredDataServers ¶
RequiredDataServers returns how many data servers are required, based on the K and M values.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server defines a tlog server
func NewServer ¶
func NewServer(conf *Config, poolFactory tlog.RedisPoolFactory) (*Server, error)
NewServer creates a new tlog server
func (*Server) ListenAddr ¶
ListenAddr returns the address the (tcp) server is listening on
Click to show internal directories.
Click to hide internal directories.