Versions in this module Expand all Collapse all v0 v0.14.2 Sep 20, 2019 Changes in this version + type Handler interface + OnBarrierReply func(openflow.Factory, Writer, openflow.BarrierReply) error + OnDescReply func(openflow.Factory, Writer, openflow.DescReply) error + OnError func(openflow.Factory, Writer, openflow.Error) error + OnFeaturesReply func(openflow.Factory, Writer, openflow.FeaturesReply) error + OnFlowRemoved func(openflow.Factory, Writer, openflow.FlowRemoved) error + OnGetConfigReply func(openflow.Factory, Writer, openflow.GetConfigReply) error + OnHello func(openflow.Factory, Writer, openflow.Hello) error + OnPacketIn func(openflow.Factory, Writer, openflow.PacketIn) error + OnPortDescReply func(openflow.Factory, Writer, openflow.PortDescReply) error + OnPortStatus func(openflow.Factory, Writer, openflow.PortStatus) error + type Stream struct + func NewStream(channel io.ReadWriteCloser, bufSize int) *Stream + func (r *Stream) Close() error + func (r *Stream) GetReadTimeout() time.Duration + func (r *Stream) GetWriteTimeout() time.Duration + func (r *Stream) LastRead() time.Time + func (r *Stream) LastWrite() time.Time + func (r *Stream) Peek(n int) ([]byte, error) + func (r *Stream) Read(p []byte) (n int, err error) + func (r *Stream) ReadN(n int) (p []byte, err error) + func (r *Stream) RemoteAddr() net.Addr + func (r *Stream) SetReadTimeout(t time.Duration) + func (r *Stream) SetWriteTimeout(t time.Duration) + func (r *Stream) Write(p []byte) (n int, err error) + type Transceiver struct + func NewTransceiver(stream *Stream, handler Handler) *Transceiver + func (r *Transceiver) Close() error + func (r *Transceiver) Run(ctx context.Context) error + func (r *Transceiver) Version() (negotiated bool, version uint8) + func (r *Transceiver) Write(msg encoding.BinaryMarshaler) error + type WriteCloser interface + Close func() error + type Writer interface + Write func(msg encoding.BinaryMarshaler) error