Versions in this module Expand all Collapse all v0 v0.1.0 Aug 30, 2026 Changes in this version + const EventClientConnected + const EventClientDisconnected + const EventConnected + const EventDisconnected + type Client struct + func NewClient(cfg ClientConfig) *Client + func (c *Client) OnActivated(ctx context.Context, args map[string]any) + func (c *Client) OnBusMessage(ctx context.Context, m bus.Message) + func (c *Client) Stop(ctx context.Context) + type ClientConfig struct + Active *bool + ForwardMessages []bus.Message + Headers map[string]string + LocalWorker string + Name string + RemoteWorker string + Serializer bus.MessageSerializer + URL string + type Server struct + func NewServer(cfg ServerConfig) *Server + func (s *Server) OnBusMessage(ctx context.Context, m bus.Message) + func (s *Server) OnWorkerReady(ctx context.Context, data registry.WorkerReadyData) + func (s *Server) Start(ctx context.Context) + func (s *Server) Stop(ctx context.Context) + type ServerConfig struct + Conn *wsutil.Conn + ForwardMessages []bus.Message + LocalWorker string + Name string + RemoteWorker string + Serializer bus.MessageSerializer
Go to main page