mirror of
https://github.com/kreuzwerker/terraform-provider-docker.git
synced 2025-12-22 23:59:35 -05:00
dc824c1030
Adds docker swarm features to the provider for the Docker Engine 17.09.1 and API Version 1.32. The spec is close to the API. By default, the swarm services are fire and forget. A converging config implements the features of the docker cli to ensure a service and all its replicas are up and running. Furthermore, service can have configs, secrets, networks, mounts and be added to a network.
124 lines
3 KiB
Go
124 lines
3 KiB
Go
package docker
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"fmt"
|
|
"regexp"
|
|
"strconv"
|
|
"time"
|
|
|
|
"github.com/hashicorp/terraform/helper/schema"
|
|
)
|
|
|
|
func validateIntegerInRange(min, max int) schema.SchemaValidateFunc {
|
|
return func(v interface{}, k string) (ws []string, errors []error) {
|
|
value := v.(int)
|
|
if value < min {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q cannot be lower than %d: %d", k, min, value))
|
|
}
|
|
if value > max {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q cannot be higher than %d: %d", k, max, value))
|
|
}
|
|
return
|
|
}
|
|
}
|
|
|
|
func validateIntegerGeqThan(threshold int) schema.SchemaValidateFunc {
|
|
return func(v interface{}, k string) (ws []string, errors []error) {
|
|
value := v.(int)
|
|
if value < threshold {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q cannot be lower than %q", k, threshold))
|
|
}
|
|
return
|
|
}
|
|
}
|
|
|
|
func validateFloatRatio() schema.SchemaValidateFunc {
|
|
return func(v interface{}, k string) (ws []string, errors []error) {
|
|
value := v.(float64)
|
|
if value < 0.0 || value > 1.0 {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q has to be between 0.0 and 1.0", k))
|
|
}
|
|
return
|
|
}
|
|
}
|
|
|
|
func validateStringIsFloatRatio() schema.SchemaValidateFunc {
|
|
return func(v interface{}, k string) (ws []string, errors []error) {
|
|
switch v.(type) {
|
|
case string:
|
|
stringValue := v.(string)
|
|
value, err := strconv.ParseFloat(stringValue, 64)
|
|
if err != nil {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q is not a float", k))
|
|
}
|
|
if value < 0.0 || value > 1.0 {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q has to be between 0.0 and 1.0", k))
|
|
}
|
|
case int:
|
|
value := float64(v.(int))
|
|
if value < 0.0 || value > 1.0 {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q has to be between 0.0 and 1.0", k))
|
|
}
|
|
default:
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q is not a string", k))
|
|
}
|
|
return
|
|
}
|
|
}
|
|
|
|
func validateDurationGeq0() schema.SchemaValidateFunc {
|
|
return func(v interface{}, k string) (ws []string, errors []error) {
|
|
value := v.(string)
|
|
dur, err := time.ParseDuration(value)
|
|
if err != nil {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q is not a valid duration", k))
|
|
}
|
|
if dur < 0 {
|
|
errors = append(errors, fmt.Errorf(
|
|
"duration must not be negative"))
|
|
}
|
|
return
|
|
}
|
|
}
|
|
|
|
func validateStringMatchesPattern(pattern string) schema.SchemaValidateFunc {
|
|
return func(v interface{}, k string) (ws []string, errors []error) {
|
|
compiledRegex, err := regexp.Compile(pattern)
|
|
if err != nil {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q regex does not compile", pattern))
|
|
return
|
|
}
|
|
|
|
value := v.(string)
|
|
if !compiledRegex.MatchString(value) {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q doesn't match the pattern (%q): %q",
|
|
k, pattern, value))
|
|
}
|
|
|
|
return
|
|
}
|
|
}
|
|
|
|
func validateStringIsBase64Encoded() schema.SchemaValidateFunc {
|
|
return func(v interface{}, k string) (ws []string, errors []error) {
|
|
value := v.(string)
|
|
if _, err := base64.StdEncoding.DecodeString(value); err != nil {
|
|
errors = append(errors, fmt.Errorf(
|
|
"%q is not base64 decodeable", k))
|
|
}
|
|
|
|
return
|
|
}
|
|
}
|