receiver

Documentation

Index

• type Receiver
  • func NewReceiver(quit chan struct{}, path string) Receiver
  • func (r *Receiver) ReceiveOops(c net.Conn)
  • func (r *Receiver) Run(laddr *net.TCPAddr)
  • func (r *Receiver) Stop() error

Types

type Receiver

type Receiver struct {
	Wg sync.WaitGroup
	// contains filtered or unexported fields
}

Receiver implements a simple TCP service to receive Oopses

func NewReceiver

func NewReceiver(quit chan struct{}, path string) Receiver

NewReceiver is a Receiver factory

func (*Receiver) ReceiveOops

func (r *Receiver) ReceiveOops(c net.Conn)

ReceiverOops is the TPC connection handler that handles the reception of oopses

func (*Receiver) Run

func (r *Receiver) Run(laddr *net.TCPAddr)

Run start the Receiver service

func (*Receiver) Stop

func (r *Receiver) Stop() error

Stop stops the receptions of oops