stages

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2024 License: MIT Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Repo = map[string]core.NewStage{
	"connect":   NewConnect,
	"exec":      NewExec,
	"grep":      NewGrep,
	"limit":     NewLimit,
	"listen":    NewListen,
	"pipe":      NewPipe,
	"read":      NewRead,
	"speaker":   NewSpeaker,
	"stdin":     NewStdin,
	"stdout":    NewStdout,
	"websocket": NewWebsocket,
	"write":     NewWrite,
}

Functions

func NewConnect 

func NewConnect(parent *core.StageBase) core.Stage

func NewExec 

func NewExec(parent *core.StageBase) core.Stage

func NewGrep added in v0.9.0 

func NewGrep(parent *core.StageBase) core.Stage

func NewLimit added in v0.1.4 

func NewLimit(parent *core.StageBase) core.Stage

func NewListen 

func NewListen(parent *core.StageBase) core.Stage

func NewPipe added in v0.2.0 

func NewPipe(parent *core.StageBase) core.Stage

func NewRead added in v0.2.0 

func NewRead(parent *core.StageBase) core.Stage

func NewSpeaker 

func NewSpeaker(parent *core.StageBase) core.Stage

func NewStdin 

func NewStdin(parent *core.StageBase) core.Stage

func NewStdout 

func NewStdout(parent *core.StageBase) core.Stage

func NewWebsocket added in v0.1.6 

func NewWebsocket(parent *core.StageBase) core.Stage

func NewWrite added in v0.2.0 

func NewWrite(parent *core.StageBase) core.Stage

Types

type Connect 

type Connect struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Connect) Attach 

func (s *Connect) Attach() error

func (*Connect) Prepare 

func (s *Connect) Prepare() error

func (*Connect) Run 

func (s *Connect) Run() error

type Exec 

type Exec struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Exec) Attach 

func (s *Exec) Attach() error

func (*Exec) Prepare 

func (s *Exec) Prepare() (err error)

Prepare starts the command in background

func (*Exec) Run 

func (s *Exec) Run() (err error)

Run runs the data flow

func (*Exec) Stop 

func (s *Exec) Stop() error

Stop stops the flow of data

type Grep added in v0.9.0 

type Grep struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Grep) Attach added in v0.9.0 

func (s *Grep) Attach() error

type Limit added in v0.1.4 

type Limit struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Limit) Attach added in v0.1.4 

func (s *Limit) Attach() error

type Listen 

type Listen struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Listen) Attach 

func (s *Listen) Attach() error

func (*Listen) Prepare 

func (s *Listen) Prepare() error

func (*Listen) Run 

func (s *Listen) Run() error

type Pipe added in v0.2.0 

type Pipe struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Pipe) Attach added in v0.2.0 

func (s *Pipe) Attach() error

func (*Pipe) Prepare added in v0.2.0 

func (s *Pipe) Prepare() error

func (*Pipe) Run added in v0.2.0 

func (s *Pipe) Run() error

func (*Pipe) Stop added in v0.2.0 

func (s *Pipe) Stop() error

type Read added in v0.2.0 

type Read struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Read) Attach added in v0.2.0 

func (s *Read) Attach() error

func (*Read) Prepare added in v0.2.0 

func (s *Read) Prepare() error

func (*Read) Run added in v0.2.0 

func (s *Read) Run() error

func (*Read) Stop added in v0.2.0 

func (s *Read) Stop() error

type Speaker 

type Speaker struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Speaker) Attach 

func (s *Speaker) Attach() error

type Stdin 

type Stdin struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Stdin) Attach 

func (s *Stdin) Attach() error

func (*Stdin) Run 

func (s *Stdin) Run() error

func (*Stdin) Stop added in v0.2.0 

func (s *Stdin) Stop() error

type Stdout 

type Stdout struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Stdout) Attach 

func (s *Stdout) Attach() error

func (*Stdout) Run added in v0.2.0 

func (s *Stdout) Run() (err error)

func (*Stdout) Stop added in v0.2.0 

func (s *Stdout) Stop() error

type Websocket added in v0.1.6 

type Websocket struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Websocket) Attach added in v0.1.6 

func (s *Websocket) Attach() error

func (*Websocket) Prepare added in v0.1.6 

func (s *Websocket) Prepare() error

func (*Websocket) Run added in v0.1.6 

func (s *Websocket) Run() (err error)

func (*Websocket) Stop added in v0.1.6 

func (s *Websocket) Stop() error

type Write added in v0.2.0 

type Write struct {
	*core.StageBase
	// contains filtered or unexported fields
}

func (*Write) Attach added in v0.2.0 

func (s *Write) Attach() error

func (*Write) Prepare added in v0.2.0 

func (s *Write) Prepare() error

func (*Write) Run added in v0.2.0 

func (s *Write) Run() (err error)

func (*Write) Stop added in v0.2.0 

func (s *Write) Stop() error

Source Files

View all Source files

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.