xsync

package

v3.66.3 Latest Latest Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ydb-platform/ydb-go-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

func NewLastUsage(opts ...lastUsageOption) *lastUsage
func OnceFunc(f func(ctx context.Context) error) func(ctx context.Context) error
func WithClock(clock clockwork.Clock) lastUsageOption
type EventBroadcast
- func (b *EventBroadcast) Broadcast()
- func (b *EventBroadcast) Waiter() OneTimeWaiter
type LastUsage
type Mutex
- func (l *Mutex) WithLock(f func())
type Once
- func OnceValue[T closer.Closer](f func() T) *Once[T]
- func (v *Once[T]) Close(ctx context.Context) (err error)
- func (v *Once[T]) Get() T
type OneTimeWaiter
- func (w *OneTimeWaiter) Done() <-chan struct{}
type RWMutex
- func (l *RWMutex) WithLock(f func())
- func (l *RWMutex) WithRLock(f func())

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewLastUsage ¶ added in v3.65.0

func NewLastUsage(opts ...lastUsageOption) *lastUsage

func OnceFunc ¶ added in v3.58.0

func OnceFunc(f func(ctx context.Context) error) func(ctx context.Context) error

func WithClock ¶ added in v3.65.0

func WithClock(clock clockwork.Clock) lastUsageOption

Types ¶

type EventBroadcast ¶ added in v3.38.0

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

EventBroadcast is implementation of broadcast notify about event Zero value is usable, must not copy after first call any method

func (*EventBroadcast) Broadcast ¶ added in v3.38.0

func (b *EventBroadcast) Broadcast()

func (*EventBroadcast) Waiter ¶ added in v3.38.0

func (b *EventBroadcast) Waiter() OneTimeWaiter

Waiter return channel, that will close when next event will be broadcast. For prevent race between subscribe and event client code must subscribe at first, then check condition if false - wait closing channed and check condition again

type LastUsage ¶ added in v3.65.0

type LastUsage interface {
	Get() time.Time
	Start() (stop func())
}

type Mutex ¶

type Mutex struct {
	sync.Mutex
}

func (*Mutex) WithLock ¶

func (l *Mutex) WithLock(f func())

type Once ¶ added in v3.59.0

type Once[T closer.Closer] struct {
	// contains filtered or unexported fields
}

func OnceValue ¶ added in v3.58.0

func OnceValue[T closer.Closer](f func() T) *Once[T]

func (*Once[T]) Close ¶ added in v3.59.0

func (v *Once[T]) Close(ctx context.Context) (err error)

func (*Once[T]) Get ¶ added in v3.59.0

func (v *Once[T]) Get() T

type OneTimeWaiter ¶ added in v3.38.0

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

func (*OneTimeWaiter) Done ¶ added in v3.38.0

func (w *OneTimeWaiter) Done() <-chan struct{}

type RWMutex ¶

type RWMutex struct {
	sync.RWMutex
}

func (*RWMutex) WithLock ¶

func (l *RWMutex) WithLock(f func())

func (*RWMutex) WithRLock ¶

func (l *RWMutex) WithRLock(f func())

Source Files ¶

View all Source files

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