redis

Documentation

Overview

Package redis implements the Redis Pub/Sub connector.

Index

• type RedisSink
  • func NewRedisSink(config *redis.Options, channel string) *RedisSink
  • func (rs *RedisSink) In() chan<- any
• type RedisSource
  • func NewRedisSource(ctx context.Context, config *redis.Options, channel string) (*RedisSource, error)
  • func (rs *RedisSource) Out() <-chan any
  • func (rs *RedisSource) Via(_flow streams.Flow) streams.Flow

Types

type RedisSink

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

RedisSink represents a Redis Pub/Sub sink connector.

func NewRedisSink

func NewRedisSink(config *redis.Options, channel string) *RedisSink

NewRedisSink returns a new RedisSink instance.

func (*RedisSink) In

func (rs *RedisSink) In() chan<- any

In returns an input channel for receiving data.

type RedisSource

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

RedisSource represents a Redis Pub/Sub source connector.

func NewRedisSource

func NewRedisSource(ctx context.Context, config *redis.Options, channel string) (*RedisSource, error)

NewRedisSource returns a new RedisSource instance.

func (*RedisSource) Out

func (rs *RedisSource) Out() <-chan any

Out returns an output channel for sending data.

func (*RedisSource) Via

func (rs *RedisSource) Via(_flow streams.Flow) streams.Flow

Via streams data through the given flow.