node

package

Go to main page

Versions in this module

v0

v0.7.1

Dec 4, 2024

Changes in this version

type Run

+ func (r *Run) Validate() (err error)

+ type UnionError struct

+ Set int

+ Value any

+ func (u UnionError) Error() string

v0.7.0

Nov 30, 2024

Changes in this version

type PacketClient

+ Key []byte

+ func (c *PacketClient) SetKey(key []byte)

type PacketServer

+ Key []byte

+ func (s *PacketServer) SetKey(key []byte)

type Runners

+ func (r *Runners) SetKeyer() (sk SetKeyer)

+ type SetKeyer interface

+ SetKey func([]byte)

type Sockopts

+ DSCP byte

+ ECN byte

type StreamClient

+ Key []byte

+ func (s *StreamClient) SetKey(key []byte)

type StreamServer

+ Key []byte

+ func (s *StreamServer) SetKey(key []byte)

type TCPInfo

+ SendSSThresh int

type Transfer

+ HMAC []byte

+ Nonce []byte

v0.6.0

Aug 30, 2024

Changes in this version

type Local

+ Set bool

+ Sudo bool

type PacketHeader

+ Sender int

type PacketIO

+ Server bool

type SSH

+ Set bool

+ Sudo bool

v0.5.0

Jun 27, 2024

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

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