stages

Apr 12, 2024

Changes in this version

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

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

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

+ type Pipe struct

+ func (s *Pipe) Attach() error

+ func (s *Pipe) Prepare() error

+ func (s *Pipe) Run() error

+ func (s *Pipe) Stop() error

+ type Read struct

+ func (s *Read) Attach() error

+ func (s *Read) Prepare() error

+ func (s *Read) Run() error

+ func (s *Read) Stop() error

type Stdin

+ func (s *Stdin) Stop() error

type Stdout

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

+ func (s *Stdout) Stop() error

+ type Write struct

+ func (s *Write) Attach() error

+ func (s *Write) Prepare() error

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

+ func (s *Write) Stop() error

Feb 19, 2024

Changes in this version

+ func NewWebsocket(parent *bgpipe.StageBase) bgpipe.Stage

+ type Websocket struct

+ func (s *Websocket) Attach() error

+ func (s *Websocket) Prepare() error

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

+ func (s *Websocket) Stop() error

Oct 30, 2023

Changes in this version

+ const MAX_IPV6

+ func NewLimit(parent *bgpipe.StageBase) bgpipe.Stage

+ type Limit struct

+ func (s *Limit) Attach() error

Oct 26, 2023

Changes in this version

+ const EXEC_OUTPUT_BUF

+ var Repo = map[string]bgpipe.NewStage

+ func FnFlag(name, short, usage string, fn func()) *pflag.Flag

+ func NewConnect(parent *bgpipe.StageBase) bgpipe.Stage

+ func NewExec(parent *bgpipe.StageBase) bgpipe.Stage

+ func NewListen(parent *bgpipe.StageBase) bgpipe.Stage

+ func NewMrt(parent *bgpipe.StageBase) bgpipe.Stage

+ func NewSpeaker(parent *bgpipe.StageBase) bgpipe.Stage

+ func NewStdin(parent *bgpipe.StageBase) bgpipe.Stage

+ func NewStdout(parent *bgpipe.StageBase) bgpipe.Stage

+ type Connect struct

+ func (s *Connect) Attach() error

+ func (s *Connect) Prepare() error

+ func (s *Connect) Run() error

+ type Exec struct

+ func (s *Exec) Attach() error

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

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

+ func (s *Exec) Stop() error

+ type Listen struct

+ func (s *Listen) Attach() error

+ func (s *Listen) Prepare() error

+ func (s *Listen) Run() error

+ type Mrt struct

+ func (s *Mrt) Attach() error

+ func (s *Mrt) Run() error

+ type Speaker struct

+ func (s *Speaker) Attach() error

+ type Stdin struct

+ func (s *Stdin) Attach() error

+ func (s *Stdin) Run() error

+ type Stdout struct

+ func (s *Stdout) Attach() error

+ func (s *Stdout) OnMsg(m *msg.Msg) (action pipe.Action)