command/services: move the config helpers to parent package

This commit is contained in:
Mitchell Hashimoto 2018-10-01 08:27:59 -07:00
parent 664d4badd5
commit 85f6ea4007
No known key found for this signature in database
GPG Key ID: A3A9A8F4F25C3E56
3 changed files with 48 additions and 65 deletions

View File

@ -1,14 +1,50 @@
package register package services
import ( import (
"reflect" "reflect"
"time" "time"
"github.com/hashicorp/consul/agent/config"
"github.com/hashicorp/consul/agent/structs" "github.com/hashicorp/consul/agent/structs"
"github.com/hashicorp/consul/api" "github.com/hashicorp/consul/api"
"github.com/mitchellh/mapstructure" "github.com/mitchellh/mapstructure"
) )
// ServicesFromFiles returns the list of agent service registration structs
// from a set of file arguments.
func ServicesFromFiles(files []string) ([]*api.AgentServiceRegistration, error) {
// We set devMode to true so we can get the basic valid default
// configuration. devMode doesn't set any services by default so this
// is okay since we only look at services.
devMode := true
b, err := config.NewBuilder(config.Flags{
ConfigFiles: files,
DevMode: &devMode,
})
if err != nil {
return nil, err
}
cfg, err := b.BuildAndValidate()
if err != nil {
return nil, err
}
// The services are now in "structs.ServiceDefinition" form and we need
// them in "api.AgentServiceRegistration" form so do the conversion.
result := make([]*api.AgentServiceRegistration, 0, len(cfg.Services))
for _, svc := range cfg.Services {
apiSvc, err := serviceToAgentService(svc)
if err != nil {
return nil, err
}
result = append(result, apiSvc)
}
return result, nil
}
// serviceToAgentService converts a ServiceDefinition struct to an // serviceToAgentService converts a ServiceDefinition struct to an
// AgentServiceRegistration API struct. // AgentServiceRegistration API struct.
func serviceToAgentService(svc *structs.ServiceDefinition) (*api.AgentServiceRegistration, error) { func serviceToAgentService(svc *structs.ServiceDefinition) (*api.AgentServiceRegistration, error) {

View File

@ -1,4 +1,4 @@
package register package services
import ( import (
"testing" "testing"

View File

@ -4,9 +4,8 @@ import (
"flag" "flag"
"fmt" "fmt"
"github.com/hashicorp/consul/agent/config"
"github.com/hashicorp/consul/api"
"github.com/hashicorp/consul/command/flags" "github.com/hashicorp/consul/command/flags"
"github.com/hashicorp/consul/command/services"
"github.com/mitchellh/cli" "github.com/mitchellh/cli"
) )
@ -50,7 +49,7 @@ func (c *cmd) Run(args []string) int {
return 1 return 1
} }
svcs, err := c.svcsFromFiles(args) svcs, err := services.ServicesFromFiles(args)
if err != nil { if err != nil {
c.UI.Error(fmt.Sprintf("Error: %s", err)) c.UI.Error(fmt.Sprintf("Error: %s", err))
return 1 return 1
@ -75,42 +74,6 @@ func (c *cmd) Run(args []string) int {
return 0 return 0
} }
// svcsFromFiles loads service definitions from a set of configuration
// files and returns them. It will return an error if the configuration is
// invalid in any way.
func (c *cmd) svcsFromFiles(args []string) ([]*api.AgentServiceRegistration, error) {
// We set devMode to true so we can get the basic valid default
// configuration. devMode doesn't set any services by default so this
// is okay since we only look at services.
devMode := true
b, err := config.NewBuilder(config.Flags{
ConfigFiles: args,
DevMode: &devMode,
})
if err != nil {
return nil, err
}
cfg, err := b.BuildAndValidate()
if err != nil {
return nil, err
}
// The services are now in "structs.ServiceDefinition" form and we need
// them in "api.AgentServiceRegistration" form so do the conversion.
result := make([]*api.AgentServiceRegistration, 0, len(cfg.Services))
for _, svc := range cfg.Services {
apiSvc, err := serviceToAgentService(svc)
if err != nil {
return nil, err
}
result = append(result, apiSvc)
}
return result, nil
}
func (c *cmd) Synopsis() string { func (c *cmd) Synopsis() string {
return synopsis return synopsis
} }
@ -119,33 +82,17 @@ func (c *cmd) Help() string {
return c.help return c.help
} }
const synopsis = "Create intentions for service connections." const synopsis = "Register services with the local agent"
const help = ` const help = `
Usage: consul intention create [options] SRC DST Usage: consul services register [options] [FILE...]
Usage: consul intention create [options] -file FILE...
Create one or more intentions. The data can be specified as a single Register one or more services using the local agent API. Services can
source and destination pair or via a set of files when the "-file" flag be registered from standard Consul configuration files (HCL or JSON) or
is specified. using flags. The service is registered and the command returns. The caller
must remember to call "consul services deregister" or a similar API to
deregister the service when complete.
$ consul intention create web db $ consul services register web.json
To consume data from a set of files:
$ consul intention create -file one.json two.json
When specifying the "-file" flag, "-" may be used once to read from stdin:
$ echo "{ ... }" | consul intention create -file -
An "allow" intention is created by default (whitelist). To create a
"deny" intention, the "-deny" flag should be specified.
If a conflicting intention is found, creation will fail. To replace any
conflicting intentions, specify the "-replace" flag. This will replace any
conflicting intentions with the intention specified in this command.
Metadata and any other fields of the previous intention will not be
preserved.
Additional flags and more advanced use cases are detailed below. Additional flags and more advanced use cases are detailed below.
` `