server

type Config struct {
	Dispatchers uint          `json:"dispatchers" toml:"dispatchers" yaml:"dispatchers" xml:"dispatchers"`
	Timeout     time.Duration `json:"timeout" toml:"timeout" yaml:"timeout" xml:"timeout"`
	IdleTimeout time.Duration `json:"idleTimeout" toml:"idle_timeout" yaml:"idleTimeout" xml:"idle_timeout"`
	SecretKey   string        `json:"secretKey" toml:"secret_key" yaml:"secretKey" xml:"secret_key"`
	// IDHeader sets the upstream header to parse for a remote client.
	// Default behavior is to send requests to clients randomly.
	// If this value is set, requests can only be directed to clients by providing the client ID in this header.
	IDHeader string `json:"idHeader" toml:"id_header" yaml:"idHeader" xml:"id_header"`
	// If a KeyValidator method is provided, then Secretkey is ignored.
	// If the validator returns a string then all pool IDs become a
	// sha256 of that string and the client's generated or provided id.
	// See the NewPool function to see that in action.
	// This allows you to let clients provide their own ID, but a secure
	// access-ID is created with your provided seed to prevent hash collisions.
	KeyValidator func(context.Context, http.Header) (string, error) `json:"-" toml:"-" yaml:"-" xml:"-"`
	// Logger allows routing logs from this package to somewhere special.
	// If left nil logs are written to stdout.
	Logger mulch.Logger `json:"-" toml:"-" yaml:"-" xml:"-"`
}

type ConnStats struct {
	Remote    string    `json:"remote"`
	Requests  int       `json:"requests"`
	Connected time.Time `json:"conneteed"`
	Idle      string    `json:"idle"`
}

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

type ConnectionStatus int

type Metrics struct {
	Uptime    prometheus.CounterFunc
	Pools     prometheus.Gauge
	Conns     *prometheus.GaugeVec
	Regs      *prometheus.CounterVec
	PoolConns *prometheus.GaugeVec
	// contains filtered or unexported fields
}

type Pool struct {
	mulch.Logger
	// contains filtered or unexported fields
}

type PoolConfig struct {
	*mulch.Handshake
	Sock *websocket.Conn
	// contains filtered or unexported fields
}

type PoolSize struct {
	Total  int          `json:"total"`
	Idle   int          `json:"idle"`
	Busy   int          `json:"busy"`
	Closed int          `json:"closed"`
	Conns  []*ConnStats `json:"conns"`
}

type Server struct {
	Config *Config
	// contains filtered or unexported fields
}

type Stats struct {
	Pools   map[clientID]any `json:"pools"`
	Threads map[uint]uint64  `json:"threads"`
}