stages

package

v0.1.4 Latest Latest Go to latest Published: Oct 30, 2023 License: MIT Imports: 29 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 ¶

Constants
Variables
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 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
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) (action pipe.Action)

Constants ¶

View Source

const (
	EXEC_OUTPUT_BUF = 100
)

View Source

const (
	MAX_IPV6 = 58 // 58 bits for prefix + 6 bits for length
)

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,
}

Functions ¶

func FnFlag ¶

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

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

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
	// contains filtered or unexported fields
}

func (*Stdout) Attach ¶

func (s *Stdout) Attach() error

func (*Stdout) OnMsg ¶

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

Source Files ¶

View all Source files

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