model

type ESRespond struct {
	Index  string
	Id     string
	Action string
	Date   string
}

type MQRespond struct {
	Topic     string      `json:"-"`
	Action    string      `json:"action"`
	Timestamp uint32      `json:"timestamp"`
	Raw       interface{} `json:"raw,omitempty"`
	Date      interface{} `json:"date"`
	ByteArray []byte      `json:"-"`
}

type MongoRespond struct {
	RuleKey    string
	Collection string
	Action     string
	Id         interface{}
	Table      map[string]interface{}
}

type Padding struct {
	WrapName string

	ColumnName     string
	ColumnIndex    int
	ColumnType     int
	ColumnMetadata *schema.TableColumn
}

type PipelineInfo struct {
	Id         uint64
	Name       string
	SourceId   uint64
	TargetId   uint64
	Status     uint8
	CreateTime int64
	UpdateTime int64
}

type PosRequest struct {
	Name  string
	Pos   uint32
	Force bool
}

type RedisRespond struct {
	Action    string
	Structure string
	Key       string
	Field     string
	Score     float64
	OldVal    interface{}
	Val       interface{}
	Exts      map[string]interface{} // 扩展字段，备用
}

type Replog struct {
	Id       uint64
	Type     uint8
	Target   uint8
	TargetId uint8

	Context []byte
	// contains filtered or unexported fields
}

type RowRequest struct {
	RuleKey   string
	Action    string
	Timestamp uint32
	Old       []interface{}
	Row       []interface{}
}

type TargetInfo struct {
	Id       uint64
	Type     uint8
	Name     string
	Addr     string //地址
	Username string //用户名
	Password string //密码

	GroupType  string `yaml:"group_type"`  //集群类型 sentinel或者cluster
	MasterName string `yaml:"master_name"` //Master节点名称
	Database   int    `yaml:"database"`    //数据库

	Version int //版本

	NameServers  string //命名服务地址，多个用逗号分隔
	GroupName    string //group name,默认为空
	InstanceName string //instance name,默认为空
	AccessKey    string //访问控制 accessKey,默认为空
	SecretKey    string //访问控制 secretKey,默认为空

	SASLUser     string `yaml:"sasl_user"`     //SASL_PLAINTEXT认证模式 用户名
	SASLPassword string `yaml:"sasl_password"` //SASL_PLAINTEXT认证模式 密码

}