entry

Documentation

Index

• type DockerLogServer
  • func NewDockerLogServer(conf conf.DockerLogServerConf, log *logrus.Entry, storeManager store.Manager) (*DockerLogServer, error)
  • func (s *DockerLogServer) ListenError() chan error
  • func (s *DockerLogServer) OnClose(*util.Conn)
  • func (s *DockerLogServer) OnConnect(c *util.Conn) bool
  • func (s *DockerLogServer) OnMessage(p util.Packet) bool
  • func (s *DockerLogServer) Serve()
  • func (s *DockerLogServer) Stop()
• type Entry
  • func NewEntry(conf conf.EntryConf, log *logrus.Entry, storeManager store.Manager) *Entry
  • func (e *Entry) Start() error
  • func (e *Entry) Stop()
• type EventLogServer
  • func NewEventLogServer(conf conf.EventLogServerConf, log *logrus.Entry, storeManager store.Manager) (*EventLogServer, error)
  • func (s *EventLogServer) ListenError() chan error
  • func (s *EventLogServer) Serve()
  • func (s *EventLogServer) Stop()
• type MonitorMessageServer
  • func NewMonitorMessageServer(conf conf.MonitorMessageServerConf, log *logrus.Entry, ...) (*MonitorMessageServer, error)
  • func (s *MonitorMessageServer) ListenError() chan error
  • func (s *MonitorMessageServer) Serve()
  • func (s *MonitorMessageServer) Stop()
• type NMonitorMessageServer
  • func NewNMonitorMessageServer(conf conf.NewMonitorMessageServerConf, log *logrus.Entry, ...) (*NMonitorMessageServer, error)
  • func (s *NMonitorMessageServer) ListenError() chan error
  • func (s *NMonitorMessageServer) Serve()
  • func (s *NMonitorMessageServer) Stop()

Types

type DockerLogServer

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

DockerLogServer 日志接受服务

func NewDockerLogServer

func NewDockerLogServer(conf conf.DockerLogServerConf, log *logrus.Entry, storeManager store.Manager) (*DockerLogServer, error)

NewDockerLogServer 创建zmq server服务端

func (*DockerLogServer) ListenError

func (s *DockerLogServer) ListenError() chan error

ListenError listen error chan

func (*DockerLogServer) OnClose

func (s *DockerLogServer) OnClose(*util.Conn)

OnClose is called when the connection closed

func (*DockerLogServer) OnConnect

func (s *DockerLogServer) OnConnect(c *util.Conn) bool

OnConnect is called when the connection was accepted, If the return value of false is closed

func (*DockerLogServer) OnMessage

func (s *DockerLogServer) OnMessage(p util.Packet) bool

OnMessage is called when the connection receives a packet, If the return value of false is closed

func (*DockerLogServer) Serve

func (s *DockerLogServer) Serve()

Serve 执行

func (*DockerLogServer) Stop

func (s *DockerLogServer) Stop()

Stop 停止

type Entry

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

Entry 数据入口

func NewEntry

func NewEntry(conf conf.EntryConf, log *logrus.Entry, storeManager store.Manager) *Entry

NewEntry 创建

func (*Entry) Start

func (e *Entry) Start() error

Start 启动

func (*Entry) Stop

func (e *Entry) Stop()

Stop 停止

type EventLogServer

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

EventLogServer 日志接受服务

func NewEventLogServer

func NewEventLogServer(conf conf.EventLogServerConf, log *logrus.Entry, storeManager store.Manager) (*EventLogServer, error)

NewEventLogServer 创建zmq server服务端

func (*EventLogServer) ListenError

func (s *EventLogServer) ListenError() chan error

ListenError listen error chan

func (*EventLogServer) Serve

func (s *EventLogServer) Serve()

Serve 执行

func (*EventLogServer) Stop

func (s *EventLogServer) Stop()

Stop 停止

type MonitorMessageServer

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

MonitorMessageServer 监控实时数据接受服务

func NewMonitorMessageServer

func NewMonitorMessageServer(conf conf.MonitorMessageServerConf, log *logrus.Entry, storeManager store.Manager) (*MonitorMessageServer, error)

NewMonitorMessageServer 创建zmq sub

func (*MonitorMessageServer) ListenError

func (s *MonitorMessageServer) ListenError() chan error

ListenError listen error chan

func (*MonitorMessageServer) Serve

func (s *MonitorMessageServer) Serve()

Serve 执行

func (*MonitorMessageServer) Stop

func (s *MonitorMessageServer) Stop()

Stop 停止

type NMonitorMessageServer

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

NMonitorMessageServer 新性能分析实时数据接受服务

func NewNMonitorMessageServer

func NewNMonitorMessageServer(conf conf.NewMonitorMessageServerConf, log *logrus.Entry, storeManager store.Manager) (*NMonitorMessageServer, error)

NewNMonitorMessageServer 创建UDP服务端

func (*NMonitorMessageServer) ListenError

func (s *NMonitorMessageServer) ListenError() chan error

ListenError listen error chan

func (*NMonitorMessageServer) Serve

func (s *NMonitorMessageServer) Serve()

Serve 执行

func (*NMonitorMessageServer) Stop

func (s *NMonitorMessageServer) Stop()

Stop 停止