GitHub - ywengineer/chain-job: source -> filter -> sink. support kafka source, json filter, elastic and mysql sink.

Name		Name	Last commit message	Last commit date
Latest commit History 63 Commits
.gitignore		.gitignore
conf.go		conf.go
constants.go		constants.go
filter.go		filter.go
filter_elasticsearch_analyzer.go		filter_elasticsearch_analyzer.go
filter_json.go		filter_json.go
filter_mail.go		filter_mail.go
filter_snowflake_id.go		filter_snowflake_id.go
go.mod		go.mod
sink.go		sink.go
sink_discard.go		sink_discard.go
sink_elasticsearch.go		sink_elasticsearch.go
sink_elasticsearch_update.go		sink_elasticsearch_update.go
sink_mysql.go		sink_mysql.go
sink_std.go		sink_std.go
source.go		source.go
source_kafka.go		source_kafka.go
task.go		task.go