store

package

v0.3.0 Latest Latest Go to latest Published: Sep 27, 2016 License: Apache-2.0 Imports: 12 Imported by: 0

Details

View Source

const (
	DefaultEtcdEndpoints   = "127.0.0.1:2379"
	DefaultConsulEndpoints = "127.0.0.1:8500"
)

View Source

const (
	//TODO(sgotti) fix this in libkv?
	// consul min ttl is 10s and libkv divides this by 2
	MinTTL = 20 * time.Second
)

This section is empty.

func NewStore(backend Backend, addrsStr string) (kvstore.Store, error)

type Backend string

Backend represents a KV Store Backend

const (
	CONSUL Backend = "consul"
	ETCD   Backend = "etcd"
)

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

func NewStoreManager(kvStore kvstore.Store, path string) *StoreManager

func (e *StoreManager) GetClusterData() (*cluster.ClusterData, *kvstore.KVPair, error)

func (e *StoreManager) GetClusterView() (*cluster.ClusterView, *kvstore.KVPair, error)

func (e *StoreManager) GetKeeperDiscoveryInfo(id string) (*cluster.KeeperDiscoveryInfo, bool, error)

func (e *StoreManager) GetKeepersDiscoveryInfo() (cluster.KeepersDiscoveryInfo, error)

func (e *StoreManager) GetKeepersState() (cluster.KeepersState, *kvstore.KVPair, error)

func (e *StoreManager) GetLeaderSentinelId() (string, error)

func (e *StoreManager) GetProxiesInfo() (cluster.ProxiesInfo, error)

func (e *StoreManager) GetProxyInfo(id string) (*cluster.ProxyInfo, bool, error)

func (e *StoreManager) GetSentinelInfo(id string) (*cluster.SentinelInfo, bool, error)

func (e *StoreManager) GetSentinelsInfo() (cluster.SentinelsInfo, error)

func (e *StoreManager) SetClusterData(mss cluster.KeepersState, cv *cluster.ClusterView, previous *kvstore.KVPair) (*kvstore.KVPair, error)

func (e *StoreManager) SetKeeperDiscoveryInfo(id string, ms *cluster.KeeperDiscoveryInfo, ttl time.Duration) error

func (e *StoreManager) SetProxyInfo(pi *cluster.ProxyInfo, ttl time.Duration) error

func (e *StoreManager) SetSentinelInfo(si *cluster.SentinelInfo, ttl time.Duration) error