kv

Documentation

Index

• func DistributePairs(kvPairs [](*KVPair)) (err error)
• func GetValue(key string) (value string, found bool, err error)
• func InitKVStores()
• func PutKVPair(kvPair *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 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 PutKVPair

func PutKVPair(kvPair *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)
	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 NewInternalKVStore

func NewInternalKVStore() KVStore

func NewZkStore

func NewZkStore() KVStore