publishredis

Documentation

Index

• type PublishRedis
  • func New(logger ytfeed.Logger, channel string, opts *redis.Options) (pr *PublishRedis)
  • func (p *PublishRedis) DataHandler(ctx context.Context, d *ytfeed.Data)
• type RedisPublisher

Types

type PublishRedis

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

func New

func New(logger ytfeed.Logger, channel string, opts *redis.Options) (pr *PublishRedis)

func (*PublishRedis) DataHandler

func (p *PublishRedis) DataHandler(ctx context.Context, d *ytfeed.Data)

type RedisPublisher

type RedisPublisher interface {
	Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd
}