参考请求地址从ui看到的,类似一个job的执行,支持异步以及同步数据查询处理，还包含了相对时间、绝对时间查询的/api/views/search/<id>/execute/api/views/s

OutputRouter核心是基于stream以及消息获取到实际消息的外部输出，方便后续的存储以及处理，实现上依赖了OutputRegistry存储了MessageOutput与Stream的关系，可以用来方便的

MessageOutput才是graylog真正写入日志到外部存储的地方不同的实现都依赖一个MessageQueueAcknowledger，对于已经处理的消息进行确认，确保不会多次执行扩展的子类  参考资

ProcessBufferProcessor的核心是进行消息处理，会调用消息处理器，同时会将消息放到OutputBuffer中ProcessBufferProcessor实际上是ProcessBuffer中Disruptor的一个handl

InputBuffer是graylog实际处理日志的部分，内部处理基于了Disruptor，同时还依赖了Journalling能力内部实际处理是依赖LocalKafka的（而且是推荐的）InputBuffer处理的几个模

graylog在消息进入之后（对应input），选择不同的handler处理之后，会到不同的buffer中对于DirectMessageHandler的会到ProcessBuffer中，对于是否开启了Journalling，处理会不一

input是graylog处理消息的核心，内部对于网络的处理是基于了netty框架，消息的核心基类是MessageInput基类的能力如下图，包含了基本常用的配置，状态，以及input节点信息，同时还包

RawMessage是从grayloginput组件获取到的还没解析处理的消息，是有SimpleChannelInboundHandler处理的原始消息RawMessageEvent是Disruptor处理的事件包装MessageE

OutputRouter核心是基于stream以及消息获取到实际消息的外部输出，方便后续的存储以及处理，实现上依赖了OutputRegistry存储了MessageOutput与Stream的关系，可以用来方便

MessageOutput才是graylog真正写入日志到外部存储的地方不同的实现都依赖一个MessageQueueAcknowledger，对于已经处理的消息进行确认，确保不会多次执行扩展的子类  

因为graylog比较依赖buffer，所以对于输出，套路与process类似，技术上也依赖了Disruptor消息处理上依赖一个OutputBufferProcessor，与process一致，OutputBufferProcessor后边

InputBuffer是graylog实际处理日志的部分，内部处理基于了Disruptor，同时还依赖了Journalling能力内部实际处理是依赖LocalKafka的（而且是推荐的）InputBuffer处理的几个

input是graylog处理消息的核心，内部对于网络的处理是基于了netty框架，消息的核心基类是MessageInput基类的能力如下图，包含了基本常用的配置，状态，以及input节点信息，同时

参考处理模块定义Graylog2ModuleprotectedvoidaddSystemRestResource(Class<?>restResourceClass){systemRestResourceBinder().addBinding().toI

graylog的journalmessage做为graylog背压的处理还是比较重要的一个模块，以下说明下具体实现功能接口图  简单调用关系  启动入口LocalKafkaJournal类

graylogjournalmessage是一个数据的背压处理策略，默认graylog对于消息是基于disruptor处理的，里边包含了buffer，但是如果消息比较多，来不及处理的journalmessage存储就

graylog的PluginModule可以简化graylog插件的开发，方便我们进行扩展参考功能类结构从下图可以看出是依赖了guice进行的包装，代码中好多都是支持依赖PluginModule开

grn是graylog的资源名称，属于一种urn，从功能上类似aws的arn主要用来进行权限以及资源分配管理参考格式grn:<cluster>:<tenant>:<scope>:<type>:<entity>