events

type DeferredResponder struct {
	// contains filtered or unexported fields
}

type DeferredResponderHandlerChalk struct {
	// contains filtered or unexported fields
}

type DeferredResponseManager struct {
	// contains filtered or unexported fields
}

type DeferredResponsePreHandler func(http.ResponseWriter, *http.Request) (error, string)

type DeferredResponsePreHandler3 func(http.ResponseWriter, *http.Request, httprouter.Params) (error, string)

type EventCallback func(dat *ResponderData, id string, events []*MaestroEvent) //(stop bool, remove bool)

type EventHandler interface {
	// a simple function which is called when new Events
	// are available on 'channel' eventChannel
	HandleEventNotify(channel string)

	// called when a channel is dropping events
	// May do something with the events, or may just
	// ignore them
	HandleEventOverflow(channel string, events []*MaestroEvent)
}

type EventManagerReadyCB func() error

type EventSubscription interface {
	GetChannel() (bool, chan *MaestroEvent)
	// call when the channel is not being waiting on
	ReleaseChannel()
	// close the subscription entirely
	Close()
	GetID() string
	IsClosed() bool
}

type HttpHandler func(http.ResponseWriter, *http.Request)

type HttpHandler3 func(http.ResponseWriter, *http.Request, httprouter.Params)

type MaestroEvent struct {

	// some data, usually JSON encodable
	Data interface{} `json:"data"`
	// contains filtered or unexported fields
}

type MaestroEventBaton struct {
	// contains filtered or unexported fields
}

type MaestroEventError struct {
	// contains filtered or unexported fields
}

type ResponderData struct {
	Writer  http.ResponseWriter
	Request *http.Request
	Params  httprouter.Params
}

type ResponderSubscriptionClosedCallback func(dat *ResponderData, id string)