zsync

Documentation

Index

• type AggregateError
  • func (ae *AggregateError) Error() string
• type Promise
  • func NewPromise[T any](executor func() (T, error)) *Promise[T]
  • func NewPromiseContext[T any](ctx context.Context, executor func() (T, error)) *Promise[T]
  • func PromiseAll[T any](promises ...*Promise[T]) *Promise[[]T]
  • func PromiseAllContext[T any](ctx context.Context, promises ...*Promise[T]) *Promise[[]T]
  • func PromiseAny[T any](promises ...*Promise[T]) *Promise[T]
  • func PromiseAnyContext[T any](ctx context.Context, promises ...*Promise[T]) *Promise[T]
  • func PromiseRace[T any](promises ...*Promise[T]) *Promise[T]
  • func PromiseRaceContext[T any](ctx context.Context, promises ...*Promise[T]) *Promise[T]
  • func (p *Promise[T]) Catch(rejected func(error) (T, error)) *Promise[T]
  • func (p *Promise[T]) Done() (value T, reason error)
  • func (p *Promise[T]) Finally(finally func()) *Promise[T]
  • func (p *Promise[T]) Then(fulfilled func(T) (T, error), rejected ...func(error) (T, error)) *Promise[T]
• type PromiseState
• type RBMutex
  • func NewRBMutex() *RBMutex
  • func (mu *RBMutex) Lock()
  • func (mu *RBMutex) RLock() *RToken
  • func (mu *RBMutex) RUnlock(t *RToken)
  • func (mu *RBMutex) Unlock()
• type RToken
• type WaitGroup
  • func (h *WaitGroup) Add(delta int)
  • func (h *WaitGroup) Done()
  • func (h *WaitGroup) Go(f func())
  • func (h *WaitGroup) GoTry(f func())
  • func (h *WaitGroup) Wait() error

Types

type AggregateError

type AggregateError struct {
	Errors []error
}

func (*AggregateError) Error

func (ae *AggregateError) Error() string

type Promise

type Promise[T any] struct {
	// contains filtered or unexported fields
}

func NewPromise

func NewPromise[T any](executor func() (T, error)) *Promise[T]

func NewPromiseContext

func NewPromiseContext[T any](ctx context.Context, executor func() (T, error)) *Promise[T]

func PromiseAll

func PromiseAll[T any](promises ...*Promise[T]) *Promise[[]T]

func PromiseAllContext

func PromiseAllContext[T any](ctx context.Context, promises ...*Promise[T]) *Promise[[]T]

func PromiseAny

func PromiseAny[T any](promises ...*Promise[T]) *Promise[T]

func PromiseAnyContext

func PromiseAnyContext[T any](ctx context.Context, promises ...*Promise[T]) *Promise[T]

func PromiseRace

func PromiseRace[T any](promises ...*Promise[T]) *Promise[T]

func PromiseRaceContext

func PromiseRaceContext[T any](ctx context.Context, promises ...*Promise[T]) *Promise[T]

func (*Promise[T]) Catch

func (p *Promise[T]) Catch(rejected func(error) (T, error)) *Promise[T]

func (*Promise[T]) Done

func (p *Promise[T]) Done() (value T, reason error)

func (*Promise[T]) Finally

func (p *Promise[T]) Finally(finally func()) *Promise[T]

func (*Promise[T]) Then

func (p *Promise[T]) Then(fulfilled func(T) (T, error), rejected ...func(error) (T, error)) *Promise[T]

type PromiseState

type PromiseState uint8

type RBMutex

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

RBMutex is a reader biased reader/writer mutual exclusion lock

func NewRBMutex

func NewRBMutex() *RBMutex

NewRBMutex creates a new RBMutex instance

func (*RBMutex) Lock

func (mu *RBMutex) Lock()

func (*RBMutex) RLock

func (mu *RBMutex) RLock() *RToken

func (*RBMutex) RUnlock

func (mu *RBMutex) RUnlock(t *RToken)

func (*RBMutex) Unlock

func (mu *RBMutex) Unlock()

type RToken

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

type WaitGroup

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

func (*WaitGroup) Add

func (h *WaitGroup) Add(delta int)

func (*WaitGroup) Done

func (h *WaitGroup) Done()

func (*WaitGroup) Go

func (h *WaitGroup) Go(f func())

func (*WaitGroup) GoTry

func (h *WaitGroup) GoTry(f func())

func (*WaitGroup) Wait

func (h *WaitGroup) Wait() error