Versions in this module Expand all Collapse all v1 v1.2.0 Jun 21, 2024 v1.0.0 Mar 29, 2024 Changes in this version + const DefaultMaxMessages + var ErrRouteCapacityReached = protocolerrors.New(false, "route capacity has been reached") + var ErrRouteClosed = errors.New("route is closed") + var ErrTimeout = protocolerrors.New(false, "timeout expired") + type OnRouteCapacityReachedHandler func() + type Route struct + func NewRoute(name string) *Route + func (r *Route) Close() + func (r *Route) Dequeue() (appmessage.Message, error) + func (r *Route) DequeueWithTimeout(timeout time.Duration) (appmessage.Message, error) + func (r *Route) Enqueue(message appmessage.Message) error + func (r *Route) MaybeEnqueue(message appmessage.Message) error + type Router struct + func NewRouter(name string) *Router + func (r *Router) AddIncomingRoute(name string, messageTypes []appmessage.MessageCommand) (*Route, error) + func (r *Router) AddIncomingRouteWithCapacity(name string, capacity int, messageTypes []appmessage.MessageCommand) (*Route, error) + func (r *Router) Close() + func (r *Router) EnqueueIncomingMessage(message appmessage.Message) error + func (r *Router) OutgoingRoute() *Route + func (r *Router) RemoveRoute(messageTypes []appmessage.MessageCommand) error
Go to main page