redis

Documentation

Index

• func New(ctx context.Context, config *Options) (receiver.Receiver, error)
• type Options
• type Redis
  • func (r *Redis) In(data interface{})

Functions

func New

func New(ctx context.Context, config *Options) (receiver.Receiver, error)

New creates redis receiver

Types

type Options

type Options struct {
	ClientOptions *redis.Options
	Channel       string
}

Options defines initialization options for redis receiver

type Redis

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

Redis defines redis receiver channel

func (*Redis) In

func (r *Redis) In(data interface{})

In provides sending data to the channel