cassandra

Documentation

Index

• type Lock
  • func NewLock(session cassandra.Session, tenantID string) *Lock
  • func (l *Lock) Acquire(resource string, ttl time.Duration) (bool, error)
  • func (l *Lock) Forfeit(resource string) (bool, error)

Types

type Lock

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

Lock is a distributed lock based off Cassandra.

func NewLock

func NewLock(session cassandra.Session, tenantID string) *Lock

NewLock creates a new instance of a distributed locking mechanism based off Cassandra.

func (*Lock) Acquire

func (l *Lock) Acquire(resource string, ttl time.Duration) (bool, error)

Acquire acquires a lease around a given resource. NB. Cassandra only allows ttl of seconds granularity

func (*Lock) Forfeit

func (l *Lock) Forfeit(resource string) (bool, error)

Forfeit forfeits an existing lease around a given resource.