mutex

Documentation

Overview

@Title @Description @Author Wangwengang 2024/1/8 13:09 @Update Wangwengang 2024/1/8 13:09

Index

• type EtcdMutex
  • func NewEtcdLeaseMutex(key string, client *clientv3.Client, ttl int64) (*EtcdMutex, error)
  • func NewEtcdMutex(client *clientv3.Client) (*EtcdMutex, error)
  • func (em *EtcdMutex) Close()
  • func (em *EtcdMutex) Lock(key string) error
  • func (em *EtcdMutex) Unlock(key string) error

Types

type EtcdMutex

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

func NewEtcdLeaseMutex

func NewEtcdLeaseMutex(key string, client *clientv3.Client, ttl int64) (*EtcdMutex, error)

NewEtcdLeaseMutex ttl

func NewEtcdMutex

func NewEtcdMutex(client *clientv3.Client) (*EtcdMutex, error)

NewEtcdMutex default 10s

func (*EtcdMutex) Close

func (em *EtcdMutex) Close()

func (*EtcdMutex) Lock

func (em *EtcdMutex) Lock(key string) error

Lock get lock

func (*EtcdMutex) Unlock

func (em *EtcdMutex) Unlock(key string) error