entry

package
v3.6.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 11, 2018 License: LGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 停止

Directories

Path Synopsis
grpc
pb

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL