tcplog

Documentation

Index

• func NewMessage(t *testing.T) *cypress.Message
• type Formatter
• type Logger
  • func NewLogger(address string, ssl bool, formatter Formatter) *Logger
  • func (l *Logger) Close() error
  • func (l *Logger) Read(message interface{}) (err error)
  • func (l *Logger) ReadAsync(message interface{}) (err error)
  • func (l *Logger) Receive(message *cypress.Message) error
  • func (l *Logger) Run()
• type TcpServer
  • func NewTcpServer() *TcpServer
  • func (s *TcpServer) Run(host string)

Functions

func NewMessage

func NewMessage(t *testing.T) *cypress.Message

Types

type Formatter

type Formatter interface {
	Format(m *cypress.Message) ([]byte, error)
}

type Logger

type Logger struct {
	Formatter
	Address     string
	Ssl         bool
	Pump        chan []byte
	PumpClosed  bool
	PumpDropped uint64
	ConnDropped uint64
	// contains filtered or unexported fields
}

func NewLogger

func NewLogger(address string, ssl bool, formatter Formatter) *Logger

func (*Logger) Close

func (l *Logger) Close() error

func (*Logger) Read

func (l *Logger) Read(message interface{}) (err error)

func (*Logger) ReadAsync

func (l *Logger) ReadAsync(message interface{}) (err error)

func (*Logger) Receive

func (l *Logger) Receive(message *cypress.Message) error

func (*Logger) Run

func (l *Logger) Run()

type TcpServer

type TcpServer struct {
	Port     int
	Address  chan string
	Messages chan []byte
}

func NewTcpServer

func NewTcpServer() *TcpServer

func (*TcpServer) Run

func (s *TcpServer) Run(host string)