GoPipeline - 数据管道

GoPipeline是一个被设计用来消息分派和处理的框架。它用于艾润物联大数据系统的数据源采集前端，将Http WebHook、WebSocket等消息数据源，通过GoPipeline内部转换数据格式，并分派到Spark、Kafka、WebSocketServer等其它服务。

Name		Name	Last commit message	Last commit date
Latest commit History 1 Commit
.idea		.idea
abc		abc
bench		bench
cmd		cmd
common		common
hooks		hooks
http		http
kafka		kafka
splitter		splitter
sql		sql
util		util
.gitignore		.gitignore
Gopkg.lock		Gopkg.lock
Gopkg.toml		Gopkg.toml
INPUTS.md		INPUTS.md
Makefile		Makefile
OUTPUTS.md		OUTPUTS.md
README.md		README.md
TODO.md		TODO.md
TOPIC_RULE.md		TOPIC_RULE.md
abc_slot.go		abc_slot.go
components.go		components.go
config.go		config.go
data_frame.go		data_frame.go
data_frame_pool.go		data_frame_pool.go
data_frame_test.go		data_frame_test.go
decoder.go		decoder.go
filter.go		filter.go
find.go		find.go
globals.go		globals.go
input.go		input.go
json.go		json.go
json_test.go		json_test.go
matcher.go		matcher.go
matcher_test.go		matcher_test.go
multi_reader.go		multi_reader.go
output.go		output.go
registry.go		registry.go
ringsamp.go		ringsamp.go
ringsamp_test.go		ringsamp_test.go
router.go		router.go
x_atomic.go		x_atomic.go
x_counter.go		x_counter.go
x_performance.go		x_performance.go
x_time.go		x_time.go

Provide feedback