firehose

Documentation

Index

• func Publish(channel, message string) error
• type Publisher
  • func New(client *redis.Client) Publisher
• type RedisClient
  • func (c *RedisClient) Publish(channel, message string) error

Functions

func Publish

func Publish(channel, message string) error

Types

type Publisher

type Publisher interface {
	Publish(string, string) error
}

var DefaultPublisher Publisher

func New

func New(client *redis.Client) Publisher

type RedisClient

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

func (*RedisClient) Publish

func (c *RedisClient) Publish(channel, message string) error