mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-08-28 02:44:59 +00:00
enable staticcheck in ci; remove dead code (#2281)
(cherry picked from commit 0d6a92aeaf)
This commit is contained in:
parent
751b7a74fe
commit
dcdc99db25
2 changed files with 2 additions and 11 deletions
|
|
@ -13,6 +13,7 @@ import (
|
|||
"google.golang.org/grpc"
|
||||
"google.golang.org/grpc/connectivity"
|
||||
"google.golang.org/grpc/credentials"
|
||||
"google.golang.org/grpc/credentials/insecure"
|
||||
)
|
||||
|
||||
const maxMsgSize = 1024 * 1024 * 100 // 100 megs ought to be enough for anybody!
|
||||
|
|
@ -64,7 +65,7 @@ func (c *GRPCClient) resetConn() error {
|
|||
creds := credentials.NewTLS(c.tlsConfig)
|
||||
opts = append(opts, grpc.WithTransportCredentials(creds))
|
||||
} else {
|
||||
opts = append(opts, grpc.WithInsecure())
|
||||
opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()))
|
||||
}
|
||||
|
||||
opts = append(opts, grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(maxMsgSize)))
|
||||
|
|
|
|||
|
|
@ -489,16 +489,6 @@ func (c *ShareableCluster) Start() error {
|
|||
|
||||
// Close stops a Cluster
|
||||
func (c *ShareableCluster) Close() error {
|
||||
if c.shared {
|
||||
for i := range c.Nodes {
|
||||
holder := c.GetHolder(i)
|
||||
indexes := holder.Indexes()
|
||||
var indexNames []string
|
||||
for _, idx := range indexes {
|
||||
indexNames = append(indexNames, idx.Name())
|
||||
}
|
||||
}
|
||||
}
|
||||
for i, cc := range c.Nodes {
|
||||
if err := cc.Close(); err != nil {
|
||||
return errors.Wrapf(err, "stopping server %d", i)
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue