adds sslmode parameter

postgresreplication/provider.go

@@ -10,6 +10,7 @@ const (
 	portKey     = "port"
 	hostKey     = "host"
 	userKey     = "user"
+	sslmodeKey  = "sslmode"
 	passwordKey = "password"
 )
 
@@ -18,13 +19,15 @@ const (
 	defaultHost     = "localhost"
 	defaultUser     = "postgres"
 	defaultPassword = ""
+	defaultSslMode  = "preferp"
 )
 
 type providerConfiguration struct {
 	port     uint16
 	host     string
 	user     string
 	password string
+	sslMode  string
 }
 
 func Provider() *schema.Provider {
@@ -35,6 +38,7 @@ func Provider() *schema.Provider {
 				host:     d.Get(hostKey).(string),
 				user:     d.Get(userKey).(string),
 				password: d.Get(passwordKey).(string),
+				sslMode:  d.Get(sslmodeKey).(string),
 			}, nil
 		},
 		ResourcesMap: map[string]*schema.Resource{
@@ -55,6 +59,13 @@ func Provider() *schema.Provider {
 				Default:     defaultPort,
 				Description: "The server port to connect to.",
 			},
+			sslmodeKey: {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Sensitive:   false,
+				Default:     defaultSslMode,
+				Description: "The ssl mode to use.",
+			},
 			userKey: {
 				Type:        schema.TypeString,
 				Optional:    true,

postgresreplication/resource_replication_slot.go

@@ -1,6 +1,7 @@
 package postgresreplication
 
 import (
+	"fmt"
 	"github.com/hashicorp/terraform/helper/schema"
 	"github.com/jackc/pgx"
 	"github.com/pkg/errors"
@@ -46,12 +47,16 @@ func resourceReplicationSlot() *schema.Resource {
 
 func connect(d *schema.ResourceData, m interface{}) (r *pgx.ReplicationConn, err error) {
 	c := m.(*providerConfiguration)
-	dbConfig := pgx.ConnConfig{
-		Host:     c.host,
-		Port:     c.port,
-		User:     c.user,
-		Password: c.password,
-		Database: d.Get(databaseAttributeName).(string),
+	dbConfig, err := pgx.ParseURI(fmt.Sprintf("postgres://%s:%s@%s:%d/%s?sslmode=%s",
+		c.user,
+		c.password,
+		c.host,
+		c.port,
+		d.Get(databaseAttributeName).(string),
+		c.sslMode))
+
+	if err != nil {
+		return nil, errors.Wrap(err, "error setting up database connection.")
 	}
 
 	replConn, err := pgx.ReplicationConnect(dbConfig)