ipc

package

v2.19.1 Latest Latest Go to latest Published: Oct 20, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func ReadProto(r io.Reader, msg proto.Message) error

ReadProto reads a length-prefixed protobuf message into msg.

func WriteProto(w io.Writer, msg proto.Message) error

WriteProto sends a protobuf message with a 4-byte big-endian length prefix.

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

Listener wraps a net.Listener for protobuf IPC.

func Listen(addr string) (*Listener, error)

Listen creates a new IPC listener on the given address.

func (l *Listener) Accept() (net.Conn, error)

Accept waits for a new connection.

func (l *Listener) Addr() net.Addr

Addr returns the listener's address.

func (l *Listener) Close() error

Close closes the listener.