Versions in this module Expand all Collapse all v0 v0.0.1 Jan 7, 2021 Changes in this version + func RegisterFilter(class string, f FilterBuilder) + func RegisterPlugin(class string, f PluginBuilder) + type Action uint8 + const ActionFinish + const ActionJump + const ActionNext + const ActionReturn + const ActionStop + type Builder struct + func NewBuilder(regsvc apiservice.Discover, opt ...BuilderOption) *Builder + func (b *Builder) Build(def StackDef) (*Stack, error) + func (b *Builder) Logger() yalogi.Logger + func (b *Builder) OnShutdown(f func() error) + func (b *Builder) OnStartup(f func() error) + func (b *Builder) Service(id string) (apiservice.Service, bool) + func (b *Builder) Shutdown() error + func (b *Builder) Stack(name string) (*Stack, bool) + func (b *Builder) StackNames() []string + func (b *Builder) Start() error + func (b Builder) CachePath(data string) string + func (b Builder) CertPath(cert string) string + func (b Builder) DataPath(data string) string + type BuilderOption func(*buildOpts) + func CacheDir(s string) BuilderOption + func CertsDir(s string) BuilderOption + func DataDir(s string) BuilderOption + func SetBuildLogger(l yalogi.Logger) BuilderOption + type CbRequest func(*Request) + type FilterBuilder func(*Builder, *ItemDef) (ModuleFilter, error) + type GUIDGenerator func() string + type Hooks struct + func NewHooks() *Hooks + func (h *Hooks) AfterModule(fn CbRequest) + func (h *Hooks) AfterProc(fn CbRequest) + func (h *Hooks) BeforeModule(fn CbRequest) + func (h *Hooks) BeforeProc(fn CbRequest) + func (h *Hooks) FinishProc(fn CbRequest) + type ItemDef struct + Args []string + Class string + Opts map[string]interface{} + type Module struct + Filters []ModuleFilter + Name string + OnError StackAction + OnSuccess StackAction + Plugins []ModulePlugin + type ModuleDef struct + Disabled bool + Filters []*ItemDef + Name string + OnError StackAction + OnSuccess StackAction + Plugins []*ItemDef + type ModuleFilter func(e event.Event) (result bool) + type ModulePlugin func(e *event.Event) error + type Option func(*options) + func SetBufferSize(n int) Option + func SetGUIDGen(g GUIDGenerator) Option + func SetLogger(l yalogi.Logger) Option + func Workers(n int) Option + type PluginBuilder func(*Builder, *ItemDef) (ModulePlugin, error) + type Processor struct + func New(main *Stack, others []*Stack, db eventdb.Database, opt ...Option) *Processor + func (p *Processor) Close() + func (p *Processor) ForwardEvent(ctx context.Context, e event.Event) error + func (p *Processor) NotifyEvent(ctx context.Context, e event.Event) (string, error) + type Request struct + Enqueued time.Time + Event event.Event + Finished time.Time + Peer *peer.Peer + StackTrace []string + Started time.Time + type Stack struct + func NewStack(name string) *Stack + func (s *Stack) Add(m *Module) + func (s Stack) Name() string + type StackAction struct + Action Action + Label string + func (a *StackAction) UnmarshalJSON(data []byte) error + func (a StackAction) MarshalJSON() ([]byte, error) + func (a StackAction) String() string + type StackDef struct + Disabled bool + Modules []ModuleDef + Name string + func StackDefsFromFile(path string) ([]StackDef, error)
Go to main page