entry

package
v0.0.0-...-a3a5c94 Latest Latest
Warning

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

Go to latest
Published: Aug 21, 2021 License: MIT 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 - log acceptance service

func NewDockerLogServer

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

NewDockerLogServer - create 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 - data 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 - log acceptance service

func NewEventLogServer

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

NewEventLogServer - create 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 - monitor real-time data acceptance service

func NewMonitorMessageServer

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

NewMonitorMessageServer - create 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 - new performance analysis real-time data acceptance service

func NewNMonitorMessageServer

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

NewNMonitorMessageServer - create UDP server

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