mirror of
https://github.com/element-hq/dendrite.git
synced 2025-03-14 14:15:35 +00:00
f4506a0d82
This should gracefully handle some more potential errors that the consumer fetches can return with retries, as well as setting some client settings for reconnects etc when using an external NATS Server. Also allow specifying the JetStream domain in case of a leafnode scenario and better manage client reuse across Dendrite. And also update NATS Server to 2.10.24 for good measure. This code is backported from Harmony. Signed-off-by: Neil Alexander <git@neilalexander.dev> --------- Signed-off-by: Neil Alexander <git@neilalexander.dev> Co-authored-by: Neil Alexander <neilalexander@users.noreply.github.com> Co-authored-by: Till <2353100+S7evinK@users.noreply.github.com>
50 lines
1.6 KiB
Go
50 lines
1.6 KiB
Go
package config
|
|
|
|
import (
|
|
"fmt"
|
|
)
|
|
|
|
type JetStream struct {
|
|
Matrix *Global `yaml:"-"`
|
|
|
|
// Persistent directory to store JetStream streams in.
|
|
StoragePath Path `yaml:"storage_path"`
|
|
// A list of NATS addresses to connect to. If none are specified, an
|
|
// internal NATS server will be used when running in monolith mode only.
|
|
Addresses []string `yaml:"addresses"`
|
|
// The prefix to use for stream names for this homeserver - really only
|
|
// useful if running more than one Dendrite on the same NATS deployment.
|
|
TopicPrefix string `yaml:"topic_prefix"`
|
|
// The JetStream domain, if needed.
|
|
JetStreamDomain string `yaml:"js_domain"`
|
|
// Keep all storage in memory. This is mostly useful for unit tests.
|
|
InMemory bool `yaml:"in_memory"`
|
|
// Disable logging. This is mostly useful for unit tests.
|
|
NoLog bool `yaml:"-"`
|
|
// Disables TLS validation. This should NOT be used in production
|
|
DisableTLSValidation bool `yaml:"disable_tls_validation"`
|
|
// A credentials file to be used for authentication, example:
|
|
// https://docs.nats.io/using-nats/developer/connecting/creds
|
|
Credentials Path `yaml:"credentials_path"`
|
|
}
|
|
|
|
func (c *JetStream) Prefixed(name string) string {
|
|
return fmt.Sprintf("%s%s", c.TopicPrefix, name)
|
|
}
|
|
|
|
func (c *JetStream) Durable(name string) string {
|
|
return c.Prefixed(name)
|
|
}
|
|
|
|
func (c *JetStream) Defaults(opts DefaultOpts) {
|
|
c.Addresses = []string{}
|
|
c.TopicPrefix = "Dendrite"
|
|
if opts.Generate {
|
|
c.StoragePath = Path("./")
|
|
c.NoLog = true
|
|
c.DisableTLSValidation = true
|
|
c.Credentials = Path("")
|
|
}
|
|
}
|
|
|
|
func (c *JetStream) Verify(configErrs *ConfigErrors) {}
|