udf_test

package
v1.5.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 5, 2020 License: MIT Imports: 7 Imported by: 0

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 *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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL