server

type Backend interface {
	// Name returns the name of the backend.
	Name() string

	// Query retrieves SenML data from the backend with the given parameters.
	Query(name, host string, from, to time.Time, last bool) (measurements []senml.Measurement, err error)

	// Write writes SenML data to the backend.
	Write(name, host string, data ...senml.Measurement) error

	// Close closes the connection to the backend.
	Close() error
}

type BackendConfig struct {
	// InfluxDB configuration
	InfluxDB *influxdb.ClientConfig `yaml:"influxdb"`

	// InfluxDB2 configuration.
	InfluxDB2 *influxdb2.ClientConfig `yaml:"influxdb2"`

	// PostgreSQL configuration.
	Postgres *postgres.ClientConfig `yaml:"postgres"`

	// TimescaleDB configuration.
	Timescale *postgres.ClientConfig `yaml:"timescale"`
}

type CoAPResponseWriter struct {
	mux.ResponseWriter
}

type EndpointConfig struct {
	Enabled bool   `yaml:"enabled"`
	Path    string `yaml:"path"`
}

type Error struct {
	// The error causing this error.
	Err error

	// The corresponding response code.
	Code codes.Code
}

type HTTPResponseWriter struct {
	http.ResponseWriter
}

type Limiter struct {
	LimiterConfig
	sync.Mutex
	// contains filtered or unexported fields
}

type LimiterConfig struct {
	Body     int64   `yaml:"body"`
	Rate     float64 `yaml:"rate"`
	Burst    float64 `yaml:"burst"`
	IPv4Mask int     `yaml:"ipv4_mask"`
	IPv6Mask int     `yaml:"ipv6_mask"`
}

type Listener struct {
	Type         string `yaml:"type"`
	Address      string `yaml:"address"`
	CertFile     string `yaml:"tls_cert"`
	KeyFile      string `yaml:"tls_key"`
	PreSharedKey string `yaml:"psk"`
	Metrics      bool   `yaml:"metrics"`
	MetricsPath  string `yaml:"metrics_path"`
	Profile      bool   `yaml:"profile"`
	ProfilePath  string `yaml:"profile_path"`
}

type MaxBytesReadCloser struct {
	MaxBytesReader
	Reader io.ReadCloser
}

type MaxBytesReadSeeker struct {
	MaxBytesReader
	Reader io.ReadSeeker
}

type MaxBytesReader struct {
	Reader io.Reader
	Remain int64
}

type Metrics struct {
	Info            *prometheus.Desc
	Requests        *prometheus.CounterVec
	Responses       *prometheus.CounterVec
	LastMeasurement *prometheus.GaugeVec
}

type Request struct {
	Protocol    string
	Method      string
	RemoteAddr  string
	Path        []string
	Query       url.Values
	ContentType string
	Accept      string
	Body        io.Reader
	Confirmable bool
}

type ResponseWriter interface {
	// SetResponse sets the response code, content type and data.
	SetResponse(code codes.Code, contentType string, data []byte) error

	// WriteErrors returns true if errors should be written to the client.
	WriteErrors() bool
}

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