source

Documentation

Index

• Constants
• type RedisSourceHandler
  • func NewRedisSourceHandler(baseSource source.BaseSource) *RedisSourceHandler
  • func (r *RedisSourceHandler) CloseSource()
  • func (r *RedisSourceHandler) FetchData()
  • func (r *RedisSourceHandler) InitSource()
  • func (r *RedisSourceHandler) SourceName() string
  • func (r *RedisSourceHandler) SourceTopic() string

Constants

const (
	NilType           = redis.Nil
	RedisPoolSize int = 200 // pool size
	RedisMinIdles int = 100 // min pool idle connection
)

Types

type RedisSourceHandler

type RedisSourceHandler struct {
	source.BaseSource
	// contains filtered or unexported fields
}

func NewRedisSourceHandler

func NewRedisSourceHandler(baseSource source.BaseSource) *RedisSourceHandler

NewRedisSourceHandler initializes a new Redis source handler

func (*RedisSourceHandler) CloseSource

func (r *RedisSourceHandler) CloseSource()

CloseSource closes the Redis source

func (*RedisSourceHandler) FetchData

func (r *RedisSourceHandler) FetchData()

FetchData fetches data from Redis

func (*RedisSourceHandler) InitSource

func (r *RedisSourceHandler) InitSource()

InitSource initializes the Redis source

func (*RedisSourceHandler) SourceName

func (r *RedisSourceHandler) SourceName() string

SourceName returns the name of the Redis source

func (*RedisSourceHandler) SourceTopic

func (r *RedisSourceHandler) SourceTopic() string

SourceTopic returns the topic of the Redis source