locker

Documentation

Index

• Variables
• type AerospikeLocker
  • func NewAearospikeLocker(client *aerospike.Client, namespace string) *AerospikeLocker
  • func (al *AerospikeLocker) Lock(name string) (Releaser, bool, error)
  • func (al *AerospikeLocker) LockWait(name string) (Releaser, error)
• type AerospikeReleaser
  • func NewAerospikeReleaser(locker *AerospikeLocker, stop chan bool, key *aerospike.Key) *AerospikeReleaser
  • func (ar *AerospikeReleaser) Release() error
• type Locker
• type Releaser

Variables

var Logger = log.New(os.Stderr, "", log.LstdFlags)

Types

type AerospikeLocker

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

func NewAearospikeLocker

func NewAearospikeLocker(client *aerospike.Client, namespace string) *AerospikeLocker

func (*AerospikeLocker) Lock

func (al *AerospikeLocker) Lock(name string) (Releaser, bool, error)

func (*AerospikeLocker) LockWait

func (al *AerospikeLocker) LockWait(name string) (Releaser, error)

type AerospikeReleaser

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

func NewAerospikeReleaser

func NewAerospikeReleaser(locker *AerospikeLocker, stop chan bool, key *aerospike.Key) *AerospikeReleaser

func (*AerospikeReleaser) Release

func (ar *AerospikeReleaser) Release() error

type Locker

type Locker interface {
	Lock(string) (releaser Releaser, success bool, err error)
	LockWait(string) (releaser Releaser, err error)
}

type Releaser

type Releaser interface {
	Release() error
}