whatnot

package module

Go to main page

Versions in this module

v0

v0.8.2

Aug 17, 2022

v0.8.1

Sep 1, 2021

Changes in this version

type Namespace

+ func (ns *Namespace) FetchOrCreateAbsolutePath(path PathString) (elem *PathElement, err error)

type SemaphorePool

+ func (p *SemaphorePool) Claim(ctx context.Context, slots int64) (claim *SemaphoreClaim, err error)

type SemaphorePoolOpts

+ Prefix bool

v0.8.0

Jul 6, 2021

Changes in this version

+ const ChangePruned

+ const ChangeReleased

+ const MaxPathDepth

+ const MaxPathLength

+ var WithPruning managerOptionFunc = func() optionName

type PathElement

+ func (p *PathElement) CreateSemaphorePool(prefix bool, purge bool, opts SemaphorePoolOpts) (err error)

+ func (p *PathElement) Delete() (err error)

+ func (p *PathElement) EnablePruningAfter(age time.Duration)

+ func (p *PathElement) PreventPruning()

+ type SemaphoreClaim struct

+ func (p *SemaphoreClaim) Return() error

+ type SemaphorePool struct

+ func (p *SemaphorePool) ClaimPercentageWeighted(poolpercentage float64, timeout time.Duration) (claim *SemaphoreClaim, err error)

+ func (p *SemaphorePool) ClaimSingle(timeout time.Duration) (claim *SemaphoreClaim, err error)

+ func (p *SemaphorePool) ClaimWeighted() (claim *SemaphoreClaim, err error)

+ type SemaphorePoolOpts struct

+ PoolSize float64

v0.7.0

Feb 8, 2021

Changes in this version

+ type ConfigError struct

type NameSpaceManager

+ func (n NameSpaceManager) Debug(msg string)

+ func (n NameSpaceManager) Debugf(format string, a ...interface{})

+ func (n NameSpaceManager) Error(msg string)

+ func (n NameSpaceManager) Errorf(format string, a ...interface{})

+ func (n NameSpaceManager) Info(msg string)

+ func (n NameSpaceManager) Infof(format string, a ...interface{})

+ func (n NameSpaceManager) Warn(msg string)

+ func (n NameSpaceManager) Warnf(format string, a ...interface{})

+ type WithLogger struct

v0.6.0

Feb 7, 2021

Changes in this version

+ const ChangeAdded

+ const ChangeDeleted

+ const ChangeEdited

+ const ChangeLocked

+ const ChangeUnknown

+ const ChangeUnlocked

+ var WithRateLimit = func() optionName

+ func HealthHandler(r *http.Request, w http.ResponseWriter)

+ func Healthy() bool

type ElementWatchSubscription

+ func (n ElementWatchSubscription) Debug(msg string)

+ func (n ElementWatchSubscription) Debugf(format string, a ...interface{})

+ func (n ElementWatchSubscription) Error(msg string)

+ func (n ElementWatchSubscription) Errorf(format string, a ...interface{})

+ func (n ElementWatchSubscription) Info(msg string)

+ func (n ElementWatchSubscription) Infof(format string, a ...interface{})

+ func (n ElementWatchSubscription) Warn(msg string)

+ func (n ElementWatchSubscription) Warnf(format string, a ...interface{})

type EventMultiplexer

+ func NewEventsMultiplexer() *EventMultiplexer

+ func (n EventMultiplexer) Debug(msg string)

+ func (n EventMultiplexer) Debugf(format string, a ...interface{})

+ func (n EventMultiplexer) Error(msg string)

+ func (n EventMultiplexer) Errorf(format string, a ...interface{})

+ func (n EventMultiplexer) Info(msg string)

+ func (n EventMultiplexer) Infof(format string, a ...interface{})

+ func (n EventMultiplexer) Warn(msg string)

+ func (n EventMultiplexer) Warnf(format string, a ...interface{})

type LeaseContext

+ func (n LeaseContext) Debug(msg string)

+ func (n LeaseContext) Debugf(format string, a ...interface{})

+ func (n LeaseContext) Error(msg string)

+ func (n LeaseContext) Errorf(format string, a ...interface{})

+ func (n LeaseContext) Info(msg string)

+ func (n LeaseContext) Infof(format string, a ...interface{})

+ func (n LeaseContext) Warn(msg string)

+ func (n LeaseContext) Warnf(format string, a ...interface{})

type Logger

+ Debugf func(format string, a ...interface{})

+ Error func(msg string)

+ Errorf func(format string, a ...interface{})

+ Infof func(format string, a ...interface{})

+ Warn func(msg string)

+ Warnf func(format string, a ...interface{})

type PathElement

+ func (n PathElement) Debug(msg string)

+ func (n PathElement) Debugf(format string, a ...interface{})

+ func (n PathElement) Error(msg string)

+ func (n PathElement) Errorf(format string, a ...interface{})

+ func (n PathElement) Info(msg string)

+ func (n PathElement) Infof(format string, a ...interface{})

+ func (n PathElement) Warn(msg string)

+ func (n PathElement) Warnf(format string, a ...interface{})

v0.1.0

Feb 5, 2021

