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
• type Service
• type ServiceRegistration

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)
	IsLocked(context.Context, string) (bool, error)
	Unlock(context.Context, string) error

	Register(context.Context, *ServiceRegistration) error
	Deregister(string) error

	List(context.Context, string) (map[string]string, error)
	WatchServices(context.Context, string, []string, chan<- []*Service, time.Duration) error

	Stop() error
	SetLogger(*log.Logger)
}

type Option

type Option func(Locker)

func WithLogger

func WithLogger(logger *log.Logger) Option

type Service

type Service struct {
	ID      string
	Address string
	Tags    []string
}

type ServiceRegistration

type ServiceRegistration struct {
	ID      string
	Name    string
	Address string
	Port    int
	Tags    []string
	TTL     time.Duration
}