mirror of
https://github.com/status-im/consul.git
synced 2025-02-19 17:14:37 +00:00
Remove redundant hardcoded environment variables
The following hardcoded environment variables are removed: * CONSUL_RPC_ADDR * CONSUL_HTTP_ADDR
This commit is contained in:
parent
6a30762965
commit
bb6bb19aad
@ -20,6 +20,12 @@ import (
|
|||||||
"github.com/hashicorp/go-cleanhttp"
|
"github.com/hashicorp/go-cleanhttp"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
// HTTPAddrEnvName defines an environment variable name which sets
|
||||||
|
// the HTTP address if there is no -http-addr specified.
|
||||||
|
HTTPAddrEnvName = "CONSUL_HTTP_ADDR"
|
||||||
|
)
|
||||||
|
|
||||||
// QueryOptions are used to parameterize a query
|
// QueryOptions are used to parameterize a query
|
||||||
type QueryOptions struct {
|
type QueryOptions struct {
|
||||||
// Providing a datacenter overwrites the DC provided
|
// Providing a datacenter overwrites the DC provided
|
||||||
@ -178,7 +184,7 @@ func defaultConfig(transportFn func() *http.Transport) *Config {
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
if addr := os.Getenv("CONSUL_HTTP_ADDR"); addr != "" {
|
if addr := os.Getenv(HTTPAddrEnvName); addr != "" {
|
||||||
config.Address = addr
|
config.Address = addr
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -76,8 +76,8 @@ func TestDefaultConfig_env(t *testing.T) {
|
|||||||
token := "abcd1234"
|
token := "abcd1234"
|
||||||
auth := "username:password"
|
auth := "username:password"
|
||||||
|
|
||||||
os.Setenv("CONSUL_HTTP_ADDR", addr)
|
os.Setenv(HTTPAddrEnvName, addr)
|
||||||
defer os.Setenv("CONSUL_HTTP_ADDR", "")
|
defer os.Setenv(HTTPAddrEnvName, "")
|
||||||
os.Setenv("CONSUL_HTTP_TOKEN", token)
|
os.Setenv("CONSUL_HTTP_TOKEN", token)
|
||||||
defer os.Setenv("CONSUL_HTTP_TOKEN", "")
|
defer os.Setenv("CONSUL_HTTP_TOKEN", "")
|
||||||
os.Setenv("CONSUL_HTTP_AUTH", auth)
|
os.Setenv("CONSUL_HTTP_AUTH", auth)
|
||||||
|
@ -13,6 +13,12 @@ import (
|
|||||||
"sync/atomic"
|
"sync/atomic"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
// RPCAddrEnvName defines an environment variable name which sets
|
||||||
|
// an RPC address if there is no -rpc-addr specified.
|
||||||
|
RPCAddrEnvName = "CONSUL_RPC_ADDR"
|
||||||
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
clientClosed = fmt.Errorf("client closed")
|
clientClosed = fmt.Errorf("client closed")
|
||||||
)
|
)
|
||||||
@ -84,7 +90,7 @@ func NewRPCClient(addr string) (*RPCClient, error) {
|
|||||||
var conn net.Conn
|
var conn net.Conn
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
if envAddr := os.Getenv("CONSUL_RPC_ADDR"); envAddr != "" {
|
if envAddr := os.Getenv(RPCAddrEnvName); envAddr != "" {
|
||||||
addr = envAddr
|
addr = envAddr
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -8,20 +8,10 @@ import (
|
|||||||
"github.com/hashicorp/consul/command/agent"
|
"github.com/hashicorp/consul/command/agent"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
|
||||||
// RPCAddrEnvName defines an environment variable name which sets
|
|
||||||
// an RPC address if there is no -rpc-addr specified.
|
|
||||||
RPCAddrEnvName = "CONSUL_RPC_ADDR"
|
|
||||||
|
|
||||||
// HTTPAddrEnvName defines an environment variable name which sets
|
|
||||||
// the HTTP address if there is no -http-addr specified.
|
|
||||||
HTTPAddrEnvName = "CONSUL_HTTP_ADDR"
|
|
||||||
)
|
|
||||||
|
|
||||||
// RPCAddrFlag returns a pointer to a string that will be populated
|
// RPCAddrFlag returns a pointer to a string that will be populated
|
||||||
// when the given flagset is parsed with the RPC address of the Consul.
|
// when the given flagset is parsed with the RPC address of the Consul.
|
||||||
func RPCAddrFlag(f *flag.FlagSet) *string {
|
func RPCAddrFlag(f *flag.FlagSet) *string {
|
||||||
defaultRPCAddr := os.Getenv(RPCAddrEnvName)
|
defaultRPCAddr := os.Getenv(agent.RPCAddrEnvName)
|
||||||
if defaultRPCAddr == "" {
|
if defaultRPCAddr == "" {
|
||||||
defaultRPCAddr = "127.0.0.1:8400"
|
defaultRPCAddr = "127.0.0.1:8400"
|
||||||
}
|
}
|
||||||
@ -37,7 +27,7 @@ func RPCClient(addr string) (*agent.RPCClient, error) {
|
|||||||
// HTTPAddrFlag returns a pointer to a string that will be populated
|
// HTTPAddrFlag returns a pointer to a string that will be populated
|
||||||
// when the given flagset is parsed with the HTTP address of the Consul.
|
// when the given flagset is parsed with the HTTP address of the Consul.
|
||||||
func HTTPAddrFlag(f *flag.FlagSet) *string {
|
func HTTPAddrFlag(f *flag.FlagSet) *string {
|
||||||
defaultHTTPAddr := os.Getenv(HTTPAddrEnvName)
|
defaultHTTPAddr := os.Getenv(consulapi.HTTPAddrEnvName)
|
||||||
if defaultHTTPAddr == "" {
|
if defaultHTTPAddr == "" {
|
||||||
defaultHTTPAddr = "127.0.0.1:8500"
|
defaultHTTPAddr = "127.0.0.1:8500"
|
||||||
}
|
}
|
||||||
|
@ -4,6 +4,9 @@ import (
|
|||||||
"flag"
|
"flag"
|
||||||
"os"
|
"os"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
consulapi "github.com/hashicorp/consul/api"
|
||||||
|
"github.com/hashicorp/consul/command/agent"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@ -21,11 +24,11 @@ func getParsedAddr(t *testing.T, addrType, cliVal, envVal string) string {
|
|||||||
switch addrType {
|
switch addrType {
|
||||||
case "rpc":
|
case "rpc":
|
||||||
fn = RPCAddrFlag
|
fn = RPCAddrFlag
|
||||||
envVar = RPCAddrEnvName
|
envVar = agent.RPCAddrEnvName
|
||||||
cliFlag = "-rpc-addr"
|
cliFlag = "-rpc-addr"
|
||||||
case "http":
|
case "http":
|
||||||
fn = HTTPAddrFlag
|
fn = HTTPAddrFlag
|
||||||
envVar = HTTPAddrEnvName
|
envVar = consulapi.HTTPAddrEnvName
|
||||||
cliFlag = "-http-addr"
|
cliFlag = "-http-addr"
|
||||||
default:
|
default:
|
||||||
t.Fatalf("unknown address type %s", addrType)
|
t.Fatalf("unknown address type %s", addrType)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user