Fix #576. Don't set timestamp or sequence numbers when listing cq
parent
67c30bc63f
commit
1f7fd3129c
|
@ -12,7 +12,6 @@ import (
|
||||||
"regexp"
|
"regexp"
|
||||||
"strings"
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
|
||||||
|
|
||||||
log "code.google.com/p/log4go"
|
log "code.google.com/p/log4go"
|
||||||
)
|
)
|
||||||
|
@ -733,15 +732,11 @@ func (self *CoordinatorImpl) ListContinuousQueries(user common.User, db string)
|
||||||
for _, query := range queries {
|
for _, query := range queries {
|
||||||
queryId := int64(query.Id)
|
queryId := int64(query.Id)
|
||||||
queryString := query.Query
|
queryString := query.Query
|
||||||
timestamp := time.Now().Unix()
|
|
||||||
sequenceNumber := uint64(1)
|
|
||||||
points = append(points, &protocol.Point{
|
points = append(points, &protocol.Point{
|
||||||
Values: []*protocol.FieldValue{
|
Values: []*protocol.FieldValue{
|
||||||
&protocol.FieldValue{Int64Value: &queryId},
|
&protocol.FieldValue{Int64Value: &queryId},
|
||||||
&protocol.FieldValue{StringValue: &queryString},
|
&protocol.FieldValue{StringValue: &queryString},
|
||||||
},
|
},
|
||||||
Timestamp: ×tamp,
|
|
||||||
SequenceNumber: &sequenceNumber,
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
seriesName := "continuous queries"
|
seriesName := "continuous queries"
|
||||||
|
|
Loading…
Reference in New Issue