taskrunner

package

v0.0.5 Latest Latest Go to latest Published: Jan 18, 2022 License: MulanPSL-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/shanghaitech-university-codec_0/video_server

Links

Open Source Insights

Documentation ¶

Overview ¶

* @Descripttion: * @version: * @Author: congsir * @Date: 2022-01-14 14:59:52 * @LastEditors: Please set LastEditors * @LastEditTime: 2022-01-18 12:22:12

* @Descripttion: * @version: * @Author: congsir * @Date: 2022-01-14 14:59:12 * @LastEditors: Please set LastEditors * @LastEditTime: 2022-01-14 17:48:22

* @Descripttion: * @version: * @Author: congsir * @Date: 2022-01-14 14:59:21 * @LastEditors: Please set LastEditors * @LastEditTime: 2022-01-18 17:57:41

* @Descripttion: * @version: * @Author: congsir * @Date: 2022-01-14 14:59:31 * @LastEditors: Please set LastEditors * @LastEditTime: 2022-01-18 10:27:03

Index ¶

Constants
func Start()
func VideoClearDispatcher(dc dataChan) error
func VideoClearExecutor(dc dataChan) error
type Runner
- func NewRunner(size int, longlived bool, d fn, e fn) *Runner
- func (r *Runner) StartAll()
type Worker
- func NewWorker(interval time.Duration, r *Runner) *Worker

Constants ¶

View Source

const (
	READY_TO_DISPATCH = "d"
	READY_TO_EXECUTE  = "e"
	CLOSE             = "c"
	VIDEO_PATH        = "../streamserver/videos/"
)

Variables ¶

This section is empty.

Functions ¶

func Start ¶

func Start()

func VideoClearDispatcher ¶

func VideoClearDispatcher(dc dataChan) error

func VideoClearExecutor ¶

func VideoClearExecutor(dc dataChan) error

Types ¶

type Runner ¶

type Runner struct {
	Controller controlChan
	Error      controlChan
	Data       dataChan

	Dispatcher fn
	Executor   fn
	// contains filtered or unexported fields
}

func NewRunner ¶

func NewRunner(size int, longlived bool, d fn, e fn) *Runner

func (*Runner) StartAll ¶

func (r *Runner) StartAll()

type Worker ¶

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

func NewWorker ¶

func NewWorker(interval time.Duration, r *Runner) *Worker

Source Files ¶

View all Source files

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