Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GlobalConfig ¶
type GlobalConfig struct {
UDF *UDFConfig `json:"udf"`
Sink *SinkConfig `json:"sink"`
ISBSvc *ISBSvcConfig `json:"isbsvc"`
}
func LoadConfig ¶
func LoadConfig(onErrorReloading func(error)) (*GlobalConfig, error)
func (*GlobalConfig) GetJetStreamVersion ¶
func (g *GlobalConfig) GetJetStreamVersion(version string) (*JetStreamVersion, error)
func (*GlobalConfig) GetRedisVersion ¶
func (g *GlobalConfig) GetRedisVersion(version string) (*RedisVersion, error)
func (*GlobalConfig) GetUDFContentType ¶
func (g *GlobalConfig) GetUDFContentType() dfv1.ContentType
func (*GlobalConfig) GetUDSinkContentType ¶
func (g *GlobalConfig) GetUDSinkContentType() dfv1.ContentType
type ISBSvcConfig ¶
type ISBSvcConfig struct {
Redis *RedisConfig `json:"redis"`
JetStream *JetStreamConfig `json:"jetstream"`
}
type JetStreamConfig ¶
type JetStreamConfig struct {
Settings string `json:"settings"`
BufferConfig string `json:"bufferConfig"`
Versions []JetStreamVersion `json:"versions"`
}
type JetStreamVersion ¶
type RedisConfig ¶
type RedisConfig struct {
Settings *RedisSettings `json:"settings"`
Versions []RedisVersion `json:"versions"`
}
type RedisSettings ¶
type RedisVersion ¶
type SinkConfig ¶
type SinkConfig struct {
ContentType string `json:"contentType"`
}
Click to show internal directories.
Click to hide internal directories.