unison

package

Go to main page

Versions in this module

v0

v0.3.0

Jun 20, 2024

v0.2.0

May 29, 2021

Changes in this version

type TaskGroup

+ MaxErrors int

+ OnQuit TaskGroupQuitHandler

+ func (t *TaskGroup) Context() context.Context

+ func (t *TaskGroup) Wait() error

+ type TaskGroupQuitHandler func(error) (TaskGroupStopAction, error)

+ type TaskGroupStopAction uint

+ const TaskGroupStopActionContinue

+ const TaskGroupStopActionRestart

+ const TaskGroupStopActionShutdown

+ func ContinueOnErrors(err error) (TaskGroupStopAction, error)

+ func RestartOnError(err error) (TaskGroupStopAction, error)

+ func StopAll(err error) (TaskGroupStopAction, error)

+ func StopOnError(err error) (TaskGroupStopAction, error)

+ func StopOnErrorOrCancel(err error) (TaskGroupStopAction, error)

v0.1.0

Jan 29, 2021

Changes in this version

+ type Cell struct

+ func NewCell(st interface{}) *Cell

+ func (c *Cell) Get() interface{}

+ func (c *Cell) Set(st interface{})

+ func (c *Cell) Wait(cancel Canceler) (interface{}, error)

type SafeWaitGroup

+ func SafeWaitGroupWithCancel(parent Canceler) *SafeWaitGroup

type TaskGroup

+ func TaskGroupWithCancel(canceler Canceler) *TaskGroup

v0.0.4

Aug 13, 2020

v0.0.3

Jun 18, 2020

v0.0.2

Apr 29, 2020

Changes in this version

+ var ErrGroupClosed = errors.New("group closed")

+ type Canceler interface

+ Done func() <-chan struct{}

+ Err func() error

+ type Group interface

+ Go func(fn func(Canceler) error) error

+ func ClosedGroup(reportedError error) Group

+ type MultiErrGroup struct

+ func (g *MultiErrGroup) Go(fn func() error)

+ func (g *MultiErrGroup) Wait() []error

+ type SafeWaitGroup struct

+ func (s *SafeWaitGroup) Add(n int) error

+ func (s *SafeWaitGroup) Close()

+ func (s *SafeWaitGroup) Done()

+ func (s *SafeWaitGroup) Wait()

+ type TaskGroup struct

+ StopOnError func(err error) bool

+ func (t *TaskGroup) Go(fn func(Canceler) error) error

+ func (t *TaskGroup) Stop() error

v0.0.1

Mar 25, 2020

Changes in this version

+ type LockManager struct

+ func NewLockManager() *LockManager

+ func (m *LockManager) Access(key string) *ManagedLock

+ func (m *LockManager) ForceUnlock(key string)

+ func (m *LockManager) ForceUnlockAll()

+ type LockOption interface

+ type LockSession struct

+ func (s *LockSession) Done() <-chan struct{}

+ func (s *LockSession) LockLost() <-chan struct{}

+ func (s *LockSession) Unlocked() <-chan struct{}

+ type ManagedLock struct

+ func (ml *ManagedLock) IsLocked() bool

+ func (ml *ManagedLock) Key() string

+ func (ml *ManagedLock) Lock(opts ...LockOption) *LockSession

+ func (ml *ManagedLock) LockContext(context doneContext, opts ...LockOption) (*LockSession, error)

+ func (ml *ManagedLock) LockTimeout(duration time.Duration, opts ...LockOption) (*LockSession, bool)

+ func (ml *ManagedLock) TryLock(opts ...LockOption) (*LockSession, bool)

+ func (ml *ManagedLock) Unlock()

+ type Mutex struct

+ func MakeMutex() Mutex

+ func (c Mutex) Await() <-chan struct{}

+ func (c Mutex) Lock()

+ func (c Mutex) LockContext(context doneContext) error

+ func (c Mutex) LockTimeout(duration time.Duration) bool

+ func (c Mutex) TryLock() bool

+ func (c Mutex) Unlock()

+ type TxExclusiveLock TxLock

+ func (l *TxExclusiveLock) Lock()

+ func (l *TxExclusiveLock) Unlock()

+ type TxLock struct

+ func NewTxLock() *TxLock

+ func (l *TxLock) Exclusive() *TxExclusiveLock

+ func (l *TxLock) Get(readonly bool) sync.Locker

+ func (l *TxLock) Pending() *TxPendingLock

+ func (l *TxLock) Reserved() *TxReservedLock

+ func (l *TxLock) Shared() *TxSharedLock

+ type TxPendingLock TxLock

+ func (l *TxPendingLock) Lock()

+ func (l *TxPendingLock) Unlock()

+ type TxReservedLock TxLock

+ func (l *TxReservedLock) Lock()

+ func (l *TxReservedLock) Unlock()

+ type TxSharedLock TxLock

+ func (l *TxSharedLock) Lock()

+ func (l *TxSharedLock) Unlock()

+ type WithSignalCallbacks struct

+ Done func()

+ Lost func()

+ Unlocked func()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL