conf

Mar 31, 2024

Changes in this version

type ConsumerConfig

+ TopicIndex int

type InternalProcessorConfig

+ WindowSize int

type ProcessorConfig

+ WindowSize int

Mar 30, 2024

Changes in this version

+ type ConsumerConfig struct

+ Address string

+ NumOfWorkers int

+ Topic string

type InternalProcessorConfig

+ ConsumerConfigs []*ConsumerConfig

+ Type string

+ func NewInternalProcessorConfig(rootConfig *RootConfig, processorName string) *InternalProcessorConfig

type ProcessorConfig

+ InputKafkaConfigs []*KafkaConfig

+ InputProcessors []string

+ Type string

Mar 29, 2024

Changes in this version

type GlobalStoreConfig

+ MemcachedConfigs []*MemcachedConfig

+ type MemcachedConfig struct

+ Addresses []string

+ Name string

+ func GetMemcachedConfigByName(name string) *MemcachedConfig

Mar 29, 2024

Changes in this version

+ var ErrConfigNotInitialized = fmt.Errorf("config is not initialized")

+ func LoadConfig(config *InternalProcessorConfig) error

type InternalProcessorConfig

+ func Config() *InternalProcessorConfig

type RedisConfig

+ func GetRedisConfigByName(name string) *RedisConfig

Mar 28, 2024

Changes in this version

+ type GlobalKafkaConfig struct

+ Address string

+ InitialTopics []*InitialTopic

+ type GlobalStoreConfig struct

+ RedisConfigs []*RedisConfig

+ type InitialTopic struct

+ Partitions int

+ Topic string

+ type InternalKafkaConfig struct

+ Address string

+ Partitions int

+ Topic string

+ type InternalProcessorConfig struct

+ DefaultOutputKafkaConfig *KafkaConfig

+ GlobalKafkaConfig *GlobalKafkaConfig

+ GlobalStoreConfig *GlobalStoreConfig

+ InputKafkaConfig *KafkaConfig

+ Name string

+ NumOfWorker int

+ OutputKafkaConfigs map[string]*KafkaConfig

+ func (ipc *InternalProcessorConfig) Validate() error

+ type KafkaConfig struct

+ Address string

+ Topic string

+ type NamedKafkaConfig struct

+ Address string

+ Name string

+ Topic string

+ type OutputConfig struct

+ DefaultTopicPartitions int

+ OutputKafkaConfigs []*NamedKafkaConfig

+ OutputProcessors []string

+ type ProcessorConfig struct

+ EntryPoint string

+ Files []string

+ InputKafkaConfig *KafkaConfig

+ InputProcessor string

+ Name string

+ NumOfWorker int

+ OutputConfig *OutputConfig

+ ParentDirectory string

+ type RedisConfig struct

+ Address string

+ Name string

+ type RootConfig struct

+ GlobalKafkaConfig *GlobalKafkaConfig

+ GlobalStoreConfig *GlobalStoreConfig

+ ProcessorConfigs []*ProcessorConfig

+ func (rc *RootConfig) Validate() error