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

ywengineer / chain-job Public

source -> filter -> sink. support kafka source, json filter, elastic and mysql sink.

Notifications

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