adapter

package
Version: v0.0.0-...-8928e6c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 5, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL