Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CascadingWaitListener ¶
type CascadingWaitListener struct {
// contains filtered or unexported fields
}
func NewCascadingWaitListener ¶
func NewCascadingWaitListener(listeners ...Listener) *CascadingWaitListener
func (*CascadingWaitListener) Close ¶
func (this *CascadingWaitListener) Close()
func (*CascadingWaitListener) Listen ¶
func (this *CascadingWaitListener) Listen()
type CloseWaitListener ¶
type CloseWaitListener struct {
// contains filtered or unexported fields
}
func NewCloseWaitListener ¶
func NewCloseWaitListener(listener Listener) *CloseWaitListener
func (*CloseWaitListener) Close ¶
func (this *CloseWaitListener) Close()
func (*CloseWaitListener) Listen ¶
func (this *CloseWaitListener) Listen()
type CompositeListener ¶
type CompositeListener struct {
// contains filtered or unexported fields
}
func NewCompositeListener ¶
func NewCompositeListener(items ...Listener) *CompositeListener
func (*CompositeListener) Close ¶
func (this *CompositeListener) Close()
func (*CompositeListener) Listen ¶
func (this *CompositeListener) Listen()
type CompositeWaitListener ¶
type CompositeWaitListener struct {
// contains filtered or unexported fields
}
func NewCompositeWaitDelayedShutdownListener ¶ added in v1.0.1
func NewCompositeWaitDelayedShutdownListener(shutdownDelay time.Duration, listeners ...Listener) *CompositeWaitListener
func NewCompositeWaitListener ¶
func NewCompositeWaitListener(listeners ...Listener) *CompositeWaitListener
func NewCompositeWaitShutdownListener ¶
func NewCompositeWaitShutdownListener(listeners ...Listener) *CompositeWaitListener
func (*CompositeWaitListener) Close ¶
func (this *CompositeWaitListener) Close()
func (*CompositeWaitListener) Listen ¶
func (this *CompositeWaitListener) Listen()
type ListenCloser ¶
type ListenCloser interface { Listener Close() }
type Listener ¶
type Listener interface { // Listen is generally a long-running method, and should be executed within // its own goroutine so that other Listeners may run concurrently. Listen() }
Listener generally describes a struct that listens for items from one or more input channels (received in it's constructor) and optionally sends other items on one or more output channels.
type NoopListener ¶
type NoopListener struct{}
func (NoopListener) Listen ¶
func (this NoopListener) Listen()
type SerialListener ¶
type SerialListener struct {
// contains filtered or unexported fields
}
func NewSerialListener ¶
func NewSerialListener(items ...Listener) *SerialListener
func (*SerialListener) Close ¶
func (this *SerialListener) Close()
func (*SerialListener) Listen ¶
func (this *SerialListener) Listen()
type ShutdownListener ¶
type ShutdownListener struct {
// contains filtered or unexported fields
}
func NewShutdownListener ¶
func NewShutdownListener(shutdown func()) *ShutdownListener
func (*ShutdownListener) Close ¶
func (this *ShutdownListener) Close()
func (*ShutdownListener) Listen ¶
func (this *ShutdownListener) Listen()
type WaitGroupListener ¶
type WaitGroupListener struct {
// contains filtered or unexported fields
}
func NewWaitGroupListener ¶
func NewWaitGroupListener(listener Listener, waiter WaitGroup) *WaitGroupListener
func (*WaitGroupListener) Close ¶
func (this *WaitGroupListener) Close()
func (*WaitGroupListener) Listen ¶
func (this *WaitGroupListener) Listen()
Click to show internal directories.
Click to hide internal directories.