Versions in this module Expand all Collapse all v1 v1.0.7 Jun 6, 2022 Changes in this version + const PipelineInfoDisable + const PipelineInfoNormal + const TargetTypeElasticsearch + const TargetTypeKafka + const TargetTypeMongodb + const TargetTypeRabbitmq + const TargetTypeRedis + const TargetTypeRocketmq + const TargetTypeScript + var RowRequestPool = sync.Pool + func ReleaseESRespond(t *ESRespond) + func ReleaseMQRespond(t *MQRespond) + func ReleaseMongoRespond(t *MongoRespond) + func ReleaseRedisRespond(t *RedisRespond) + func ReleaseRowRequest(t *RowRequest) + type ESRespond struct + Action string + Date string + Id string + Index string + func BuildESRespond() *ESRespond + type MQRespond struct + Action string + ByteArray []byte + Date interface{} + Raw interface{} + Timestamp uint32 + Topic string + func BuildMQRespond() *MQRespond + type MongoRespond struct + Action string + Collection string + Id interface{} + RuleKey string + Table map[string]interface{} + func BuildMongoRespond() *MongoRespond + type Padding struct + ColumnIndex int + ColumnMetadata *schema.TableColumn + ColumnName string + ColumnType int + WrapName string + type PipelineInfo struct + CreateTime int64 + Id uint64 + Name string + SourceId uint64 + Status uint8 + TargetId uint64 + UpdateTime int64 + type PosRequest struct + Force bool + Name string + Pos uint32 + type RedisRespond struct + Action string + Field string + Key string + OldVal interface{} + Score float64 + Structure string + Val interface{} + func BuildRedisRespond() *RedisRespond + type Replog struct + Context []byte + Id uint64 + Target uint8 + TargetId uint8 + Type uint8 + type RowRequest struct + Action string + Old []interface{} + Row []interface{} + RuleKey string + Timestamp uint32 + func BuildRowRequest() *RowRequest + type TargetInfo struct + AccessKey string + Addr string + Database int + GroupName string + GroupType string + Id uint64 + InstanceName string + MasterName string + Name string + NameServers string + Password string + SASLPassword string + SASLUser string + SecretKey string + Type uint8 + Username string + Version int
Go to main page