common

Documentation

Index

• Constants
• func TestStart(removeData bool) error
• func TestStop() error
• func Version(uri string, options map[string]string) (string, error)
• type EtcdCommon
  • func NewEtcdCommon(options map[string]string) EtcdCommon
• type EtcdLock
• type LockerIDInfo

Constants

const (
	// DefaultRetryCount for etcd operations
	DefaultRetryCount = 60
	// DefaultIntervalBetweenRetries for etcd failed operations
	DefaultIntervalBetweenRetries = time.Millisecond * 500
	// Bootstrap key
	Bootstrap = "kvdb/bootstrap"
	// DefaultDialTimeout in etcd http requests
	// the maximum amount of time a dial will wait for a connection to setup.
	// 30s is long enough for most of the network conditions.
	DefaultDialTimeout = 30 * time.Second
	// DefaultLockTTL is the ttl for an etcd lock
	DefaultLockTTL = 16
	// DefaultLockRefreshDuration is the time interval for refreshing an etcd lock
	DefaultLockRefreshDuration = 2 * time.Second
)

Functions

func TestStart

func TestStart(removeData bool) error

TestStart starts test

func TestStop

func TestStop() error

TestStop stops test

func Version

func Version(uri string, options map[string]string) (string, error)

Version returns the version of the provided etcd server

Types

type EtcdCommon

type EtcdCommon interface {
	// GetAuthInfoFromOptions
	GetAuthInfoFromOptions() (transport.TLSInfo, string, string, error)

	// GetRetryCount
	GetRetryCount() int

	// IsTLSEnabled returns TRUE if SSL is enabled in options
	IsTLSEnabled() bool
}

EtcdCommon defined the common functions between v2 and v3 etcd implementations.

func NewEtcdCommon

func NewEtcdCommon(options map[string]string) EtcdCommon

NewEtcdCommon returns the EtcdCommon interface

type EtcdLock

type EtcdLock struct {
	Done            chan struct{}
	Unlocked        bool
	Err             error
	Tag             string
	AcquisitionTime time.Time
	sync.Mutex
}

EtcdLock combines Mutex and channel

type LockerIDInfo

type LockerIDInfo struct {
	LockerID string
}

LockerIDInfo id of locker