udf_test

Documentation

Index

• type IO
  • func NewIO() *IO
  • func (o *IO) In() io.WriteCloser
  • func (o *IO) Kill()
  • func (o *IO) Out() agent.ByteReadReader
• type UDF
  • func New(taskID, nodeID string, uio *IO, d udf.Diagnostic) *UDF
  • func (u *UDF) Close() error
  • func (u *UDF) Open() error

Types

type IO

type IO struct {

	// Requests sent to the UDF
	Requests chan *agent.Request
	// Responses from the UDF
	Responses chan *agent.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 NewIO

func NewIO() *IO

func (*IO) In

func (o *IO) In() io.WriteCloser

func (*IO) Kill

func (o *IO) Kill()

Forcefully kill the command. This will likely cause a panic.

func (*IO) Out

func (o *IO) Out() agent.ByteReadReader

type UDF

type UDF struct {
	*udf.Server
	// contains filtered or unexported fields
}

func New

func New(taskID, nodeID string, uio *IO, d udf.Diagnostic) *UDF

func (*UDF) Close

func (u *UDF) Close() error

func (*UDF) Open

func (u *UDF) Open() error