etcd

Documentation

Index

• func InitContext(c context.Context)
• func InitLogger(logger *zap.SugaredLogger)
• type Config
  • func (ec Config) GetTimeoutDuration(parentContext context.Context) (context.Context, context.CancelFunc)
  • func (ec *Config) SetDefaults()
• type Locker
  • func NewEtcdLocker(config Config) Locker
  • func (el *Locker) Close()
  • func (el *Locker) Lock()
  • func (el *Locker) UnLock()

Functions

func InitContext

func InitContext(c context.Context)

func InitLogger

func InitLogger(logger *zap.SugaredLogger)

Types

type Config

type Config struct {
	Endpoints   []string `yaml:"endpoints"`
	LockKey     string   `yaml:"lockKey"`
	LockTimeout string   `yaml:"lockTimeout"`
}

func (Config) GetTimeoutDuration

func (ec Config) GetTimeoutDuration(parentContext context.Context) (context.Context, context.CancelFunc)

func (*Config) SetDefaults

func (ec *Config) SetDefaults()

type Locker

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

func NewEtcdLocker

func NewEtcdLocker(config Config) Locker

func (*Locker) Close

func (el *Locker) Close()

func (*Locker) Lock

func (el *Locker) Lock()

func (*Locker) UnLock

func (el *Locker) UnLock()