Versions in this module Expand all Collapse all v3 v3.35.0 Mar 30, 2023 v3.34.0 Mar 16, 2023 Changes in this version + func ConfigToFields(c Config) ([]*dax.Field, error) + func ValidateConfig(c Config) error + type Config struct + BatchMaxStaleness time.Duration + BatchSize int + Fields []Field + Group string + Hosts []string + Table string + Timeout time.Duration + Topics []string + type ConfigForIDK struct + BatchMaxStaleness time.Duration + BatchSize int + Fields []idk.RawField + Group string + Hosts []string + IDField string + Table string + Timeout time.Duration + Topics []string + func ConvertConfig(c Config) (ConfigForIDK, error) + type Field struct + Name string + PrimaryKey bool + SourcePath []string + SourceType string + func CheckFieldCompatibility(cflds []Field, scr *featurebase.ShowColumnsResponse) ([]Field, error) + func FieldsToConfig(flds []*dax.Field) []Field + type Runner struct + Group string + Header []idk.RawField + KafkaHosts []string + Timeout time.Duration + Topics []string + func NewRunner(cfg ConfigForIDK, batcher fbbatch.Batcher, logWriter io.Writer) *Runner
Go to main page