filteredConn

Documentation

Index

• type FilteredConn
  • func NewFilteredConn(conn net.Conn, TxDataChannel chan interfaces.TrafficWithChannelTag, ...) *FilteredConn
  • func (fc *FilteredConn) Close() error
  • func (fc *FilteredConn) GetPacketStatus() (uint64, uint64)
  • func (fc *FilteredConn) LocalAddr() net.Addr
  • func (fc *FilteredConn) Read(p []byte) (int, error)
  • func (fc *FilteredConn) RemoteAddr() net.Addr
  • func (fc *FilteredConn) SetDeadline(t time.Time) error
  • func (fc *FilteredConn) SetReadDeadline(t time.Time) error
  • func (fc *FilteredConn) SetWriteDeadline(t time.Time) error
  • func (fc *FilteredConn) Write(p []byte) (int, error)
  • func (fc *FilteredConn) WriteC()

Types

type FilteredConn

type FilteredConn struct {
	TxDataChannel chan interfaces.TrafficWithChannelTag
	RxChannel     chan interfaces.TrafficWithChannelTag
	// contains filtered or unexported fields
}

func NewFilteredConn

func NewFilteredConn(conn net.Conn,
	TxDataChannel chan interfaces.TrafficWithChannelTag,
	RxChannel chan interfaces.TrafficWithChannelTag,
	ctx context.Context) *FilteredConn

func (*FilteredConn) Close

func (fc *FilteredConn) Close() error

func (*FilteredConn) GetPacketStatus

func (fc *FilteredConn) GetPacketStatus() (uint64, uint64)

func (*FilteredConn) LocalAddr

func (fc *FilteredConn) LocalAddr() net.Addr

func (*FilteredConn) Read

func (fc *FilteredConn) Read(p []byte) (int, error)

func (*FilteredConn) RemoteAddr

func (fc *FilteredConn) RemoteAddr() net.Addr

func (*FilteredConn) SetDeadline

func (fc *FilteredConn) SetDeadline(t time.Time) error

func (*FilteredConn) SetReadDeadline

func (fc *FilteredConn) SetReadDeadline(t time.Time) error

func (*FilteredConn) SetWriteDeadline

func (fc *FilteredConn) SetWriteDeadline(t time.Time) error

func (*FilteredConn) Write

func (fc *FilteredConn) Write(p []byte) (int, error)

func (*FilteredConn) WriteC

func (fc *FilteredConn) WriteC()