Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + const FailureHandlerInitRetryIntervalInSeconds + const FailureHandlerMaxRetryMinutes + const FailureHandlerMultiplier + const FailureHandlerType + const KafkaAutoRecoveryThreshold + const KafkaBatchSize + const KafkaErrorThreshold + const KafkaLatestOffset + const KafkaMaxBatchDelayMS + const KafkaMegaBytePerSec + const KafkaProcessorCount + const KafkaRestartInterval + const KafkaRestartOnFailure + const KafkaStatusCheckInterval + const KafkaTopicType + var DefaultKafkaConfig = KafkaConfig + type FailureHandler struct + Config FailureHandlerConfig + Type string + type FailureHandlerConfig struct + InitRetryIntervalInSeconds int + MaxRetryMinutes int + Multiplier float32 + type IngestionAssignment struct + Instances map[string]Instance + Jobs []JobConfig + Subscriber string + type Instance struct + Address string + Host string + Name string + Port uint32 + type JobConfig struct + AresTableConfig TableConfig + Name string + NumShards int + StreamingConfig KafkaConfig + Version int + type KafkaConfig struct + ARThreshold int + BatchSize int + ChannelBufferSize uint + Cluster string + ErrorThreshold int + FailureHandler FailureHandler + File string + KafkaBroker string + KafkaVersion string + LatestOffset bool + MaxBatchDelayMS int + MaxPollIntervalMs int + MegaBytePerSec int + ProcessorCount int + RestartInterval int + RestartOnFailure bool + SessionTimeoutNs int + StatusCheckInterval int + Topic string + TopicType string + type Subscriber struct + Host string + Name string + type TableConfig struct + Cluster string + Name string + Table *metaCom.Table + UpdateMode map[string]string
Go to main page