destination

type DbRow struct {
	Schema string                 `json:"schema"`
	Table  string                 `json:"table"`
	Data   map[string]interface{} `json:"data"`
}

type ElasticSearch struct {
	URLs                []string       `yaml:"urls"`
	IndexName           string         `yaml:"indexName"`
	Username            string         `yaml:"username"`
	Password            string         `yaml:"password"`
	EnableSniffer       bool           `yaml:"enableSniffer"`
	Timeout             model.Duration `yaml:"timeout"`
	HealthCheckInterval model.Duration `yaml:"healthCheckInterval"`

	Client *elastic.Client `yaml:"-"`
}

type File struct {
	Prefix string `yaml:"prefix"`
}

type Kafka struct {
	Version     string   `yaml:"version"`
	Brokers     []string `yaml:"brokers"`
	TopicPrefix string   `yaml:"topicPrefix"`
	// contains filtered or unexported fields
}

type Mysql struct {
	DSN           string            `yaml:"dsn"`
	SyncMarkTable string            `yaml:"syncMarkTable"`
	SyncChannel   string            `yaml:"syncChannel"`
	SyncTables    map[string]string `yaml:"syncTables"`
	// contains filtered or unexported fields
}

type Noop struct {
}

type SyncRow struct {
	// contains filtered or unexported fields
}

type TableMeta struct {
	Table      string `yaml:"table"`
	FieldAsCid string `yaml:"fieldAsCid"`
	Prefix     string `yaml:"prefix"`
}

type Weed struct {
	Masters      []string    `yaml:"masters"`
	FidStorePath string      `yaml:"fidStorePath"` // 默认值./fid_store
	Tables       []string    `yaml:"tables"`
	FiledAsCids  []TableMeta `yaml:"filedAsCids"`
	// contains filtered or unexported fields
}