mirror of
https://github.com/status-im/consul.git
synced 2025-02-13 06:06:40 +00:00
b4151780d6
1. Upgraded agent can inherit the persisted token and join the cluster 2. Agent token prior to upgrade is still valid after upgrade 3. Enable ACL in the agent configuration
66 lines
1.1 KiB
Go
66 lines
1.1 KiB
Go
package utils
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/itchyny/gojq"
|
|
"github.com/teris-io/shortid"
|
|
)
|
|
|
|
func RandName(name string) string {
|
|
shortID, err := shortid.New(1, shortid.DefaultABC, 6666)
|
|
if err != nil {
|
|
return ""
|
|
}
|
|
id, err := shortID.Generate()
|
|
if err != nil {
|
|
return ""
|
|
}
|
|
id = strings.ToLower(id)
|
|
return name + "-" + id
|
|
}
|
|
|
|
// JQFilter uses the provided "jq" filter to parse json.
|
|
// Matching results are returned as a slice of strings.
|
|
func JQFilter(config, filter string) ([]string, error) {
|
|
result := []string{}
|
|
query, err := gojq.Parse(filter)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var m interface{}
|
|
err = json.Unmarshal([]byte(config), &m)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
iter := query.Run(m)
|
|
for {
|
|
v, ok := iter.Next()
|
|
if !ok {
|
|
break
|
|
}
|
|
if err, ok := v.(error); ok {
|
|
return nil, err
|
|
}
|
|
s := fmt.Sprintf("%v", v)
|
|
result = append(result, s)
|
|
}
|
|
return result, nil
|
|
}
|
|
|
|
func IntToPointer(i int) *int {
|
|
return &i
|
|
}
|
|
|
|
func BoolToPointer(b bool) *bool {
|
|
return &b
|
|
}
|
|
|
|
func StringToPointer(s string) *string {
|
|
return &s
|
|
}
|