stages

package

v0.1.7 Latest Latest Go to latest Published: Mar 22, 2024 License: MIT Imports: 31 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bgpfix/bgpipe

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Variables
func NewConnect(parent *bgpipe.StageBase) bgpipe.Stage
func NewExec(parent *bgpipe.StageBase) bgpipe.Stage
func NewLimit(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
func NewWebsocket(parent *bgpipe.StageBase) bgpipe.Stage
type Connect
- func (s *Connect) Attach() error
- func (s *Connect) Prepare() error
- func (s *Connect) Run() error
type Exec
- func (s *Exec) Attach() error
- func (s *Exec) Prepare() (err error)
- func (s *Exec) Run() (err error)
- func (s *Exec) Stop() error
type Limit
- func (s *Limit) Attach() error
type Listen
- func (s *Listen) Attach() error
- func (s *Listen) Prepare() error
- func (s *Listen) Run() error
type Mrt
- func (s *Mrt) Attach() error
- func (s *Mrt) Run() error
type Speaker
- func (s *Speaker) Attach() error
type Stdin
- func (s *Stdin) Attach() error
- func (s *Stdin) Run() error
type Stdout
- func (s *Stdout) Attach() error
- func (s *Stdout) OnMsg(m *msg.Msg)
type Websocket
- func (s *Websocket) Attach() error
- func (s *Websocket) Prepare() error
- func (s *Websocket) Run() (err error)
- func (s *Websocket) Stop() error

Constants ¶

This section is empty.

Variables ¶

View Source

var Repo = map[string]bgpipe.NewStage{
	"connect":   NewConnect,
	"listen":    NewListen,
	"speaker":   NewSpeaker,
	"mrt":       NewMrt,
	"stdout":    NewStdout,
	"stdin":     NewStdin,
	"exec":      NewExec,
	"limit":     NewLimit,
	"websocket": NewWebsocket,
}

Functions ¶

func NewConnect ¶

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

func NewExec ¶

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

func NewLimit ¶ added in v0.1.4

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

func NewListen ¶

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

func NewMrt ¶

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

func NewSpeaker ¶

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

func NewStdin ¶

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

func NewStdout ¶

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

func NewWebsocket ¶ added in v0.1.6

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

Types ¶

type Connect ¶

type Connect struct {
	*bgpipe.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 {
	*bgpipe.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)

func (*Exec) Stop ¶

func (s *Exec) Stop() error

type Limit ¶ added in v0.1.4

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

func (*Limit) Attach ¶ added in v0.1.4

func (s *Limit) Attach() error

type Listen ¶

type Listen struct {
	*bgpipe.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 Mrt ¶

type Mrt struct {
	*bgpipe.StageBase
	// contains filtered or unexported fields
}

func (*Mrt) Attach ¶

func (s *Mrt) Attach() error

func (*Mrt) Run ¶

func (s *Mrt) Run() error

type Speaker ¶

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

func (*Speaker) Attach ¶

func (s *Speaker) Attach() error

type Stdin ¶

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

func (*Stdin) Attach ¶

func (s *Stdin) Attach() error

func (*Stdin) Run ¶

func (s *Stdin) Run() error

type Stdout ¶

type Stdout struct {
	*bgpipe.StageBase
}

func (*Stdout) Attach ¶

func (s *Stdout) Attach() error

func (*Stdout) OnMsg ¶

func (s *Stdout) OnMsg(m *msg.Msg)

type Websocket ¶ added in v0.1.6

type Websocket struct {
	*bgpipe.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

Source Files ¶

View all Source files

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