client

type Client struct {
	// contains filtered or unexported fields
}

type Config struct {
	// Endpoint is the target WebSocket URL (e.g. "wss://localhost:8080/ws/client-1" or "http://localhost:8080").
	Endpoint string `json:"endpoint" toml:"endpoint"`

	// ClientName is the unique client identifier registered with WSBroker.
	// If omitted, a random client ID is generated or extracted from Endpoint URL.
	ClientName string `json:"client_name" toml:"client_name"`

	// InitialChannels is the list of channel names to subscribe to upon initial connection.
	InitialChannels []string `json:"initial_channels" toml:"initial_channels"`

	// Bearer is the optional Bearer token used for HTTP/WS authentication.
	Bearer string `json:"bearer" toml:"bearer"`

	// TLSConfig is a custom standard crypto/tls configuration.
	TLSConfig *tls.Config `json:"-" toml:"-"`

	// TLSCertLoader is the certloader configuration for dynamic mTLS and certificate rotation.
	TLSCertLoader *loader.Config `json:"tls" toml:"tls"`

	// AutoReconnect enables automatic reconnection upon unexpected disconnection.
	AutoReconnect bool `json:"auto_reconnect" toml:"auto_reconnect"`

	// ReconnectInterval is the initial wait duration before the first reconnection attempt.
	ReconnectInterval time.Duration `json:"reconnect_interval" toml:"reconnect_interval"`

	// MaxReconnectInterval is the upper bound duration for exponential backoff.
	MaxReconnectInterval time.Duration `json:"max_reconnect_interval" toml:"max_reconnect_interval"`

	// ReconnectBackoffFactor is the multiplier applied to backoff after each failed attempt.
	ReconnectBackoffFactor float64 `json:"reconnect_backoff_factor" toml:"reconnect_backoff_factor"`

	// MaxReconnectAttempts is the maximum number of reconnect attempts before giving up (0 = infinite).
	MaxReconnectAttempts int `json:"max_reconnect_attempts" toml:"max_reconnect_attempts"`

	// PingInterval is the interval at which client-side heartbeat pings are sent (0 = disabled).
	PingInterval time.Duration `json:"ping_interval" toml:"ping_interval"`

	// ConnectTimeout is the timeout duration for establishing a connection.
	ConnectTimeout time.Duration `json:"connect_timeout" toml:"connect_timeout"`

	// WriteTimeout is the timeout duration for write operations.
	WriteTimeout time.Duration `json:"write_timeout" toml:"write_timeout"`

	// Logger is the logger instance used for diagnostics and debug logging.
	Logger zLogger.ZLogger `json:"-" toml:"-"`
}

type ConnectionState string

type EventHandler func(evt *event.Event)

type Option func(*Config)

type Subscription interface {
	// Channel returns the subscribed channel name.
	Channel() string
	// Events returns the receive-only channel carrying incoming events.
	Events() <-chan *event.Event
	// Unsubscribe stops the subscription and releases resources.
	Unsubscribe() error
}

type UnsubscribeFunc func()