redis

type RedisStreamsFactory struct{}

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

type StreamsConfig struct {
	RedisAddr     string        `json:"redis_addr" yaml:"redis_addr"`
	RedisDB       int           `json:"redis_db" yaml:"redis_db"`
	Password      string        `json:"password" yaml:"password"`
	Streams       []string      `json:"streams" yaml:"streams"`
	ConsumerGroup string        `json:"consumer_group" yaml:"consumer_group"`
	ConsumerName  string        `json:"consumer_name" yaml:"consumer_name"`
	BatchSize     int64         `json:"batch_size" yaml:"batch_size"`
	BlockTime     time.Duration `json:"block_time" yaml:"block_time"`
	ClaimMinIdle  time.Duration `json:"claim_min_idle" yaml:"claim_min_idle"`
	ClaimInterval time.Duration `json:"claim_interval" yaml:"claim_interval"`
	SchemaName    string        `json:"schema_name" yaml:"schema_name"`
}