Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller is used to manage and drive processor.
func New ¶
func New(evtC <-chan config.Event) (*Controller, error)
New creates a controller with given event channel.
func (*Controller) DrainListeners ¶
func (c *Controller) DrainListeners()
DrainListeners drains all processor listener.
func (*Controller) GetAllProcs ¶
func (c *Controller) GetAllProcs() []proc.Proc
GetAllProcessors return all registered processors.
Source Files
Click to show internal directories.
Click to hide internal directories.