Versions in this module Expand all Collapse all v1 v1.0.0 Jul 30, 2026 Changes in this version + type Client struct + func NewClient(opts ClientOptions) *Client + func (c *Client) Close() + func (c *Client) Connect() + func (c *Client) SendCommand(ctx context.Context, cmd string) (string, error) + func (c *Client) SetBroadcastCallback(callback func(RustPayload)) + type ClientOptions struct + IP string + Logger *slog.Logger + MaxRetryBackoff time.Duration + Name string + Password string + Port int + RateLimiter RateLimiter + ReadBufferSize int + WriteBufferSize int + func DefaultOptions(ip string, port int, password string) ClientOptions + type ConnectionManager struct + func (cm *ConnectionManager) Start() + type DefaultRateLimiter struct + func NewDefaultRateLimiter(burst int, eventsPerSecond float64) *DefaultRateLimiter + func (d *DefaultRateLimiter) Wait(ctx context.Context) error + type Engine struct + func (e *Engine) Dispatch(payload RustPayload) + func (e *Engine) SendCommandSync(ctx context.Context, payload RustPayload) (string, error) + func (e *Engine) SetBroadcastCallback(cb func(RustPayload)) + type RateLimiter interface + Wait func(ctx context.Context) error + type RustPayload struct + Identifier int + Message string + Name string
Go to main page