etcd

package

v0.11.0 Latest Latest Go to latest Published: May 5, 2017 License: Apache-2.0 Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type EmbeddedEtcd struct {
	Port int
	// contains filtered or unexported fields
}

EmbeddedEtcd provides a single node etcd server.

func NewEmbeddedEtcd(sa common.ServiceAddress, dataDir string) (*EmbeddedEtcd, error)

func NewEmbeddedEtcdFromConfig() (*EmbeddedEtcd, error)

func (se *EmbeddedEtcd) Stop() error

type EtcdClient struct {
	Client  *etcd.Client
	KeysAPI etcd.KeysAPI
}

func NewEtcdClient(etcdServers []string, clientTimeout time.Duration) (*EtcdClient, error)

func NewEtcdClientFromConfig() (*EtcdClient, error)

func (client *EtcdClient) GetInt64(key string) (int64, error)

func (client *EtcdClient) SetInt64(key string, value int64) error

func (client *EtcdClient) Stop()

type EtcdMasterElectionListener interface {
	OnMaster()
	OnSlave()
}

type EtcdMasterElector struct {
	sync.RWMutex
	EtcdKeyAPI etcd.KeysAPI
	Host       string
	// contains filtered or unexported fields
}

func NewEtcdMasterElector(host string, serviceType common.ServiceType, key string, etcdClient *EtcdClient) *EtcdMasterElector

func NewEtcdMasterElectorFromConfig(serviceType common.ServiceType, key string, etcdClient *EtcdClient) *EtcdMasterElector

func (le *EtcdMasterElector) AddEventListener(listener EtcdMasterElectionListener)

func (le *EtcdMasterElector) IsMaster() bool

func (le *EtcdMasterElector) Start()

func (le *EtcdMasterElector) StartAndWait()

StartAndWait starts the election mechanism and wait for the first election before returning

func (le *EtcdMasterElector) Stop()