listeners

package module
v1.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 11, 2023 License: MIT Imports: 7 Imported by: 2

README

SMARTY DISCLAIMER: Subject to the terms of the associated license agreement, this software is freely available for your use. This software is FREE, AS IN PUPPIES, and is a gift. Enjoy your new responsibility. This means that while we may consider enhancement requests, we may or may not choose to entertain requests at our sole and absolute discretion.

Build Status Code Coverage Go Report Card GoDoc

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 WaitGroup

type WaitGroup interface {
	Add(delta int)
	Done()
	Wait()
}

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()

Jump to

Keyboard shortcuts

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