Versions in this module Expand all Collapse all v0 v0.11.0 Apr 5, 2018 v0.10.0 Feb 15, 2018 Changes in this version + func Error(err error) error + func Errorf(format string, args ...interface{}) error + func Register(t reflect.Type, fct FactoryFunc) + func Registry() []string + type App interface + Msg func() MsgStream + Scripter func() Scripter + func NewApp() App + type Component interface + Name func() string + Type func() string + type ComponentMgr interface + Component func(n string) Component + Components func() []Component + HasComponent func(n string) bool + New func(t, n string) (Component, error) + type Configurer interface + Configure func(ctx Context) error + type Context interface + ID func() int64 + Msg func() MsgStream + Slot func() int + Store func() Store + Svc func(n string) (Svc, error) + type DeclPorter interface + DeclInPort func(name string, t reflect.Type) error + DeclOutPort func(name string, t reflect.Type) error + type Deleter interface + Delete func() error + type FSMStater interface + FSMState func() fsm.State + type FactoryFunc func(t, n string, mgr App) (Component, error) + type H1D struct + Hist *hbook.H1D + ID HID + func (h H1D) Name() string + func (h H1D) Value() interface{} + type H2D struct + Hist *hbook.H2D + ID HID + func (h H2D) Name() string + func (h H2D) Value() interface{} + type HID string + type Hist interface + Name func() string + Value func() interface{} + type HistSvc interface + BookH1D func(name string, nbins int, xmin, xmax float64) (H1D, error) + BookH2D func(name string, nx int, xmin, xmax float64, ny int, ymin, ymax float64) (H2D, error) + BookP1D func(name string, nbins int, xmin, xmax float64) (P1D, error) + BookS2D func(name string) (S2D, error) + FillH1D func(id HID, x, w float64) + FillH2D func(id HID, x, y, w float64) + FillP1D func(id HID, x, y, w float64) + FillS2D func(id HID, x, y float64) + type InputStream struct + func (tsk *InputStream) Configure(ctx Context) error + func (tsk *InputStream) Process(ctx Context) error + func (tsk *InputStream) StartTask(ctx Context) error + func (tsk *InputStream) StopTask(ctx Context) error + type InputStreamer interface + Connect func(ports []Port) error + Disconnect func() error + Read func(ctx Context) error + type Level int + const LvlDebug + const LvlError + const LvlInfo + const LvlWarning + func (lvl Level) String() string + type MsgStream interface + Debugf func(format string, a ...interface{}) (int, error) + Errorf func(format string, a ...interface{}) (int, error) + Infof func(format string, a ...interface{}) (int, error) + Msg func(lvl Level, format string, a ...interface{}) (int, error) + Warnf func(format string, a ...interface{}) (int, error) + func NewMsgStream(name string, lvl Level, w WriteSyncer) MsgStream + type OutputStream struct + func (tsk *OutputStream) Configure(ctx Context) error + func (tsk *OutputStream) Process(ctx Context) error + func (tsk *OutputStream) StartTask(ctx Context) error + func (tsk *OutputStream) StopTask(ctx Context) error + type OutputStreamer interface + Connect func(ports []Port) error + Disconnect func() error + Write func(ctx Context) error + type P1D struct + ID HID + Profile *hbook.P1D + func (p P1D) Name() string + func (p P1D) Value() interface{} + type Port struct + Name string + Type reflect.Type + type PortMgr interface + DeclInPort func(c Component, name string, t reflect.Type) error + DeclOutPort func(c Component, name string, t reflect.Type) error + type PropMgr interface + DeclProp func(c Component, name string, ptr interface{}) error + GetProp func(c Component, name string) (interface{}, error) + HasProp func(c Component, name string) bool + SetProp func(c Component, name string, value interface{}) error + type Property interface + DeclProp func(name string, ptr interface{}) error + GetProp func(name string) (interface{}, error) + SetProp func(name string, value interface{}) error + type Runner interface + Run func() error + type S2D struct + ID HID + Scatter *hbook.S2D + func (s S2D) Name() string + func (s S2D) Value() interface{} + type Scripter interface + Configure func() error + Run func(evtmax int64) error + Shutdown func() error + Start func() error + Stop func() error + type Store interface + Get func(key string) (interface{}, error) + Has func(key string) bool + Put func(key string, value interface{}) error + type StreamControl struct + Ctx chan Context + Err chan error + Ports []Port + Quit chan struct{} + type Svc interface + StartSvc func(ctx Context) error + StopSvc func(ctx Context) error + type SvcBase struct + func NewSvc(typ, name string, mgr App) SvcBase + func (svc *SvcBase) DeclProp(n string, ptr interface{}) error + func (svc *SvcBase) FSMState() fsm.State + func (svc *SvcBase) GetProp(name string) (interface{}, error) + func (svc *SvcBase) Name() string + func (svc *SvcBase) SetProp(name string, value interface{}) error + func (svc *SvcBase) Type() string + type SvcMgr interface + AddSvc func(svc Svc) error + DelSvc func(svc Svc) error + GetSvc func(n string) Svc + HasSvc func(n string) bool + Svcs func() []Svc + type Task interface + Process func(ctx Context) error + StartTask func(ctx Context) error + StopTask func(ctx Context) error + type TaskBase struct + func NewTask(typ, name string, mgr App) TaskBase + func (tsk *TaskBase) DeclInPort(n string, t reflect.Type) error + func (tsk *TaskBase) DeclOutPort(n string, t reflect.Type) error + func (tsk *TaskBase) DeclProp(n string, ptr interface{}) error + func (tsk *TaskBase) FSMState() fsm.State + func (tsk *TaskBase) GetProp(n string) (interface{}, error) + func (tsk *TaskBase) Name() string + func (tsk *TaskBase) SetProp(n string, v interface{}) error + func (tsk *TaskBase) Type() string + type TaskMgr interface + AddTask func(tsk Task) error + DelTask func(tsk Task) error + GetTask func(n string) Task + HasTask func(n string) bool + Tasks func() []Task + type WriteSyncer interface + Sync func() error