Versions in this module Expand all Collapse all v1 v1.0.4 May 24, 2022 Changes in this version + var LOG_PROCESSING_ERRORS = true + func Attach(managerName string, route string, f func(any, any) any) error + func Await(managerName string, route string, data any) (any, error) + func AwaitRequest(managerName string, request *Request) (any, error) + func Detach(managerName string, route string) error + func Kill(managerName string) error + func KillAndRemove(managerName string) error + func Remove(managerName string) error + func SendRequest(managerName string, request *Request) error + func Start(managerName string, managerState any) error + type Manager struct + Name string + func GetManager(managerName string) (*Manager, error) + func NewManager(name string, bufferSize int) (*Manager, error) + func (manager *Manager) Attach(route string, function func(managerState any, request any) any) + func (manager *Manager) Await(route string, data any) (any, error) + func (manager *Manager) AwaitRequest(request *Request) (any, error) + func (manager *Manager) Detach(route string) + func (manager *Manager) IsRunning() bool + func (manager *Manager) Kill() error + func (manager *Manager) KillAndRemove() error + func (manager *Manager) Remove() error + func (manager *Manager) Send(route string, data any) *Request + func (manager *Manager) SendRequest(request *Request) + func (manager *Manager) Start(managerState any) + type Request struct + Data any + Route string + func NewRequest(route string, data any) *Request + func Send(managerName string, route string, data any) (*Request, error) + func (request *Request) Await(managerName string) (any, error) + func (request *Request) AwaitManager(manager *Manager) (any, error) + func (request *Request) HasData() bool + func (request *Request) Send(managerName string) error + func (request *Request) SendManager(manager *Manager) + func (request *Request) Wait() (any, error)
Go to main page