internal

package

v1.0.8 Latest Latest Go to latest Published: Apr 29, 2025 License: BSD-3-Clause Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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 int

const (
	Open   Status = 1
	Closed Status = 2
)

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

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 interface {
	Send([]byte) *wire.WireError
	Receive() ([]byte, *wire.WireError)
	Close()
}