Versions in this module Expand all Collapse all v0 v0.3.0 Oct 27, 2017 Changes in this version + const DefaultConsulEndpoints + const DefaultEtcdEndpoints + func DownloadFromS3(cred S3Credentials, src string, dest string) (string, error) + func NewStore(backend Backend, addrsStr, certFile, keyFile, caCertFile string) (kvstore.Store, error) + func UploadToS3(cred S3Credentials, src, dest string) (string, error) + type Backend string + const CONSUL + const ETCD + type S3Credentials struct + AccessKeyID string + SecretAccessKey string + type S3Location struct + Bucket string + Host string + Path string + type StoreManager struct + 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
Go to main page