rainbond: github.com/goodrain/rainbond/eventlog/entry Index | Files | Directories

package entry

import "github.com/goodrain/rainbond/eventlog/entry"

Index

Package Files

docker_log_server.go event_log_server.go monitor_message_server.go new_monitor_message_server.go server.go

type DockerLogServer Uses

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

DockerLogServer 日志接受服务

func NewDockerLogServer Uses

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

NewDockerLogServer 创建zmq server服务端

func (*DockerLogServer) ListenError Uses

func (s *DockerLogServer) ListenError() chan error

ListenError listen error chan

func (*DockerLogServer) OnClose Uses

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

OnClose is called when the connection closed

func (*DockerLogServer) OnConnect Uses

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 Uses

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 Uses

func (s *DockerLogServer) Serve()

Serve 执行

func (*DockerLogServer) Stop Uses

func (s *DockerLogServer) Stop()

Stop 停止

type Entry Uses

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

Entry 数据入口

func NewEntry Uses

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

NewEntry 创建

func (*Entry) Start Uses

func (e *Entry) Start() error

Start 启动

func (*Entry) Stop Uses

func (e *Entry) Stop()

Stop 停止

type EventLogServer Uses

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

EventLogServer 日志接受服务

func NewEventLogServer Uses

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

NewEventLogServer 创建zmq server服务端

func (*EventLogServer) ListenError Uses

func (s *EventLogServer) ListenError() chan error

ListenError listen error chan

func (*EventLogServer) Serve Uses

func (s *EventLogServer) Serve()

Serve 执行

func (*EventLogServer) Stop Uses

func (s *EventLogServer) Stop()

Stop 停止

type MonitorMessageServer Uses

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

MonitorMessageServer 监控实时数据接受服务

func NewMonitorMessageServer Uses

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

NewMonitorMessageServer 创建zmq sub

func (*MonitorMessageServer) ListenError Uses

func (s *MonitorMessageServer) ListenError() chan error

ListenError listen error chan

func (*MonitorMessageServer) Serve Uses

func (s *MonitorMessageServer) Serve()

Serve 执行

func (*MonitorMessageServer) Stop Uses

func (s *MonitorMessageServer) Stop()

Stop 停止

type NMonitorMessageServer Uses

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

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

func NewNMonitorMessageServer Uses

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

NewNMonitorMessageServer 创建UDP服务端

func (*NMonitorMessageServer) ListenError Uses

func (s *NMonitorMessageServer) ListenError() chan error

ListenError listen error chan

func (*NMonitorMessageServer) Serve Uses

func (s *NMonitorMessageServer) Serve()

Serve 执行

func (*NMonitorMessageServer) Stop Uses

func (s *NMonitorMessageServer) Stop()

Stop 停止

Directories

PathSynopsis
grpc/client
grpc/pb
grpc/server

Package entry imports 13 packages (graph) and is imported by 1 packages. Updated 2018-11-21. Refresh now. Tools for package owners.