Documentation
¶
Index ¶
- type Config
- type Driver
- func (p *Driver) Connections(topic string, res map[string]struct{})
- func (p *Driver) Next(ctx context.Context) (*pubsub.Message, error)
- func (p *Driver) Publish(msg *pubsub.Message) error
- func (p *Driver) PublishAsync(msg *pubsub.Message)
- func (p *Driver) Stop()
- func (p *Driver) Subscribe(connectionID string, topics ...string) error
- func (p *Driver) Unsubscribe(connectionID string, topics ...string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Addrs []string `mapstructure:"addrs"`
DB int `mapstructure:"db"`
Username string `mapstructure:"username"`
Password string `mapstructure:"password"`
MasterName string `mapstructure:"master_name"`
SentinelPassword string `mapstructure:"sentinel_password"`
RouteByLatency bool `mapstructure:"route_by_latency"`
RouteRandomly bool `mapstructure:"route_randomly"`
MaxRetries int `mapstructure:"max_retries"`
DialTimeout time.Duration `mapstructure:"dial_timeout"`
MinRetryBackoff time.Duration `mapstructure:"min_retry_backoff"`
MaxRetryBackoff time.Duration `mapstructure:"max_retry_backoff"`
PoolSize int `mapstructure:"pool_size"`
MinIdleConns int `mapstructure:"min_idle_conns"`
MaxConnAge time.Duration `mapstructure:"max_conn_age"`
ReadTimeout time.Duration `mapstructure:"read_timeout"`
WriteTimeout time.Duration `mapstructure:"write_timeout"`
PoolTimeout time.Duration `mapstructure:"pool_timeout"`
IdleTimeout time.Duration `mapstructure:"idle_timeout"`
IdleCheckFreq time.Duration `mapstructure:"idle_check_freq"`
ReadOnly bool `mapstructure:"read_only"`
}
func (*Config) InitDefaults ¶
func (s *Config) InitDefaults()
InitDefaults initializing fill config with default values
type Driver ¶
func NewPubSubDriver ¶
func (*Driver) Connections ¶
func (*Driver) PublishAsync ¶
Click to show internal directories.
Click to hide internal directories.