lock

Documentation

Index

• Variables
• type DynamoDBLockManager
  • func NewDynamoDBLockManagerWithUri(uri string, logger *zap.Logger) (*DynamoDBLockManager, error)
  • func (m *DynamoDBLockManager) Close() error
  • func (m *DynamoDBLockManager) Lock() (int64, error)
  • func (m *DynamoDBLockManager) Unlock() error
• type EtcdLockManager
  • func NewEtcdLockManagerWithUri(uri string, logger *zap.Logger) (*EtcdLockManager, error)
  • func (m *EtcdLockManager) Close() error
  • func (m *EtcdLockManager) Lock() (int64, error)
  • func (m *EtcdLockManager) Unlock() error
• type LockManager
  • func NewLockManagerWithUri(uri string, logger *zap.Logger) (LockManager, error)
• type SchemeType

Variables

var (
	SchemeType_name = map[SchemeType]string{
		SchemeTypeUnknown:  "unknown",
		SchemeTypeEtcd:     "etcd",
		SchemeTypeDynamoDB: "dynamodb",
	}
	SchemeType_value = map[string]SchemeType{
		"unknown": SchemeTypeUnknown,
		"etcd":    SchemeTypeEtcd,
		"dynamo":  SchemeTypeDynamoDB,
	}
)

Enum value maps for SchemeType.

Types

type DynamoDBLockManager

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

func NewDynamoDBLockManagerWithUri

func NewDynamoDBLockManagerWithUri(uri string, logger *zap.Logger) (*DynamoDBLockManager, error)

func (*DynamoDBLockManager) Close

func (m *DynamoDBLockManager) Close() error

func (*DynamoDBLockManager) Lock

func (m *DynamoDBLockManager) Lock() (int64, error)

func (*DynamoDBLockManager) Unlock

func (m *DynamoDBLockManager) Unlock() error

type EtcdLockManager

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

func NewEtcdLockManagerWithUri

func NewEtcdLockManagerWithUri(uri string, logger *zap.Logger) (*EtcdLockManager, error)

func (*EtcdLockManager) Close

func (m *EtcdLockManager) Close() error

func (*EtcdLockManager) Lock

func (m *EtcdLockManager) Lock() (int64, error)

func (*EtcdLockManager) Unlock

func (m *EtcdLockManager) Unlock() error

type LockManager

type LockManager interface {
	Lock() (int64, error)
	Unlock() error
	Close() error
}

func NewLockManagerWithUri

func NewLockManagerWithUri(uri string, logger *zap.Logger) (LockManager, error)

type SchemeType

type SchemeType int

const (
	SchemeTypeUnknown SchemeType = iota
	SchemeTypeEtcd
	SchemeTypeDynamoDB
)