stagger

Consul migration

Example:

package main
import (
    "fmt"
    "github.com/deweppro/stagger/consul"
)
func main() {
    // Init migration client
    cli, err := consul.CreateConsulMigrate("consul:8500")
    if err != nil {
        panic(err)
    }
    // Get all existing keys from consul
    kvs, err := cli.Dump()
    if err != nil {
        panic(err)
    }
    for _, kv := range kvs {
        fmt.Println(kv.Key, kv.Type, kv.Value)
    }
    // Save all existing keys from consul to file
    err = cli.DumpToFile("/tml/dump.yaml")
    if err != nil {
        panic(err)
    }
    // Save keys to consul
    err = cli.Migrate(kvs)
    if err != nil {
        panic(err)
    }
    // Migration of keys from a file in the consul.
    err = cli.MigrateFromFile("/tmp/dump.yaml")
    if err != nil {
        panic(err)
    }
    // Scan directories, merge files with sort by name,
    // and the migration of keys from files in the consul.
    err = cli.MigrateFromDir("/tmp")
    if err != nil {
        panic(err)
    }
}

Migration file format:

- key: test                   # name
  value: '{"hello":"world"}'  # value
  type: json                  # type (choice: base64, json)

Add Keys

Default format: (without specifying the key type to disable value validation)

- key: test  
  value: 123

JSON format: (with key value validation as json)

- key: test  
  value: '[1,2,3,4]'
  type: json

Base64 format: (with key value validation as base64)

- key: test  
  value: aGVsbG8gd29ybGQ=
  type: base64

Delete Keys

For delete a key from the consul, remove the parameter with the key value in the migration file.

- key: test