etcd

package

v0.25.0 Latest Latest Go to latest Published: Sep 12, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.phpd.cn/skydive-project/skydive

Links

Open Source Insights

Documentation ¶

Index ¶

type Client
- func NewClient(service common.Service, etcdServers []string, clientTimeout time.Duration) (*Client, error)
type EmbeddedEtcd
- func NewEmbeddedEtcd(name string, listen string, peers map[string]string, dataDir string, ...) (*EmbeddedEtcd, error)
- func (se *EmbeddedEtcd) Stop() error
type MasterElector
- func NewMasterElector(etcdClient *Client, key string) *MasterElector

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Client ¶ added in v0.17.0

type Client struct {
	KeysAPI etcd.KeysAPI
	// contains filtered or unexported fields
}

Client describes a ETCD configuration client

func NewClient ¶ added in v0.17.0

func NewClient(service common.Service, etcdServers []string, clientTimeout time.Duration) (*Client, error)

NewClient creates a new ETCD client connection to ETCD servers

func (*Client) GetInt64 ¶ added in v0.17.0

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

GetInt64 returns an int64 value from the configuration key

func (*Client) NewElection ¶ added in v0.22.0

func (client *Client) NewElection(name string) common.MasterElection

NewElection creates a new ETCD master elector

func (*Client) SetInt64 ¶ added in v0.17.0

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

SetInt64 set an int64 value to the configuration key

func (*Client) Stop ¶ added in v0.17.0

func (client *Client) Stop()

Stop the client

type EmbeddedEtcd ¶

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

EmbeddedEtcd provides a single node etcd server.

func NewEmbeddedEtcd ¶

func NewEmbeddedEtcd(name string, listen string, peers map[string]string, dataDir string, maxWalFiles, maxSnapFiles uint, debug bool) (*EmbeddedEtcd, error)

NewEmbeddedEtcd creates a new embedded ETCD server

func (*EmbeddedEtcd) Stop ¶

func (se *EmbeddedEtcd) Stop() error

Stop the embedded server

type MasterElector ¶ added in v0.17.0

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

MasterElector describes an ETCD master elector

func NewMasterElector ¶ added in v0.17.0

func NewMasterElector(etcdClient *Client, key string) *MasterElector

NewMasterElector creates a new ETCD master elector

func (*MasterElector) AddEventListener ¶ added in v0.17.0

func (le *MasterElector) AddEventListener(listener common.MasterElectionListener)

AddEventListener registers a new listener

func (*MasterElector) IsMaster ¶ added in v0.17.0

func (le *MasterElector) IsMaster() bool

IsMaster returns true if the current instance is master

func (*MasterElector) Start ¶ added in v0.17.0

func (le *MasterElector) Start()

Start the master election mechanism

func (*MasterElector) StartAndWait ¶ added in v0.17.0

func (le *MasterElector) StartAndWait()

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

func (*MasterElector) Stop ¶ added in v0.17.0

func (le *MasterElector) Stop()

Stop the election mechanism

func (*MasterElector) TTL ¶ added in v0.17.0

func (le *MasterElector) TTL() time.Duration

TTL time to live

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL