Skip to content

Commit d7609b4

Browse files
committed
Fix review issues
Signed-off-by: Kemal Akkoyun <kakkoyun@gmail.com>
1 parent 209d39d commit d7609b4

File tree

16 files changed

+97
-114
lines changed

16 files changed

+97
-114
lines changed

cmd/thanos/bucket.go

Lines changed: 10 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -12,18 +12,6 @@ import (
1212
"text/template"
1313
"time"
1414

15-
"github.com/thanos-io/thanos/pkg/extflag"
16-
17-
"github.com/thanos-io/thanos/pkg/block"
18-
"github.com/thanos-io/thanos/pkg/block/metadata"
19-
"github.com/thanos-io/thanos/pkg/compact"
20-
extpromhttp "github.com/thanos-io/thanos/pkg/extprom/http"
21-
"github.com/thanos-io/thanos/pkg/objstore"
22-
"github.com/thanos-io/thanos/pkg/objstore/client"
23-
"github.com/thanos-io/thanos/pkg/runutil"
24-
"github.com/thanos-io/thanos/pkg/ui"
25-
"github.com/thanos-io/thanos/pkg/verifier"
26-
2715
"github.com/go-kit/kit/log"
2816
"github.com/go-kit/kit/log/level"
2917
"github.com/oklog/run"
@@ -34,6 +22,16 @@ import (
3422
"github.com/prometheus/client_golang/prometheus"
3523
"github.com/prometheus/common/route"
3624
"github.com/prometheus/prometheus/tsdb/labels"
25+
"github.com/thanos-io/thanos/pkg/block"
26+
"github.com/thanos-io/thanos/pkg/block/metadata"
27+
"github.com/thanos-io/thanos/pkg/compact"
28+
"github.com/thanos-io/thanos/pkg/extflag"
29+
extpromhttp "github.com/thanos-io/thanos/pkg/extprom/http"
30+
"github.com/thanos-io/thanos/pkg/objstore"
31+
"github.com/thanos-io/thanos/pkg/objstore/client"
32+
"github.com/thanos-io/thanos/pkg/runutil"
33+
"github.com/thanos-io/thanos/pkg/ui"
34+
"github.com/thanos-io/thanos/pkg/verifier"
3735
"golang.org/x/text/language"
3836
"golang.org/x/text/message"
3937
kingpin "gopkg.in/alecthomas/kingpin.v2"

cmd/thanos/compact.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,9 +10,6 @@ import (
1010
"strings"
1111
"time"
1212

13-
"github.com/thanos-io/thanos/pkg/extflag"
14-
httpserver "github.com/thanos-io/thanos/pkg/server/http"
15-
1613
"github.com/go-kit/kit/log"
1714
"github.com/go-kit/kit/log/level"
1815
"github.com/oklog/run"
@@ -25,10 +22,12 @@ import (
2522
"github.com/thanos-io/thanos/pkg/compact"
2623
"github.com/thanos-io/thanos/pkg/compact/downsample"
2724
"github.com/thanos-io/thanos/pkg/component"
25+
"github.com/thanos-io/thanos/pkg/extflag"
2826
"github.com/thanos-io/thanos/pkg/objstore"
2927
"github.com/thanos-io/thanos/pkg/objstore/client"
3028
"github.com/thanos-io/thanos/pkg/prober"
3129
"github.com/thanos-io/thanos/pkg/runutil"
30+
httpserver "github.com/thanos-io/thanos/pkg/server/http"
3231
"gopkg.in/alecthomas/kingpin.v2"
3332
)
3433

cmd/thanos/downsample.go

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,15 @@ import (
66
"path/filepath"
77
"time"
88

9+
"github.com/go-kit/kit/log"
10+
"github.com/go-kit/kit/log/level"
11+
"github.com/oklog/run"
12+
"github.com/oklog/ulid"
13+
opentracing "github.com/opentracing/opentracing-go"
14+
"github.com/pkg/errors"
15+
"github.com/prometheus/client_golang/prometheus"
16+
"github.com/prometheus/prometheus/tsdb"
17+
"github.com/prometheus/prometheus/tsdb/chunkenc"
918
"github.com/thanos-io/thanos/pkg/block"
1019
"github.com/thanos-io/thanos/pkg/block/metadata"
1120
"github.com/thanos-io/thanos/pkg/compact"
@@ -17,16 +26,6 @@ import (
1726
"github.com/thanos-io/thanos/pkg/prober"
1827
"github.com/thanos-io/thanos/pkg/runutil"
1928
httpserver "github.com/thanos-io/thanos/pkg/server/http"
20-
21-
"github.com/go-kit/kit/log"
22-
"github.com/go-kit/kit/log/level"
23-
"github.com/oklog/run"
24-
"github.com/oklog/ulid"
25-
opentracing "github.com/opentracing/opentracing-go"
26-
"github.com/pkg/errors"
27-
"github.com/prometheus/client_golang/prometheus"
28-
"github.com/prometheus/prometheus/tsdb"
29-
"github.com/prometheus/prometheus/tsdb/chunkenc"
3029
kingpin "gopkg.in/alecthomas/kingpin.v2"
3130
)
3231

cmd/thanos/flags.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ func regGRPCFlags(cmd *kingpin.CmdClause) (
2626
) {
2727
grpcBindAddr = cmd.Flag("grpc-address", "Listen ip:port address for gRPC endpoints (StoreAPI). Make sure this address is routable from other components.").
2828
Default("0.0.0.0:10901").String()
29-
grpcGracePeriod = modelDuration(cmd.Flag("grpc-grace-period", "Time to wait after an interrupt received for GRPC Server.").Default("5s"))
29+
grpcGracePeriod = modelDuration(cmd.Flag("grpc-grace-period", "Time to wait after an interrupt received for GRPC Server.").Default("2m")) // by default it's the same as query.timeout.
3030

3131
grpcTLSSrvCert = cmd.Flag("grpc-server-tls-cert", "TLS Certificate for gRPC server, leave blank to disable TLS").Default("").String()
3232
grpcTLSSrvKey = cmd.Flag("grpc-server-tls-key", "TLS Key for the gRPC server, leave blank to disable TLS").Default("").String()
@@ -41,7 +41,7 @@ func regGRPCFlags(cmd *kingpin.CmdClause) (
4141

4242
func regHTTPFlags(cmd *kingpin.CmdClause) (httpBindAddr *string, httpGracePeriod *model.Duration) {
4343
httpBindAddr = cmd.Flag("http-address", "Listen host:port for HTTP endpoints.").Default("0.0.0.0:10902").String()
44-
httpGracePeriod = modelDuration(cmd.Flag("http-grace-period", "Time to wait after an interrupt received for HTTP Server.").Default("5s"))
44+
httpGracePeriod = modelDuration(cmd.Flag("http-grace-period", "Time to wait after an interrupt received for HTTP Server.").Default("2m")) // by default it's the same as query.timeout.
4545

4646
return httpBindAddr, httpGracePeriod
4747
}

cmd/thanos/query.go

Lines changed: 13 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,19 @@ import (
88
"path"
99
"time"
1010

11+
"github.com/go-kit/kit/log"
12+
"github.com/go-kit/kit/log/level"
13+
grpc_middleware "github.com/grpc-ecosystem/go-grpc-middleware"
14+
grpc_prometheus "github.com/grpc-ecosystem/go-grpc-prometheus"
15+
"github.com/oklog/run"
16+
opentracing "github.com/opentracing/opentracing-go"
17+
"github.com/pkg/errors"
18+
"github.com/prometheus/client_golang/prometheus"
19+
"github.com/prometheus/common/route"
20+
"github.com/prometheus/prometheus/discovery/file"
21+
"github.com/prometheus/prometheus/discovery/targetgroup"
22+
"github.com/prometheus/prometheus/promql"
23+
"github.com/prometheus/prometheus/tsdb/labels"
1124
"github.com/thanos-io/thanos/pkg/component"
1225
"github.com/thanos-io/thanos/pkg/discovery/cache"
1326
"github.com/thanos-io/thanos/pkg/discovery/dns"
@@ -23,20 +36,6 @@ import (
2336
"github.com/thanos-io/thanos/pkg/tls"
2437
"github.com/thanos-io/thanos/pkg/tracing"
2538
"github.com/thanos-io/thanos/pkg/ui"
26-
27-
"github.com/go-kit/kit/log"
28-
"github.com/go-kit/kit/log/level"
29-
grpc_middleware "github.com/grpc-ecosystem/go-grpc-middleware"
30-
grpc_prometheus "github.com/grpc-ecosystem/go-grpc-prometheus"
31-
"github.com/oklog/run"
32-
opentracing "github.com/opentracing/opentracing-go"
33-
"github.com/pkg/errors"
34-
"github.com/prometheus/client_golang/prometheus"
35-
"github.com/prometheus/common/route"
36-
"github.com/prometheus/prometheus/discovery/file"
37-
"github.com/prometheus/prometheus/discovery/targetgroup"
38-
"github.com/prometheus/prometheus/promql"
39-
"github.com/prometheus/prometheus/tsdb/labels"
4039
"google.golang.org/grpc"
4140
"google.golang.org/grpc/credentials"
4241
kingpin "gopkg.in/alecthomas/kingpin.v2"

cmd/thanos/receive.go

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,15 @@ import (
77
"strings"
88
"time"
99

10+
"github.com/go-kit/kit/log"
11+
"github.com/go-kit/kit/log/level"
12+
"github.com/oklog/run"
13+
opentracing "github.com/opentracing/opentracing-go"
14+
"github.com/pkg/errors"
15+
"github.com/prometheus/client_golang/prometheus"
16+
"github.com/prometheus/common/model"
17+
"github.com/prometheus/prometheus/storage/tsdb"
18+
"github.com/prometheus/prometheus/tsdb/labels"
1019
"github.com/thanos-io/thanos/pkg/block/metadata"
1120
"github.com/thanos-io/thanos/pkg/component"
1221
"github.com/thanos-io/thanos/pkg/extflag"
@@ -19,16 +28,6 @@ import (
1928
"github.com/thanos-io/thanos/pkg/shipper"
2029
"github.com/thanos-io/thanos/pkg/store"
2130
"github.com/thanos-io/thanos/pkg/tls"
22-
23-
"github.com/go-kit/kit/log"
24-
"github.com/go-kit/kit/log/level"
25-
"github.com/oklog/run"
26-
opentracing "github.com/opentracing/opentracing-go"
27-
"github.com/pkg/errors"
28-
"github.com/prometheus/client_golang/prometheus"
29-
"github.com/prometheus/common/model"
30-
"github.com/prometheus/prometheus/storage/tsdb"
31-
"github.com/prometheus/prometheus/tsdb/labels"
3231
kingpin "gopkg.in/alecthomas/kingpin.v2"
3332
)
3433

cmd/thanos/rule.go

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,22 @@ import (
1717
"syscall"
1818
"time"
1919

20+
"github.com/go-kit/kit/log"
21+
"github.com/go-kit/kit/log/level"
22+
"github.com/oklog/run"
23+
"github.com/opentracing/opentracing-go"
24+
"github.com/pkg/errors"
25+
"github.com/prometheus/client_golang/prometheus"
26+
"github.com/prometheus/common/model"
27+
"github.com/prometheus/common/route"
28+
"github.com/prometheus/prometheus/discovery/file"
29+
"github.com/prometheus/prometheus/discovery/targetgroup"
30+
promlabels "github.com/prometheus/prometheus/pkg/labels"
31+
"github.com/prometheus/prometheus/promql"
32+
"github.com/prometheus/prometheus/rules"
33+
"github.com/prometheus/prometheus/storage/tsdb"
34+
"github.com/prometheus/prometheus/tsdb/labels"
35+
"github.com/prometheus/prometheus/util/strutil"
2036
"github.com/thanos-io/thanos/pkg/alert"
2137
"github.com/thanos-io/thanos/pkg/block/metadata"
2238
"github.com/thanos-io/thanos/pkg/component"
@@ -39,23 +55,6 @@ import (
3955
"github.com/thanos-io/thanos/pkg/tls"
4056
"github.com/thanos-io/thanos/pkg/tracing"
4157
"github.com/thanos-io/thanos/pkg/ui"
42-
43-
"github.com/go-kit/kit/log"
44-
"github.com/go-kit/kit/log/level"
45-
"github.com/oklog/run"
46-
"github.com/opentracing/opentracing-go"
47-
"github.com/pkg/errors"
48-
"github.com/prometheus/client_golang/prometheus"
49-
"github.com/prometheus/common/model"
50-
"github.com/prometheus/common/route"
51-
"github.com/prometheus/prometheus/discovery/file"
52-
"github.com/prometheus/prometheus/discovery/targetgroup"
53-
promlabels "github.com/prometheus/prometheus/pkg/labels"
54-
"github.com/prometheus/prometheus/promql"
55-
"github.com/prometheus/prometheus/rules"
56-
"github.com/prometheus/prometheus/storage/tsdb"
57-
"github.com/prometheus/prometheus/tsdb/labels"
58-
"github.com/prometheus/prometheus/util/strutil"
5958
"gopkg.in/alecthomas/kingpin.v2"
6059
)
6160

@@ -521,6 +520,7 @@ func runRule(
521520
statusProber.SetReady()
522521
return s.ListenAndServe()
523522
}, func(err error) {
523+
statusProber.SetNotReady(err)
524524
s.Shutdown(err)
525525
})
526526
}

cmd/thanos/sidecar.go

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,14 @@ import (
77
"sync"
88
"time"
99

10+
"github.com/go-kit/kit/log"
11+
"github.com/go-kit/kit/log/level"
12+
"github.com/oklog/run"
13+
"github.com/opentracing/opentracing-go"
14+
"github.com/pkg/errors"
15+
"github.com/prometheus/client_golang/prometheus"
16+
"github.com/prometheus/common/model"
17+
"github.com/prometheus/prometheus/tsdb/labels"
1018
"github.com/thanos-io/thanos/pkg/block/metadata"
1119
"github.com/thanos-io/thanos/pkg/component"
1220
"github.com/thanos-io/thanos/pkg/extflag"
@@ -22,15 +30,6 @@ import (
2230
"github.com/thanos-io/thanos/pkg/store"
2331
"github.com/thanos-io/thanos/pkg/store/storepb"
2432
"github.com/thanos-io/thanos/pkg/tls"
25-
26-
"github.com/go-kit/kit/log"
27-
"github.com/go-kit/kit/log/level"
28-
"github.com/oklog/run"
29-
"github.com/opentracing/opentracing-go"
30-
"github.com/pkg/errors"
31-
"github.com/prometheus/client_golang/prometheus"
32-
"github.com/prometheus/common/model"
33-
"github.com/prometheus/prometheus/tsdb/labels"
3433
"gopkg.in/alecthomas/kingpin.v2"
3534
)
3635

@@ -248,8 +247,10 @@ func runSidecar(
248247
grpcserver.WithTLSConfig(tlsCfg),
249248
)
250249
g.Add(func() error {
250+
statusProber.SetReady()
251251
return s.ListenAndServe()
252252
}, func(err error) {
253+
statusProber.SetNotReady(err)
253254
s.Shutdown(err)
254255
})
255256
}

cmd/thanos/store.go

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,13 @@ import (
44
"context"
55
"time"
66

7+
"github.com/go-kit/kit/log"
8+
"github.com/go-kit/kit/log/level"
9+
"github.com/oklog/run"
10+
"github.com/opentracing/opentracing-go"
11+
"github.com/pkg/errors"
12+
"github.com/prometheus/client_golang/prometheus"
13+
"github.com/prometheus/prometheus/pkg/relabel"
714
"github.com/thanos-io/thanos/pkg/component"
815
"github.com/thanos-io/thanos/pkg/extflag"
916
"github.com/thanos-io/thanos/pkg/model"
@@ -15,14 +22,6 @@ import (
1522
"github.com/thanos-io/thanos/pkg/store"
1623
storecache "github.com/thanos-io/thanos/pkg/store/cache"
1724
"github.com/thanos-io/thanos/pkg/tls"
18-
19-
"github.com/go-kit/kit/log"
20-
"github.com/go-kit/kit/log/level"
21-
"github.com/oklog/run"
22-
"github.com/opentracing/opentracing-go"
23-
"github.com/pkg/errors"
24-
"github.com/prometheus/client_golang/prometheus"
25-
"github.com/prometheus/prometheus/pkg/relabel"
2625
"gopkg.in/alecthomas/kingpin.v2"
2726
yaml "gopkg.in/yaml.v2"
2827
)

docs/components/compact.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ Flags:
8484
https://thanos.io/tracing.md/#configuration
8585
--http-address="0.0.0.0:10902"
8686
Listen host:port for HTTP endpoints.
87-
--http-grace-period=5s Time to wait after an interrupt received for HTTP
87+
--http-grace-period=2m Time to wait after an interrupt received for HTTP
8888
Server.
8989
--data-dir="./data" Data directory in which to cache blocks and
9090
process compactions.

0 commit comments

Comments
 (0)