coordinator

Documentation

Index

• func Acquire(ctx context.Context, agentID, resourceID string) error
• func Global() *muxcoord.Coordinator
• func Release(agentID, resourceID string) error
• func ReleaseAll(agentID string)

Functions

func Acquire

func Acquire(ctx context.Context, agentID, resourceID string) error

Acquire acquires a lock on a resource for the given agent. Convenience wrapper around Global().Acquire().

func Global

func Global() *muxcoord.Coordinator

Global returns the singleton coordinator instance. Thread-safe via sync.Once.

func Release

func Release(agentID, resourceID string) error

Release releases a lock on a resource. Convenience wrapper around Global().Release().

func ReleaseAll

func ReleaseAll(agentID string)

ReleaseAll releases all locks held by the given agent. Convenience wrapper around Global().ReleaseAll().