workers

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: May 1, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ATProcessCancel 

func ATProcessCancel(w selina.Worker) error

ATProcessCancel a worker must terminate and return context.Canceled when context is canceled

func ATProcessCloseInput 

func ATProcessCloseInput(w selina.Worker) error

ATProcessCloseInput a worker must finish its job and return nil when input chanel (<-chan []byte )is closed

func ATProcessCloseOutput 

func ATProcessCloseOutput(w selina.Worker) error

ATProcessCloseOutput a worker must close its output channel on exit

Types

This section is empty.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.