tcpcollect

Documentation

Index

• type ClientStatus
  • func (c *ClientStatus) ClientHost() string
• type TCPCollect
  • func New(cfg *conf.Collect) *TCPCollect
  • func (s *TCPCollect) ClientStatus() []*ClientStatus
  • func (s *TCPCollect) Close() error
  • func (s *TCPCollect) RegisterProcess(p process.Processer)
  • func (s *TCPCollect) Start() error

Types

type ClientStatus

type ClientStatus struct {
	Addr         string
	Counter      counter.Counter
	ErrorCounter counter.Counter
	UpTime       int64
}

ClientStatus agent client status

func (*ClientStatus) ClientHost

func (c *ClientStatus) ClientHost() string

ClientHost extract from client addr

type TCPCollect

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

TCPCollect tcp server.

func New

func New(cfg *conf.Collect) *TCPCollect

New tcp server.

func (*TCPCollect) ClientStatus

func (s *TCPCollect) ClientStatus() []*ClientStatus

ClientStatus ClientStatus

func (*TCPCollect) Close

func (s *TCPCollect) Close() error

Close tcp server.

func (*TCPCollect) RegisterProcess

func (s *TCPCollect) RegisterProcess(p process.Processer)

RegisterProcess implement process.Processer

func (*TCPCollect) Start

func (s *TCPCollect) Start() error

Start tcp server.