backend

type Action string

type Backend struct {
	Config                BackendConfig
	Mqtt                  *utils.MqttConnection
	Srv                   *http3.Server
	UplinkConnectionMutex sync.Mutex
	UplinkConnections     map[string]*WaitForClose
	ConnectionPool        *ConnectionPool
}

type BackendConfig struct {
	BrokerUrl           string
	StatusTopic         *string
	BaseConnectionTopic *string
	RefreshFreq         time.Duration
	MuxEndPointUrl      string
	Listen              string
	CertFile            string
	KeyFile             string
	CloseAfterInactive  time.Duration
	MqttCfg             *mqtt.ClientOptions
}

type Connection struct {
	Client   http.Client  `json:"-"`
	Creating sync.RWMutex `json:"-"`
	Schema   string
	Host     string
	IsQuic   bool
	Request  int
}

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

type EventFn = func(Action, string, *Connection)

type WaitForClose struct {
	Request     http.Request // First request that started the close.
	Backend     *Backend
	LastRequest time.Time
	// RemoteAddr string
	Requests uint64
}