store

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 14, 2016 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultEtcdEndpoints   = "http://127.0.0.1:2379"
	DefaultConsulEndpoints = "http://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
)

Variables

View Source 
var URLSchemeRegexp = regexp.MustCompile(`^([a-zA-Z][a-zA-Z0-9+-.]*)://`)

Functions

func NewStore 

func NewStore(cfg Config) (kvstore.Store, error)

Types

type Backend 

type Backend string

Backend represents a KV Store Backend 

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

type Config added in v0.5.0 

type Config struct {
	Backend       Backend
	Endpoints     string
	CertFile      string
	KeyFile       string
	CAFile        string
	SkipTLSVerify bool
}

type StoreManager 

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

func NewStoreManager 

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

func (*StoreManager) AtomicPutClusterData added in v0.5.0 

func (e *StoreManager) AtomicPutClusterData(cd *cluster.ClusterData, previous *kvstore.KVPair) (*kvstore.KVPair, error)

func (*StoreManager) GetClusterData 

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

func (*StoreManager) GetKeeperInfo added in v0.5.0 

func (e *StoreManager) GetKeeperInfo(id string) (*cluster.KeeperInfo, bool, error)

func (*StoreManager) GetKeepersInfo added in v0.5.0 

func (e *StoreManager) GetKeepersInfo() (cluster.KeepersInfo, error)

func (*StoreManager) GetLeaderSentinelId 

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

func (*StoreManager) GetProxiesInfo 

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

func (*StoreManager) GetProxyInfo 

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

func (*StoreManager) GetSentinelInfo 

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

func (*StoreManager) GetSentinelsInfo 

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

func (*StoreManager) PutClusterData added in v0.5.0 

func (e *StoreManager) PutClusterData(cd *cluster.ClusterData) error

func (*StoreManager) SetKeeperInfo added in v0.5.0 

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

func (*StoreManager) SetProxyInfo 

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

func (*StoreManager) SetSentinelInfo 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.