Versions in this module Expand all Collapse all v0 v0.4.0 Dec 21, 2023 Changes in this version + type Command struct + Arg []string + Command string + func (c Command) Cmd() *exec.Cmd + func (c Command) CmdContext(ctx context.Context) *exec.Cmd + func (c Command) Text(ctx context.Context) (txt string, err error) + type CommandError struct + Command string + Err error + Out []byte + func (c CommandError) Error() string + func (c CommandError) Unwrap() error + type CommandOutput struct + Out []byte + String string + func (c CommandOutput) Trim() string + type EnvVar string + func (v EnvVar) Text(ctx context.Context) (txt string, err error) + type EnvVars []string type Error + func (e Error) GetLogEntry() LogEntry + type File string + func (f File) Data() (data []byte, err error) + func (f File) Name() string + func (f File) Text(ctx context.Context) (txt string, err error) type FileData + func (f FileData) Trim() string + type ID string + func (n ID) String() string type LogEntry + func (l LogEntry) GetLogEntry() LogEntry + type LogFactory struct + func (f LogFactory) NewLogEntry(message string) LogEntry + func (f LogFactory) NewLogEntryf(format string, a ...any) LogEntry type Runners + SysInfo *SysInfo + type Sockopt struct + Level int + Name string + Opt int + Type string + Value any + type Sockopts struct + CCA string + DS int + Sockopt []Sockopt + type SysInfo struct + Command []Command + Env EnvVars + File []File + KernSrcInfo Texters + KernSrcVer Texters + OS Texters + Sysctl Sysctls + func (s SysInfo) Run(ctx context.Context, arg runArg) (ofb Feedback, err error) + type SysInfoData struct + AntlerVersion string + BuildSetting map[string]string + Command map[string]CommandOutput + Env map[string]string + File map[string]FileData + GoArch string + GoBuildVersion string + GoOS string + GoVersion string + Hostname string + KernSrcInfo string + KernSrcVer string + NodeID ID + NumCPU int + OS string + Sysctl map[string]string + type Sysctl string + func (s Sysctl) Text(ctx context.Context) (txt string, err error) + type Sysctls []string + type Texter interface + Text func(context.Context) (string, error) + type Texters struct + Command *Command + Env *EnvVar + File *File + Sysctl *Sysctl v0.3.0 Aug 18, 2023 Changes in this version + const EnvMax + const RootNodeID + var ParentNode = Node + func Do(rn *Run, src ExeSource, ctrl Control, data chan interface{}) + func PipeConn() (conn1, conn2 io.ReadWriteCloser) + func Serve(nodeID string, ctrl Control, conn io.ReadWriteCloser) error + func StdioConn() io.ReadWriteCloser + type Child struct + Node Node + type Control struct + func NewControl() Control + func (c Control) Cancel(reason string) + func (c Control) Stop() + type Direction string + const Down + const Up + type Download struct + func (d Download) String() string + type Env struct + Inherit bool + Vars [EnvMax]string + type Error struct + Message string + NodeID string + Tag string + Time time.Time + func (e Error) Error() string + func (e Error) String() string + type ErrorFactory struct + func (f ErrorFactory) NewError(message string) Error + func (f ErrorFactory) NewErrore(err error) Error + func (f ErrorFactory) NewErrorf(format string, a ...interface{}) Error + type ExeName string + func PlatformExeName(platform string) ExeName + func (n ExeName) Platform() string + func (n ExeName) String() string + func (n ExeName) Valid() bool + type ExeSource interface + Platforms func() ([]string, error) + Reader func(platform string) (io.ReadCloser, error) + Size func(platform string) (int64, error) + type Feedback map[string]interface + type FileData struct + Data []byte + Name string + func (f FileData) String() string + type Flow string + type Flower interface + Flow func() Flow + type Local struct + type Location string + const Client + const Server + type LogEntry struct + NodeID string + Tag string + Text string + Time time.Time + func (e LogEntry) String() string + type MessageFilter struct + All bool + File []string + Flow []Flow + Log bool + type Netns struct + Create bool + Name string + type Node struct + Env Env + ID NodeID + Launcher launchers + Netns Netns + Platform string + func (n Node) String() string + type NodeID string + func (n NodeID) String() string + type Packet struct + Len int + type PacketClient struct + Addr string + Flow Flow + MaxPacketSize int + Protocol string + Sender []PacketSenders + func (c *PacketClient) Run(ctx context.Context, arg runArg) (ofb Feedback, err error) + type PacketFlag byte + const FlagEcho + const FlagReply + type PacketHeader struct + Flag PacketFlag + Flow Flow + Seq Seq + func (p *PacketHeader) Len() int + func (p *PacketHeader) Read(b []byte) (n int, err error) + func (p *PacketHeader) Write(b []byte) (n int, err error) + type PacketIO struct + Sent bool + T metric.RelativeTime + func (p PacketIO) String() string + type PacketInfo struct + Flow Flow + Server bool + Tinit time.Time + func (p PacketInfo) String() string + func (p PacketInfo) Time(r metric.RelativeTime) time.Time + type PacketSenders struct + Unresponsive *Unresponsive + type PacketServer struct + ListenAddr string + MaxPacketSize int + Protocol string + func (s *PacketServer) Cancel(rec *recorder) error + func (s *PacketServer) Run(ctx context.Context, arg runArg) (ofb Feedback, err error) + type Parallel []Run + type ResultStream struct + Exclude *MessageFilter + Include *MessageFilter + func (s *ResultStream) Run(ctx context.Context, arg runArg) (ofb Feedback, err error) + type Run struct + Child *Child + Parallel Parallel + Schedule *Schedule + Serial Serial + type Runners struct + PacketClient *PacketClient + PacketServer *PacketServer + ResultStream *ResultStream + Setup *setup + Sleep *Sleep + StreamClient *StreamClient + StreamServer *StreamServer + System *System + type SSH struct + Destination string + type Schedule struct + Random bool + Run []Run + Sequential bool + Wait []metric.Duration + WaitFirst bool + type Seq uint64 + type Serial []Run + type Sleep metric.Duration + func (s *Sleep) Run(ctx context.Context, arg runArg) (ofb Feedback, err error) + func (s *Sleep) UnmarshalText(text []byte) (err error) + type Stream struct + CCA string + Direction Direction + Flow Flow + func (s Stream) Info(server bool) StreamInfo + func (s Stream) String() string + type StreamClient struct + Addr string + AddrKey string + Protocol string + func (s *StreamClient) Run(ctx context.Context, arg runArg) (ofb Feedback, err error) + type StreamIO struct + Flow Flow + Sent bool + T metric.RelativeTime + Total metric.Bytes + func (s StreamIO) String() string + type StreamInfo struct + Server bool + Tinit time.Time + func (s StreamInfo) String() string + func (s StreamInfo) Time(r metric.RelativeTime) time.Time + type StreamServer struct + ListenAddr string + ListenAddrKey string + Protocol string + func (s *StreamServer) Cancel(rec *recorder) error + func (s *StreamServer) Run(ctx context.Context, arg runArg) (ofb Feedback, err error) + type Streamers struct + Download *Download + Upload *Upload + type System struct + Args []string + Background bool + Command string + IgnoreErrors bool + Kill bool + Stderr string + Stdout string + func (s *System) Cancel(rec *recorder) (err error) + func (s *System) Run(ctx context.Context, arg runArg) (ofb Feedback, err error) + type TCPInfo struct + DeliveryRate metric.Bitrate + PacingRate metric.Bitrate + RTT time.Duration + RTTVar time.Duration + SampleTime time.Duration + SendCwnd int + SendMSS metric.Bytes + T metric.RelativeTime + TotalRetransmits int + func (t TCPInfo) String() string + type TCPInfoID struct + Flow Flow + Location Location + type Transfer struct + BufLen int + Duration metric.Duration + IOSampleInterval metric.Duration + Length metric.Bytes + TCPInfoInterval metric.Duration + type Tree map[Node]Tree + func NewTree(run *Run) (t Tree) + func (t Tree) Platforms() (platform []string) + func (t Tree) Walk(visitor func(Node) bool) bool + type Unresponsive struct + Duration metric.Duration + Echo bool + Length []int + RandomLength bool + RandomWait bool + Wait []metric.Duration + WaitFirst bool + type Upload struct + func (u Upload) String() string v0.3.0-beta Oct 15, 2022