lockers

Documentation

Index

• Variables
• func DecodeConfig(src, dst interface{}) error
• func Register(name string, initFn Initializer)
• type Initializer
• type Locker
• type Option
  • func WithLogger(logger *log.Logger) Option

Variables

var (
	ErrCanceled = errors.New("canceled")
)

var LockerTypes = []string{
	"consul",
}

var Lockers = map[string]Initializer{}

Functions

func DecodeConfig

func DecodeConfig(src, dst interface{}) error

func Register

func Register(name string, initFn Initializer)

Types

type Initializer

type Initializer func() Locker

type Locker

type Locker interface {
	Init(context.Context, map[string]interface{}, ...Option) error
	Lock(context.Context, string, []byte) (bool, error)
	KeepLock(context.Context, string) (chan struct{}, chan error)
	Unlock(string) error
	Stop() error
	SetLogger(*log.Logger)
}

type Option

type Option func(Locker)

func WithLogger

func WithLogger(logger *log.Logger) Option