Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IO ¶
type IO struct {
// Requests sent to the UDF
Requests chan *udf.Request
// Responses from the UDF
Responses chan *udf.Response
// Any error that may have occurred
ErrC chan error
// contains filtered or unexported fields
}
IO implements a UDF process communication. Connect up to UDF server via In/Out pipes. Use Requests/Responses channels for reading and writing requests and responses for the UDF.
func (*IO) In ¶
func (o *IO) In() io.WriteCloser
func (*IO) Out ¶
func (o *IO) Out() udf.ByteReadReader
Click to show internal directories.
Click to hide internal directories.