kv

Documentation

Index

• func DistributePairs(kvPairs [](*KVPair)) (err error)
• func GetValue(key string) (value string, found bool, err error)
• func InitKVStores()
• func PutKVPairs(kvPairs []*KVPair) (err error)
• func PutValue(key string, value string) (err error)
• type KVPair
  • func NewKVPair(key string, value string) *KVPair
  • func (this *KVPair) String() string
• type KVStore
  • func NewConsulStore() KVStore
  • func NewConsulTxnStore() KVStore
  • func NewInternalKVStore() KVStore
  • func NewZkStore() KVStore

Functions

func DistributePairs

func DistributePairs(kvPairs [](*KVPair)) (err error)

func GetValue

func GetValue(key string) (value string, found bool, err error)

func InitKVStores

func InitKVStores()

InitKVStores initializes the KV stores (duh), once in the lifetime of this app. Configuration reload does not affect a running instance.

func PutKVPairs

func PutKVPairs(kvPairs []*KVPair) (err error)

func PutValue

func PutValue(key string, value string) (err error)

Types

type KVPair

type KVPair struct {
	Key   string
	Value string
}

func NewKVPair

func NewKVPair(key string, value string) *KVPair

func (*KVPair) String

func (this *KVPair) String() string

type KVStore

type KVStore interface {
	PutKeyValue(key string, value string) (err error)
	PutKVPairs(kvPairs []*KVPair) (err error)
	GetKeyValue(key string) (value string, found bool, err error)
	DistributePairs(kvPairs [](*KVPair)) (err error)
}

func NewConsulStore

func NewConsulStore() KVStore

NewConsulStore creates a new consul store. It is possible that the client for this store is nil, which is the case if no consul config is provided.

func NewConsulTxnStore

func NewConsulTxnStore() KVStore

NewConsulTxnStore creates a new consul store that uses Consul Transactions to read/write multiple KVPairs. It is possible that the client for this store is nil, which is the case if no consul config is provided

func NewInternalKVStore

func NewInternalKVStore() KVStore

func NewZkStore

func NewZkStore() KVStore