process

Feb 10, 2026

Changes in this version

+ const ContextKeyManager

+ var ErrValueNotManager = errors.Base("value is not Manager")

+ func SetManager(ctx context.Context, inst Manager) (context.Context, error)

+ func SetManagerIfAbsent(ctx context.Context, inst Manager) (context.Context, error)

+ func WithManager(ctx context.Context, fn func(Manager))

type Manager

+ func FromManager(ctx context.Context) Manager

+ func GetManager(ctx context.Context) (Manager, error)

+ func MustGetManager(ctx context.Context) Manager

+ func TryGetManager(ctx context.Context) (Manager, bool)

Jul 28, 2025

Changes in this version

+ const ContextKeyProcManager

+ var ErrValueNotProcessManager = errors.Base("value is not process.Manager")

+ func SetProcessManager(ctx context.Context, inst Manager) (context.Context, error)

type Config

+ Responder responder.Respondable

+ func NewConfig() *Config

type Manager

+ func GetProcessManager(ctx context.Context) (Manager, error)

+ func MustGetProcessManager(ctx context.Context) Manager

type Process

+ func (p *Process) Invoke(event events.Event) events.Event

+ func (p *Process) RespondsTo(event events.Event) bool

+ func (p *Process) Type() string

type State

+ func (ps *State) Invoke(event events.Event) (events.Event, bool)

+ func (ps *State) RespondsTo(event events.Event) bool

+ type StopAllResults map[string]bool

Jul 30, 2023

Changes in this version

+ type ActionResult struct

+ Error error

+ Success bool

+ Value any

+ func NewActionResult(val any, err error) *ActionResult

+ func NewEmptyActionResult() *ActionResult

+ func (ar *ActionResult) IsError() bool

type IManager

+ Logger func() logger.ILogger

type Manager

+ func (pm *Manager) Logger() logger.ILogger

Jul 6, 2022

Changes in this version

type Config

+ OnStart CallbackFn

type IManager

+ Context func() context.Context

type Manager

+ func (pm *Manager) Context() context.Context

type Process

+ OnStart CallbackFn

Jun 11, 2022

Changes in this version

type Config

+ OnQuery QueryFn

type Process

+ OnQuery QueryFn

+ func (p *Process) Context() context.Context

+ func (p *Process) Query(arg interface{}) interface{}

+ type QueryFn func(interface{}) interface

type State

+ func (ps *State) Context() context.Context

Mar 24, 2022

Changes in this version

+ const EventLoopSleep

+ type CallbackFn func(**State)

+ type Config struct

+ Function CallbackFn

+ Interval int

+ Logger logger.ILogger

+ Name string

+ OnStop CallbackFn

+ func NewDefaultConfig() *Config

+ type IManager interface

+ Add func(*Process)

+ Count func() int

+ Create func(*Config) *Process

+ Find func(string) (*Process, bool)

+ Processes func() *[]*Process

+ Run func(string) bool

+ SetContext func(context.Context)

+ SetLogger func(logger.ILogger)

+ Stop func(string) bool

+ StopAll func() bool

+ type Manager struct

+ func NewManager() *Manager

+ func NewManagerWithContext(parent context.Context) *Manager

+ func (pm *Manager) Add(proc *Process)

+ func (pm *Manager) Count() int

+ func (pm *Manager) Create(config *Config) *Process

+ func (pm *Manager) Find(name string) (*Process, bool)

+ func (pm *Manager) Processes() *[]*Process

+ func (pm *Manager) Run(name string) bool

+ func (pm *Manager) SetContext(parent context.Context)

+ func (pm *Manager) SetLogger(lgr logger.ILogger)

+ func (pm *Manager) Stop(name string) bool

+ func (pm *Manager) StopAll() bool

+ type Process struct

+ Function CallbackFn

+ Interval time.Duration

+ Name string

+ OnStop CallbackFn

+ Running bool

+ func NewProcess(config *Config) *Process

+ func NewProcessWithContext(config *Config, parent context.Context) *Process

+ func (p *Process) Receive() interface{}

+ func (p *Process) ReceiveNonBlocking() (interface{}, bool)

+ func (p *Process) Run() bool

+ func (p *Process) Send(data interface{})

+ func (p *Process) SendNonBlocking(data interface{})

+ func (p *Process) SetContext(parent context.Context)

+ func (p *Process) SetLogger(lgr logger.ILogger)

+ func (p *Process) SetWaitGroup(wg *sync.WaitGroup)

+ func (p *Process) Stop() bool

+ type State struct

+ func NewState() *State

+ func (ps *State) Logger() logger.ILogger

+ func (ps *State) Receive() (interface{}, bool)

+ func (ps *State) ReceiveBlocking() interface{}

+ func (ps *State) Send(data interface{}) bool

+ func (ps *State) SendBlocking(data interface{})