v0.0.5

Feb 5, 2021

Changes in this version

+ const ADDED

+ const DELETED

+ const EDITED

+ const LOCKED

+ const LOCKING_FAIL_TIMEOUT

+ const UNKNOWN

+ const UNLOCKED

+ var WithAcls = func() optionName

+ var WithDeadlockBreak = func() optionName

+ var WithGossip = func() optionName

+ var WithRaft = func() optionName

+ var WithTrace = func() optionName

+ type AbsolutePath []SubPath

+ func (m AbsolutePath) SubtractPath(path AbsolutePath) PathString

+ func (m AbsolutePath) ToPathString() PathString

+ type ElementValue struct

+ Val interface{}

+ type ElementWatchSubscription struct

+ func (m *ElementWatchSubscription) Events() <-chan WatchEvent

+ type EventMultiplexer struct

+ Broadcast chan<- WatchEvent

+ func (t *EventMultiplexer) BroadcastAsync(evt WatchEvent)

+ func (t *EventMultiplexer) Register(ch chan<- WatchEvent)

+ func (t *EventMultiplexer) Unregister(ch chan<- WatchEvent)

+ type LeaseContext struct

+ func (l *LeaseContext) Cancel()

+ func (l *LeaseContext) Deadline() (time.Time, bool)

+ func (l *LeaseContext) Done() <-chan struct{}

+ func (l *LeaseContext) Err() error

+ func (l *LeaseContext) Value(key interface{}) interface{}

+ type Logger interface

+ Debug func(msg string)

+ Info func(msg string)

+ type ManagerOption func() optionName

+ type NameSpaceManager struct

+ func NewNamespaceManager(opts ...ManagerOption) *NameSpaceManager

+ func (m *NameSpaceManager) FetchNamespace(name string) (ns *Namespace, err error)

+ func (m *NameSpaceManager) RegisterNamespace(ns *Namespace) error

+ func (m *NameSpaceManager) UnRegisterNamespace(ns *Namespace) error

+ func (m *NameSpaceManager) WithLogger(l Logger) *NameSpaceManager

+ type Namespace struct

+ func NewNamespace(name string) (ns *Namespace)

+ func (m *Namespace) FetchAbsolutePath(path PathString) *PathElement

+ func (m *Namespace) FetchAllAbsolutePaths() (allpaths []AbsolutePath, err error)

+ func (m *Namespace) FindPathTail(path PathString) *PathElement

+ func (m *Namespace) RegisterAbsolutePath(path AbsolutePath) error

+ func (m *Namespace) WatchEventsOnPath()

+ type NamespaceManagerOpt interface

+ type PathElement struct

+ func (m *PathElement) AbsolutePath() (path AbsolutePath)

+ func (m *PathElement) Add(path SubPath) (elem *PathElement, err error)

+ func (m *PathElement) AppendRelativePath(subPath PathString) (*PathElement, error)

+ func (m *PathElement) Chain() (chain []*PathElement)

+ func (m *PathElement) ContextLockPrefixWithLease(octx context.Context, ttl time.Duration) (ctx *LeaseContext, release func(), err error)

+ func (m *PathElement) ContextLockWithLease(octx context.Context, ttl time.Duration) (ctx *LeaseContext, release func(), err error)

+ func (m *PathElement) FetchAllSubPaths() (allpaths [][]SubPath, err error)

+ func (m *PathElement) FetchClosestSubPath(subPath PathString) (pathchain []*PathElement)

+ func (m *PathElement) FetchSubPath(subPath PathString) (*PathElement, error)

+ func (m *PathElement) GetValue() (value ElementValue)

+ func (m *PathElement) Lock()

+ func (m *PathElement) LockPrefixWithLease(ttl time.Duration) (ctx *LeaseContext, release func(), err error)

+ func (m *PathElement) LockSubs()

+ func (m *PathElement) LockWithLease(ttl time.Duration) (ctx *LeaseContext, release func(), err error)

+ func (m *PathElement) Parent() *PathElement

+ func (m *PathElement) ParentChain() (parents []*PathElement)

+ func (m *PathElement) SetValue(value ElementValue, change changeType, actor access.Role)

+ func (m *PathElement) SubPath() (path SubPath)

+ func (m *PathElement) SubscribeToEvents(prefix bool) *ElementWatchSubscription

+ func (m *PathElement) UnLock()

+ func (m *PathElement) UnLockSubs()

+ func (m *PathElement) UnSubscribeFromEvents() error

+ func (m PathElement) FetchClosestSubPathTail(subPath PathString) *PathElement

+ type PathElementPermission struct

+ func (p *PathElementPermission) ApprovedAction()

+ type PathError struct

+ type PathString string

+ func (m PathString) ToAbsolutePath() AbsolutePath

+ func (m PathString) ToRelativePath() RelativePath

+ type PathSubscription struct

+ type RelativePath []SubPath

+ type SubPath string

+ func (m SubPath) Validate() error

+ type WatchEvent struct

+ Actor access.Role

+ Change changeType

+ Note string

+ TS time.Time

+ func (e WatchEvent) OnElement() *PathElement

+ type WatchEvents chan WatchEvent

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