utils

Documentation

Index

• func JoinErrors(errors []error, sep string) string
• type Cond
  • func NewCond(l sync.Locker) *Cond
  • func (c *Cond) Broadcast()
  • func (c *Cond) NotifyChan() <-chan struct{}
  • func (c *Cond) Wait()
  • func (c *Cond) WaitWithTimeout(t time.Duration)

Functions

func JoinErrors

func JoinErrors(errors []error, sep string) string

JoinErrors объединяет ошибки из массива в строку с разделителем sep

Types

type Cond

type Cond struct {
	L sync.Locker
	// contains filtered or unexported fields
}

Cond is a conditional variable implementation that uses channels for notifications. Only supports .Broadcast() method, however supports timeout based Wait() calls unlike regular sync.Cond.

func NewCond

func NewCond(l sync.Locker) *Cond

NewCond creates a new condition lock object

func (*Cond) Broadcast

func (c *Cond) Broadcast()

Broadcast call notifies everyone that something has changed.

func (*Cond) NotifyChan

func (c *Cond) NotifyChan() <-chan struct{}

NotifyChan returns a channel that can be used to wait for next Broadcast() call.

func (*Cond) Wait

func (c *Cond) Wait()

Wait is waits for Broadcast calls. Similar to regular sync.Cond, this unlocks the underlying locker first, waits on changes and re-locks it before returning.

func (*Cond) WaitWithTimeout

func (c *Cond) WaitWithTimeout(t time.Duration)

WaitWithTimeout is same as Wait() call, but will only wait up to a given timeout.