Documentation
¶
Index ¶
- Constants
- type ReconnectMutex
- type TTLHashSet
- func (t *TTLHashSet) Close() error
- func (t *TTLHashSet) Exists(key string) (bool, error)
- func (t *TTLHashSet) Get(key string) (int, error)
- func (t *TTLHashSet) Incr(key string) error
- func (t *TTLHashSet) Ping() (string, error)
- func (t *TTLHashSet) Reconnect()
- func (t *TTLHashSet) Set(key string, val int) error
- func (t *TTLHashSet) TTL(key string) (int, error)
Constants ¶
View Source
const WaitBetweenReconnect = 2 * time.Second
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReconnectMutex ¶
type ReconnectMutex struct {
// contains filtered or unexported fields
}
func (*ReconnectMutex) Check ¶
func (r *ReconnectMutex) Check() bool
func (*ReconnectMutex) Update ¶
func (r *ReconnectMutex) Update(state bool)
type TTLHashSet ¶
type TTLHashSet struct {
// contains filtered or unexported fields
}
func NewTTLHashSet ¶
func (*TTLHashSet) Close ¶
func (t *TTLHashSet) Close() error
func (*TTLHashSet) Incr ¶
func (t *TTLHashSet) Incr(key string) error
func (*TTLHashSet) Ping ¶
func (t *TTLHashSet) Ping() (string, error)
Ping sends a PING command to the underlying Redis service. This can be used to healthcheck any Redis servers we're connected to.
func (*TTLHashSet) Reconnect ¶
func (t *TTLHashSet) Reconnect()
Reconnect asynchronously initiates a new connection to the server if there's not already one in progress. Other operations will continue to return errors until this has succeeded.
Source Files
Click to show internal directories.
Click to hide internal directories.