status-im/consul
2
0
Fork 0
mirror of https://github.com/status-im/consul.git synced 2025-01-09 13:26:07 +00:00
Code Issues Projects Releases Wiki Activity

Hold onto the token store from the base deps in the Client (#10432)

Browse Source 
This is needed in order to access the agent token in some enterprise code.
This commit is contained in:
Matt Keeler 2021-06-18 16:34:23 -04:00 committed by GitHub
parent 796ebbe5f5
commit 94e4ef0c17
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
.changelog/10432.txt Normal file
View File

@ -0,0 +1,3 @@
```release-note:bug
license: **(Enterprise only)** Fixed an issue that would cause client agents on versions before 1.10 to not be able to retrieve the license from a 1.10+ server.
```

5
agent/consul/client.go
View File

@ -13,6 +13,7 @@ import (
"github.com/hashicorp/consul/agent/pool" "github.com/hashicorp/consul/agent/pool"
"github.com/hashicorp/consul/agent/router" "github.com/hashicorp/consul/agent/router"
"github.com/hashicorp/consul/agent/structs" "github.com/hashicorp/consul/agent/structs"
"github.com/hashicorp/consul/agent/token"
"github.com/hashicorp/consul/lib" "github.com/hashicorp/consul/lib"
"github.com/hashicorp/consul/logging" "github.com/hashicorp/consul/logging"
"github.com/hashicorp/consul/tlsutil" "github.com/hashicorp/consul/tlsutil"
@ -90,6 +91,9 @@ type Client struct {
EnterpriseClient EnterpriseClient
tlsConfigurator *tlsutil.Configurator tlsConfigurator *tlsutil.Configurator
// tokens is the agent wide token store
tokens *token.Store
} }
// NewClient creates and returns a Client // NewClient creates and returns a Client
@ -111,6 +115,7 @@ func NewClient(config *Config, deps Deps) (*Client, error) {
logger: deps.Logger.NamedIntercept(logging.ConsulClient), logger: deps.Logger.NamedIntercept(logging.ConsulClient),
shutdownCh: make(chan struct{}), shutdownCh: make(chan struct{}),
tlsConfigurator: deps.TLSConfigurator, tlsConfigurator: deps.TLSConfigurator,
tokens: deps.Tokens,
} }
c.rpcLimiter.Store(rate.NewLimiter(config.RPCRate, config.RPCMaxBurst)) c.rpcLimiter.Store(rate.NewLimiter(config.RPCRate, config.RPCMaxBurst))