package cn.iocoder.yudao.module.iot.dal.dataobject.rule.config;
|
|
import cn.iocoder.yudao.framework.common.validation.InEnum;
|
import cn.iocoder.yudao.module.iot.enums.rule.IotRedisDataStructureEnum;
|
import lombok.Data;
|
|
/**
|
* IoT Redis 配置 {@link IotAbstractDataSinkConfig} 实现类
|
*
|
* @author HUIHUI
|
*/
|
@Data
|
public class IotDataSinkRedisConfig extends IotAbstractDataSinkConfig {
|
|
/**
|
* Redis 服务器地址
|
*/
|
private String host;
|
/**
|
* 端口
|
*/
|
private Integer port;
|
/**
|
* 密码
|
*/
|
private String password;
|
/**
|
* 数据库索引
|
*/
|
private Integer database;
|
|
/**
|
* Redis 数据结构类型
|
* <p>
|
* 枚举 {@link IotRedisDataStructureEnum}
|
*/
|
@InEnum(IotRedisDataStructureEnum.class)
|
private Integer dataStructure;
|
|
/**
|
* 主题/键名
|
* <p>
|
* 对于不同的数据结构：
|
* - Stream: 流的键名
|
* - Hash: Hash 的键名
|
* - List: 列表的键名
|
* - Set: 集合的键名
|
* - ZSet: 有序集合的键名
|
* - String: 字符串的键名
|
*/
|
private String topic;
|
|
/**
|
* Hash 字段名（仅当 dataStructure 为 HASH 时使用）
|
*/
|
private String hashField;
|
|
/**
|
* ZSet 分数字段（仅当 dataStructure 为 ZSET 时使用）
|
* 指定消息中哪个字段作为分数，如果不指定则使用当前时间戳
|
*/
|
private String scoreField;
|
|
}
|
