listening

Documentation

Index

• func RunAll(listeners []Listener) *sync.WaitGroup
• func SigHandler() <-chan struct{}
• type Listener

Functions

func RunAll

func RunAll(listeners []Listener) *sync.WaitGroup

func SigHandler

func SigHandler() <-chan struct{}

setup a signal hander to gracefully exit

Types

type Listener

type Listener interface {
	// Generics when?
	AddEvent(interface{})
	UpdateEvent(interface{}, interface{})
	DeleteEvent(interface{})
	Run(<-chan struct{})
}