etcd

package

v0.1.2 Latest Latest Go to latest Published: Sep 15, 2016 License: Apache-2.0 Imports: 18 Imported by: 24

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.com/coreos/torus

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BytesAddOne(in []byte) ([]byte, interface{}, error)
func BytesToUint64(b []byte) uint64
func MkKey(s ...string) string
func Uint64ToBytes(x uint64) []byte
func Uint64ToHex(x uint64) string
type AtomicModifyFunc
type Etcd

Constants ¶

View Source

const (
	KeyPrefix = "/github.com/coreos/torus/"
)

Variables ¶

This section is empty.

Functions ¶

func BytesAddOne ¶

func BytesAddOne(in []byte) ([]byte, interface{}, error)

func BytesToUint64 ¶

func BytesToUint64(b []byte) uint64

func MkKey ¶

func MkKey(s ...string) string

func Uint64ToBytes ¶

func Uint64ToBytes(x uint64) []byte

func Uint64ToHex ¶

func Uint64ToHex(x uint64) string

Types ¶

type AtomicModifyFunc ¶

type AtomicModifyFunc func(in []byte) (out []byte, data interface{}, err error)

AtomicModifyFunc is a class of commutative functions that, given the current state of a key's value `in`, returns the new state of the key `out`, and `data` to be returned to the calling function on success, or an `err`.

This function may be run multiple times, if the value has changed in the time between getting the data and setting the new value.

type Etcd ¶

type Etcd struct {
	Client *etcdv3.Client
	// contains filtered or unexported fields
}

func (*Etcd) AtomicModifyKey ¶

func (c *Etcd) AtomicModifyKey(k []byte, f AtomicModifyFunc) (interface{}, error)

func (*Etcd) Close ¶

func (e *Etcd) Close() error

func (*Etcd) CommitINodeIndex ¶

func (c *Etcd) CommitINodeIndex(vid torus.VolumeID) (torus.INodeID, error)

func (*Etcd) DumpMetadata ¶

func (c *Etcd) DumpMetadata(w io.Writer) error

func (*Etcd) GetINodeIndex ¶

func (c *Etcd) GetINodeIndex(vid torus.VolumeID) (torus.INodeID, error)

func (*Etcd) GetLease ¶

func (c *Etcd) GetLease() (int64, error)

func (*Etcd) GetPeers ¶

func (c *Etcd) GetPeers() (torus.PeerInfoList, error)

func (*Etcd) GetRing ¶

func (c *Etcd) GetRing() (torus.Ring, error)

func (*Etcd) GetVolume ¶

func (c *Etcd) GetVolume(volume string) (*models.Volume, error)

func (*Etcd) GetVolumes ¶

func (c *Etcd) GetVolumes() ([]*models.Volume, torus.VolumeID, error)

func (*Etcd) GlobalMetadata ¶

func (c *Etcd) GlobalMetadata() (torus.GlobalMetadata, error)

func (*Etcd) Kind ¶

func (e *Etcd) Kind() torus.MetadataKind

func (*Etcd) NewVolumeID ¶

func (c *Etcd) NewVolumeID() (torus.VolumeID, error)

func (*Etcd) RegisterPeer ¶

func (c *Etcd) RegisterPeer(lease int64, p *models.PeerInfo) error

func (*Etcd) RenewLease ¶ added in v0.1.1

func (c *Etcd) RenewLease(lease int64) error

func (*Etcd) SetRing ¶

func (c *Etcd) SetRing(ring torus.Ring) error

func (*Etcd) SubscribeNewRings ¶

func (e *Etcd) SubscribeNewRings(ch chan torus.Ring)

func (*Etcd) UUID ¶

func (c *Etcd) UUID() string

func (*Etcd) UnsubscribeNewRings ¶

func (e *Etcd) UnsubscribeNewRings(ch chan torus.Ring)

func (*Etcd) WithContext ¶

func (e *Etcd) WithContext(ctx context.Context) torus.MetadataService

Source Files ¶

View all Source files

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