Documentation ¶
Index ¶
- type GCPPubSub
- func (g *GCPPubSub) Dequeue(channel string) <-chan gopolling.Event
- func (g *GCPPubSub) Enqueue(_ string, event gopolling.Event)
- func (g *GCPPubSub) Publish(_ string, msg gopolling.Message) error
- func (g *GCPPubSub) SetLog(log gopolling.Log)
- func (g *GCPPubSub) Shutdown()
- func (g *GCPPubSub) Subscribe(channel string) (gopolling.Subscription, error)
- func (g *GCPPubSub) Unsubscribe(sub gopolling.Subscription) error
- type RedisAdapter
- func (r *RedisAdapter) Dequeue(channel string) <-chan gopolling.Event
- func (r *RedisAdapter) Enqueue(channel string, ev gopolling.Event)
- func (r *RedisAdapter) Find(key string) (gopolling.Message, bool)
- func (r *RedisAdapter) Publish(_ string, msg gopolling.Message) error
- func (r *RedisAdapter) Save(key string, msg gopolling.Message, t int)
- func (r *RedisAdapter) SetLog(l gopolling.Log)
- func (r *RedisAdapter) Subscribe(channel string) (gopolling.Subscription, error)
- func (r *RedisAdapter) Unsubscribe(sub gopolling.Subscription) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GCPPubSub ¶
type GCPPubSub struct {
// contains filtered or unexported fields
}
func NewGCPPubSubAdapter ¶
func (*GCPPubSub) Subscribe ¶
func (g *GCPPubSub) Subscribe(channel string) (gopolling.Subscription, error)
func (*GCPPubSub) Unsubscribe ¶
func (g *GCPPubSub) Unsubscribe(sub gopolling.Subscription) error
type RedisAdapter ¶
type RedisAdapter struct {
// contains filtered or unexported fields
}
func NewRedisAdapter ¶
func NewRedisAdapter(pool *redis.Pool) *RedisAdapter
func (*RedisAdapter) Dequeue ¶
func (r *RedisAdapter) Dequeue(channel string) <-chan gopolling.Event
func (*RedisAdapter) Publish ¶
func (r *RedisAdapter) Publish(_ string, msg gopolling.Message) error
func (*RedisAdapter) SetLog ¶
func (r *RedisAdapter) SetLog(l gopolling.Log)
func (*RedisAdapter) Subscribe ¶
func (r *RedisAdapter) Subscribe(channel string) (gopolling.Subscription, error)
func (*RedisAdapter) Unsubscribe ¶
func (r *RedisAdapter) Unsubscribe(sub gopolling.Subscription) error
Click to show internal directories.
Click to hide internal directories.