state

Documentation

Overview

Package state provides index-based state change tracking facilities.

Index

• type Tracker
  • func NewTracker() *Tracker
  • func (t *Tracker) NotifyOfChange()
  • func (t *Tracker) Poison()
  • func (t *Tracker) WaitForChange(previousIndex uint64) (uint64, bool)
• type TrackingLock
  • func NewTrackingLock(tracker *Tracker) *TrackingLock
  • func (l *TrackingLock) Lock()
  • func (l *TrackingLock) Unlock()
  • func (l *TrackingLock) UnlockWithoutNotify()

Types

type Tracker

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

Tracker provides index-based state tracking using a condition variable.

func NewTracker

func NewTracker() *Tracker

NewTracker creates a new tracker instance with state index 1.

func (*Tracker) NotifyOfChange

func (t *Tracker) NotifyOfChange()

NotifyOfChange indicates the state index and notifies waiters.

func (*Tracker) Poison

func (t *Tracker) Poison()

Poison terminates tracking.

func (*Tracker) WaitForChange

func (t *Tracker) WaitForChange(previousIndex uint64) (uint64, bool)

WaitForChange waits for a state index change from the previous index.

type TrackingLock

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

TrackingLock provides locking facilities with automatic state tracking notifications.

func NewTrackingLock

func NewTrackingLock(tracker *Tracker) *TrackingLock

NewTrackingLock creates a new tracking lock with the specified tracker.

func (*TrackingLock) Lock

func (l *TrackingLock) Lock()

Lock locks the tracking lock.

func (*TrackingLock) Unlock

func (l *TrackingLock) Unlock()

Unlock unlocks the tracking lock and triggers a state update notification.

func (*TrackingLock) UnlockWithoutNotify

func (l *TrackingLock) UnlockWithoutNotify()

UnlockWithoutNotify unlocks the tracking lock without triggering a state update notification.