redis

Documentation

Index

• func GetLookupSource() api.LookupSource
• func GetSink() api.Sink
• type RedisSink
  • func (r *RedisSink) Close(ctx api.StreamContext) error
  • func (r *RedisSink) Collect(ctx api.StreamContext, data interface{}) error
  • func (r *RedisSink) Configure(props map[string]interface{}) error
  • func (r *RedisSink) Open(ctx api.StreamContext) (err error)
  • func (r *RedisSink) Ping(dataSource string, props map[string]interface{}) error
  • func (r *RedisSink) Validate(props map[string]interface{}) error

Functions

func GetLookupSource

func GetLookupSource() api.LookupSource

func GetSink

func GetSink() api.Sink

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, data interface{}) error

func (*RedisSink) Configure

func (r *RedisSink) Configure(props map[string]interface{}) error

func (*RedisSink) Open

func (r *RedisSink) Open(ctx api.StreamContext) (err error)

func (*RedisSink) Ping

func (r *RedisSink) Ping(dataSource string, props map[string]interface{}) error

func (*RedisSink) Validate

func (r *RedisSink) Validate(props map[string]interface{}) error