redis

Documentation

Index

• func GetLookupSource() api.Source
• func GetSink() api.Sink
• func RedisPub() api.Sink
• func RedisSub() api.Source
• type RedisSink
  • func (r *RedisSink) Close(ctx api.StreamContext) error
  • func (r *RedisSink) Collect(ctx api.StreamContext, item api.MessageTuple) error
  • func (r *RedisSink) CollectList(ctx api.StreamContext, items api.MessageTupleList) error
  • func (r *RedisSink) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error
  • func (r *RedisSink) Ping(ctx api.StreamContext, props map[string]any) error
  • func (r *RedisSink) Provision(_ api.StreamContext, props map[string]any) error
  • func (r *RedisSink) Validate(props map[string]any) error

Functions

func GetLookupSource

func GetLookupSource() api.Source

func GetSink

func GetSink() api.Sink

func RedisPub

func RedisPub() api.Sink

func RedisSub

func RedisSub() api.Source

Types

type RedisSink

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

func (*RedisSink) Close

func (r *RedisSink) Close(ctx api.StreamContext) error

func (*RedisSink) Collect

func (r *RedisSink) Collect(ctx api.StreamContext, item api.MessageTuple) error

func (*RedisSink) CollectList

func (r *RedisSink) CollectList(ctx api.StreamContext, items api.MessageTupleList) error

func (*RedisSink) Connect

func (r *RedisSink) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error

func (*RedisSink) Ping

func (r *RedisSink) Ping(ctx api.StreamContext, props map[string]any) error

func (*RedisSink) Provision

func (r *RedisSink) Provision(_ api.StreamContext, props map[string]any) error

func (*RedisSink) Validate

func (r *RedisSink) Validate(props map[string]any) error