internal

Documentation

Index

• type ProtobufTCPWire
  • func NewProtobufTCPWire(maxMsgSize int, conn net.Conn) *ProtobufTCPWire
  • func (w *ProtobufTCPWire) Close()
  • func (w *ProtobufTCPWire) Receive(dst proto.Message) *wire.WireError
  • func (w *ProtobufTCPWire) Send(msg proto.Message) *wire.WireError
• type Status
• type TCPWire
  • func NewTCPWire(maxMsgSize int, conn net.Conn) *TCPWire
  • func (w *TCPWire) Close()
  • func (w *TCPWire) Receive() ([]byte, *wire.WireError)
  • func (w *TCPWire) Send(msg []byte) *wire.WireError
• type Wire

Types

type ProtobufTCPWire

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

func NewProtobufTCPWire

func NewProtobufTCPWire(maxMsgSize int, conn net.Conn) *ProtobufTCPWire

func (*ProtobufTCPWire) Close

func (w *ProtobufTCPWire) Close()

func (*ProtobufTCPWire) Receive

func (w *ProtobufTCPWire) Receive(dst proto.Message) *wire.WireError

func (*ProtobufTCPWire) Send

func (w *ProtobufTCPWire) Send(msg proto.Message) *wire.WireError

type Status

type Status int

const (
	Open   Status = 1
	Closed Status = 2
)

type TCPWire

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

func NewTCPWire

func NewTCPWire(maxMsgSize int, conn net.Conn) *TCPWire

func (*TCPWire) Close

func (w *TCPWire) Close()

func (*TCPWire) Receive

func (w *TCPWire) Receive() ([]byte, *wire.WireError)

func (*TCPWire) Send

func (w *TCPWire) Send(msg []byte) *wire.WireError

type Wire

type Wire interface {
	Send([]byte) *wire.WireError
	Receive() ([]byte, *wire.WireError)
	Close()
}