memorylocker

Documentation

Overview

Package memorylocker provides an in-memory locking mechanism.

When multiple processes are attempting to access an upload, whether it be by reading or writing, a synchronization mechanism is required to prevent data corruption, especially to ensure correct offset values and the proper order of chunks inside a single upload.

MemoryLocker persists locks using memory and therefore allowing a simple and cheap mechanism. Locks will only exist as long as this object is kept in reference and will be erased if the program exits.

Index

• type MemoryLocker
  • func New() *MemoryLocker
  • func (locker *MemoryLocker) NewLock(id string) (handler.Lock, error)
  • func (locker *MemoryLocker) UseIn(composer *handler.StoreComposer)

Types

type MemoryLocker

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

MemoryLocker persists locks using memory and therefore allowing a simple and cheap mechanism. Locks will only exist as long as this object is kept in reference and will be erased if the program exits.

func New

func New() *MemoryLocker

New creates a new in-memory locker.

func (*MemoryLocker) NewLock

func (locker *MemoryLocker) NewLock(id string) (handler.Lock, error)

func (*MemoryLocker) UseIn

func (locker *MemoryLocker) UseIn(composer *handler.StoreComposer)

UseIn adds this locker to the passed composer.