adapter

Documentation

Index

• type GCPPubSub
  • func NewGCPPubSubAdapter(client *pubsub.Client) *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 NewRedisAdapter(pool *redis.Pool) *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

Types

type GCPPubSub

type GCPPubSub struct {
	// contains filtered or unexported fields
}

func NewGCPPubSubAdapter

func NewGCPPubSubAdapter(client *pubsub.Client) *GCPPubSub

func (*GCPPubSub) Dequeue

func (g *GCPPubSub) Dequeue(channel string) <-chan gopolling.Event

func (*GCPPubSub) Enqueue

func (g *GCPPubSub) Enqueue(_ string, event gopolling.Event)

func (*GCPPubSub) Publish

func (g *GCPPubSub) Publish(_ string, msg gopolling.Message) error

func (*GCPPubSub) SetLog

func (g *GCPPubSub) SetLog(log gopolling.Log)

func (*GCPPubSub) Shutdown

func (g *GCPPubSub) Shutdown()

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) Enqueue

func (r *RedisAdapter) Enqueue(channel string, ev gopolling.Event)

func (*RedisAdapter) Find

func (r *RedisAdapter) Find(key string) (gopolling.Message, bool)

func (*RedisAdapter) Publish

func (r *RedisAdapter) Publish(_ string, msg gopolling.Message) error

func (*RedisAdapter) Save

func (r *RedisAdapter) Save(key string, msg gopolling.Message, t int)

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