gate

Documentation

Index

• type AutoReset
  • func NewAutoReset(set bool) *AutoReset
  • func (gate *AutoReset) Set()
  • func (gate *AutoReset) Wait() <-chan Empty
• type Empty
• type ManualReset
  • func NewManualReset(set bool) *ManualReset
  • func (signal *ManualReset) Reset()
  • func (gate *ManualReset) Set()
  • func (signal *ManualReset) Wait() <-chan Empty
• type SafeChannel
  • func NewSafeChannel() *SafeChannel
  • func (channel *SafeChannel) IsClosed() bool
  • func (channel *SafeChannel) SafeClose()
  • func (channel *SafeChannel) Set() bool
• type Waiter

Types

type AutoReset

type AutoReset struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewAutoReset

func NewAutoReset(set bool) *AutoReset

func (*AutoReset) Set

func (gate *AutoReset) Set()

func (*AutoReset) Wait

func (gate *AutoReset) Wait() <-chan Empty

type Empty

type Empty struct{}

type ManualReset

type ManualReset struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewManualReset

func NewManualReset(set bool) *ManualReset

NewManualReset

set: init status

func (*ManualReset) Reset

func (signal *ManualReset) Reset()

func (*ManualReset) Set

func (gate *ManualReset) Set()

func (*ManualReset) Wait

func (signal *ManualReset) Wait() <-chan Empty

type SafeChannel

type SafeChannel struct {
	C chan Empty
	// contains filtered or unexported fields
}

func NewSafeChannel

func NewSafeChannel() *SafeChannel

func (*SafeChannel) IsClosed

func (channel *SafeChannel) IsClosed() bool

func (*SafeChannel) SafeClose

func (channel *SafeChannel) SafeClose()

func (*SafeChannel) Set

func (channel *SafeChannel) Set() bool

type Waiter

type Waiter interface {
	Wait() <-chan struct{}
}