publish

Documentation

Index

• type Publisher
• type RedisPublish
  • func NewRedisPublish(connString string) (r *RedisPublish, err error)
  • func (r *RedisPublish) Publish(ctx context.Context, topic string, data string) error

Types

type Publisher

type Publisher interface {
	Publish(ctx context.Context, topic string, data string) error
}

type RedisPublish

type RedisPublish struct {
	DB *redis.Client
}

func NewRedisPublish

func NewRedisPublish(connString string) (r *RedisPublish, err error)

func (*RedisPublish) Publish

func (r *RedisPublish) Publish(ctx context.Context, topic string, data string) error