storage

Documentation

Index

• type Mssql
  • func OpenConnection(config *configuration.Struct) (*Mssql, error)
  • func (m *Mssql) Close()
  • func (db *Mssql) GetKVs(prefix string) ([]consul.KV, error)
  • func (db *Mssql) WriteKVs(kvs []consul.KV, ignoreDCs, incremental bool) error

Types

type Mssql

type Mssql struct {
	// contains filtered or unexported fields
}

Mssql is the struct representing the Mssql connection

func OpenConnection

func OpenConnection(config *configuration.Struct) (*Mssql, error)

OpenConnection opens a database connection and returns it

func (*Mssql) Close

func (m *Mssql) Close()

Close the Mssql connection

func (*Mssql) GetKVs

func (db *Mssql) GetKVs(prefix string) ([]consul.KV, error)

GetKVs reads KVs from the storage and returns all with the highest version

func (*Mssql) WriteKVs

func (db *Mssql) WriteKVs(kvs []consul.KV, ignoreDCs, incremental bool) error

WriteKVs writes a KV array to a MSSQL table TODO: Only write if value (in dc) changed