managers

Mar 17, 2022

Changes in this version

+ func AwaitRequest(managerName string, request *Request) (interface{}, error)

+ func Detach(managerName string, route string) error

+ func SendRequest(managerName string, request *Request) error

type Manager

+ func (manager *Manager) AwaitRequest(request *Request) (interface{}, error)

+ func (manager *Manager) Detach(route string)

+ func (manager *Manager) SendRequest(request *Request)

type Request

+ func (request *Request) HasData() bool

Mar 16, 2022

Changes in this version

+ func Kill(managerName string) error

+ func KillAndRemove(managerName string) error

+ func Remove(managerName string) error

type Manager

+ Running bool

+ func GetManager(managerName string) (*Manager, error)

+ func (manager *Manager) IsRunning() bool

+ func (manager *Manager) KillAndRemove() error

+ func (manager *Manager) Remove() error

type Request

+ func (request *Request) AwaitManager(manager *Manager) (interface{}, error)

+ func (request *Request) SendManager(manager *Manager)

+ func (request *Request) Wait() (interface{}, error)

Jul 22, 2021

Changes in this version

type Response

+ func (response *Response) GetData() interface{}

Jan 14, 2021

Changes in this version

+ func Start(managerName string) error

Jan 14, 2021

Changes in this version

+ func Attach(managerName string, route string, f func(interface{}) interface{}) error

+ func Send(managerName string, route string, data interface{}) error

+ type Manager struct

+ Functions map[string]func(request interface{}) interface{}

+ Name string

+ Requests chan *Request

+ StateLock sync.Mutex

+ func NewManager(name string, bufferSize int) *Manager

+ func (manager *Manager) Attach(route string, function func(request interface{}) interface{})

+ func (manager *Manager) Await(route string, data interface{}) *Response

+ func (manager *Manager) Kill()

+ func (manager *Manager) Send(route string, data interface{}) *Request

+ func (manager *Manager) Start()

+ type Request struct

+ Data interface{}

+ Response chan Response

+ Route string

+ func NewRequest(route string, data interface{}) *Request

+ func (request *Request) Await(managerName string) (*Response, error)

+ func (request *Request) Send(managerName string) error

+ type Response struct

+ Data interface{}

+ Error error

+ func Await(managerName string, route string, data interface{}) (*Response, error)