kv

Documentation

Index

• func DistributePairs(kvPairs [](*KeyValuePair)) (err error)
• func GetValue(key string) (value string, found bool, err error)
• func InitKVStores()
• func PutKVPair(kvPair *KeyValuePair) (err error)
• func PutValue(key string, value string) (err error)
• type KeyValuePair
  • func NewKVPair(key string, value string) *KeyValuePair
  • func (kvPair *KeyValuePair) String() string
• type KeyValueStore
  • func NewConsulStore() KeyValueStore
  • func NewInternalKVStore() KeyValueStore
  • func NewZkStore() KeyValueStore

Functions

func DistributePairs

func DistributePairs(kvPairs [](*KeyValuePair)) (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 *KeyValuePair) (err error)

func PutValue

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

Types

type KeyValuePair

type KeyValuePair struct {
	Key   string
	Value string
}

func NewKVPair

func NewKVPair(key string, value string) *KeyValuePair

func (*KeyValuePair) String

func (kvPair *KeyValuePair) String() string

type KeyValueStore

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

func NewConsulStore

func NewConsulStore() KeyValueStore

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() KeyValueStore

func NewZkStore

func NewZkStore() KeyValueStore