Documentation
¶
Index ¶
Constants ¶
View Source
const ( // delay queue configuration DefaultDQBindAddress = ":8000" DefaultDQBucketName = "dq_bucket" DefaultDQQueueName = "dq_queue" DefaultDQBucketSize = 8 DefaultDQBucketMaxFetchNum = 200 DefaultTimerFetchInterval = 10000 // redis configuration DefaultRedisNetwork = "tcp" DefaultRedisAddress = "127.0.0.1:6379" DefaultRedisDialTimeout = 5000 DefaultRedisReadTimeout = 3000 DefaultRedisWriteTimeout = 3000 )
default configurations
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Conf ¶
type Conf struct {
DelayQueue DelayQueue `yaml:"delay_queue,omitempty" json:"delay_queue,omitempty"`
Redis Redis `yaml:"redis,omitempty" json:"redis,omitempty"`
}
Conf configuration
type DelayQueue ¶
type DelayQueue struct {
BindAddress string `yaml:"bind_address,omitempty" json:"bind_address,omitempty"`
BucketName string `yaml:"bucket_name,omitempty" json:"bucket_name,omitempty"`
BucketSize uint64 `yaml:"bucket_size,omitempty" json:"bucket_size,omitempty"`
BucketMaxFetchNum uint64 `yaml:"bucket_max_fetch_num,omitempty" json:"bucket_max_fetch_num,omitempty"`
QueueName string `yaml:"queue_name,omitempty" json:"queue_name,omitempty"`
TimerFetchInterval int `yaml:"timer_fetch_interval,omitempty" json:"timer_fetch_interval,omitempty"`
TimerFetchDelay int `yaml:"timer_fetch_delay,omitempty" json:"timer_fetch_delay,omitempty"`
}
DelayQueue delay queue configuration
type Redis ¶
type Redis struct {
// The network type, either tcp or unix.
// Default is tcp.
Network string `yaml:"network,omitempty" json:"network,omitempty"`
// host:port address.
Address string `yaml:"address,omitempty" json:"address,omitempty"`
// Use the specified username to authenticate the current connection
// with one of the connections defined in the ACL list when connecting
// to a Redis 6.0 instance, or greater, that is using the Redis ACL system.
Username string `yaml:"username,omitempty" json:"username,omitempty"`
// Optional password. Must match the password specified in the
// require pass server configuration option (if connecting to a Redis 5.0 instance, or lower),
// or the User password when connecting to a Redis 6.0 instance, or greater,
// that is using the Redis ACL system.
Password string `yaml:"password,omitempty" json:"password,omitempty"`
// Database to be selected after connecting to the server.
DB int `yaml:"db,omitempty" json:"db,omitempty"`
// Dial timeout for establishing new connections.
// Default is 5 seconds.
DialTimeout int `yaml:"dial_timeout,omitempty" json:"dial_timeout,omitempty"`
// Timeout for socket reads. If reached, commands will fail
// with a timeout instead of blocking. Use value -1 for no timeout and 0 for default.
// Default is 3 seconds.
ReadTimeout int `yaml:"read_timeout,omitempty" json:"read_timeout,omitempty"`
// Timeout for socket writes. If reached, commands will fail
// with a timeout instead of blocking.
// Default is ReadTimeout.
WriteTimeout int `yaml:"write_timeout,omitempty" json:"write_timeout,omitempty"`
// Maximum number of socket connections.
// Default is 10 connections per every CPU as reported by runtime.NumCPU.
PoolSize int `yaml:"pool_size,omitempty" json:"pool_size,omitempty"`
// Minimum number of idle connections which is useful when establishing
// new connection is slow.
MinIdleConns int `yaml:"min_idle_conns,omitempty" json:"min_idle_conns,omitempty"`
}
Redis redis configuration
Click to show internal directories.
Click to hide internal directories.