actions

package
v0.0.0-...-7352399 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 8, 2022 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const TOS_CRITICAL = "0x68" // AF31
View Source 
const TOS_HIPRI = "0x48" // AF21
View Source 
const TOS_LOPRI = "0x00" // BE

Variables

View Source 
var TraceCommands = os.Getenv("TRACE_CMD") == "1"

Functions

func CheckNodeConnectivity 

func CheckNodeConnectivity(c *pb.DeploymentConfig) error

func CheckNodeIPs 

func CheckNodeIPs(c *pb.DeploymentConfig) error

func CloudlabDualNetFix 

func CloudlabDualNetFix(rspec *configgen.RSpec, sshUser string, verbose bool) error

func ConfigureSys 

func ConfigureSys(c *pb.DeploymentConfig, sysConfig *SysConfig) error

func DeleteLogs 

func DeleteLogs(c *pb.DeploymentConfig, remoteTopdir string) error

func FetchData 

func FetchData(c *pb.DeploymentConfig, remoteTopdir, outdir string) error

func FortioRunClients 

func FortioRunClients(c *pb.DeploymentConfig, remoteTopdir string, showOut bool, directDebug bool) error

func FortioStartServers 

func FortioStartServers(c *pb.DeploymentConfig, remoteTopdir, envoyLogLevel string) error

func GracefulStopHEYPAgents 

func GracefulStopHEYPAgents(c *pb.DeploymentConfig, remoteTopdir string) error

func GracefulStopVFortioInstances 

func GracefulStopVFortioInstances(c *pb.DeploymentConfig, remoteTopdir string) error

func InstallCodeBundle 

func InstallCodeBundle(c *pb.DeploymentConfig, localTarball, remoteTopdir string) error

func KillFortio 

func KillFortio(c *pb.DeploymentConfig) error

func KillHEYP 

func KillHEYP(c *pb.DeploymentConfig) error

func KillIPerf 

func KillIPerf(c *pb.DeploymentConfig) error

func KillSessions 

func KillSessions(c *pb.DeploymentConfig, sessionRegexp string) error

func LogWithPrefix 

func LogWithPrefix(prefix string) func(format string, args ...interface{})

func LookupNode 

func LookupNode(c *pb.DeploymentConfig, name string) *pb.DeployedNode

func MakeCodeBundle 

func MakeCodeBundle(binDir, auxBinDir, tarballPath string) error

func MeasureNodeBandwidth 

func MeasureNodeBandwidth(c *pb.DeploymentConfig) error

func ReportPrioritizationBW 

func ReportPrioritizationBW(c *pb.DeploymentConfig, lohiTOS [2]string) (hipri float64, lopri float64, err error)

func ResetNodesFromVFortio 

func ResetNodesFromVFortio(c *pb.DeploymentConfig, remoteTopdir string) error

func RunHostAgentSims 

func RunHostAgentSims(c *pb.DeploymentConfig, remoteTopdir string, showOut bool) error

func StartCollectingHostStats 

func StartCollectingHostStats(c *pb.DeploymentConfig, remoteTopdir string) error

func StartHEYPAgents 

func StartHEYPAgents(c *pb.DeploymentConfig, remoteTopdir string, startConfig HEYPAgentsConfig) error

func StopCollectingHostStats 

func StopCollectingHostStats(c *pb.DeploymentConfig, remoteTopdir string) error

func StopHEYP 

func StopHEYP(c *pb.DeploymentConfig) error

func StopSessions 

func StopSessions(c *pb.DeploymentConfig, sessionRegexp string) error

func TestLOPRIRunClients 

func TestLOPRIRunClients(c *pb.DeploymentConfig, remoteTopdir string, showOut bool) error

func TestLOPRIStartServers 

func TestLOPRIStartServers(c *pb.DeploymentConfig, remoteTopdir string) error

Types

type ClusterAgentNode 

type ClusterAgentNode struct {
	Node      *pb.DeployedNode
	Cluster   *pb.DeployedCluster
	Addresses []string
}

type FortioConfig 

type FortioConfig struct {
	Config  *pb.DeployedFortioConfig
	Proxies []*pb.DeployedNode
	Relays  []*pb.DeployedNode
	Groups  map[string]*FortioGroup
	// contains filtered or unexported fields
}

func GetAndValidateFortioConfig 

func GetAndValidateFortioConfig(dc *pb.DeploymentConfig) (*FortioConfig, error)

func (*FortioConfig) GetEnvoyYAML 

func (fc *FortioConfig) GetEnvoyYAML(proxyNode *pb.DeployedNode) string

func (*FortioConfig) GetForwardMap 

func (fc *FortioConfig) GetForwardMap(relayNode *pb.DeployedNode) map[FortioFwdKey]int32

func (*FortioConfig) GetNATRules 

func (fc *FortioConfig) GetNATRules(relayNode *pb.DeployedNode) relay.NATRules

func (*FortioConfig) UseRelays 

func (fc *FortioConfig) UseRelays() bool

type FortioFwdKey 

type FortioFwdKey struct {
	Group      string
	Inst       string
	ServePort  int32
	ServerAddr string
}

type FortioGroup 

type FortioGroup struct {
	Config       *pb.DeployedFortioGroup
	GroupProxies []*pb.DeployedNode
	GroupRelays  []*pb.DeployedNode
	Instances    map[string]*FortioInstance
}

type FortioInstance 

type FortioInstance struct {
	Config  *pb.DeployedFortioInstance
	Servers []*pb.DeployedNode
	Clients []*pb.DeployedNode
}

type HEYPAgentsConfig 

type HEYPAgentsConfig struct {
	LogClusterAllocState    bool
	LogEnforcerState        bool
	LogHostStats            bool
	LogFineGrainedHostStats bool

	HostAgentVLog int
}

func DefaultHEYPAgentsConfig 

func DefaultHEYPAgentsConfig() HEYPAgentsConfig

type HEYPNodeConfigs 

type HEYPNodeConfigs struct {
	ClusterAgentNodes []ClusterAgentNode
	HostAgentNodes    []HostAgentNode
	NodeVHostAgents   map[string][]HostAgentNode
	DCMapperConfig    *pb.StaticDCMapperConfig
}

func GetAndValidateHEYPNodeConfigs 

func GetAndValidateHEYPNodeConfigs(c *pb.DeploymentConfig) (HEYPNodeConfigs, error)

func (*HEYPNodeConfigs) MakeHostAgentConfig 

func (nodeConfigs *HEYPNodeConfigs) MakeHostAgentConfig(c *pb.DeploymentConfig, startConfig HEYPAgentsConfig, remoteTopdir string, n HostAgentNode) *pb.HostAgentConfig

type HostAgentNode 

type HostAgentNode struct {
	Host                       *pb.DeployedNode
	ControlledExperimentAddrID int
	JobName                    string
	ClusterAgentAddr           string
	PatchHostAgentConfigFunc   func(c *pb.HostAgentConfig)
}

type HostAgentSimConfig 

type HostAgentSimConfig struct {
	SrcDC             string
	ClusterAgentAddrs []string
	C                 *pb.DeployedHostAgentSimConfig
	Nodes             []*pb.DeployedNode
}

func GetAndValidateHostAgentSimConfigs 

func GetAndValidateHostAgentSimConfigs(c *pb.DeploymentConfig) ([]HostAgentSimConfig, error)

type SysConfig 

type SysConfig struct {
	CongestionControl            string
	MinPort, MaxPort             int
	DebugMonitoring              bool
	StartDropAfterNumUnauthConns int
	StartDropRatePerc            int
	MaxUnauthConns               int
}

func DefaultSysConfig 

func DefaultSysConfig() SysConfig

type TracingCmd 

type TracingCmd struct {
	*exec.Cmd
	// contains filtered or unexported fields
}

func TracingCommand 

func TracingCommand(logf func(format string, args ...interface{}),
	name string, args ...string) *TracingCmd

func TracingCommandContext 

func TracingCommandContext(ctx context.Context, logf func(format string, args ...interface{}),
	name string, args ...string) *TracingCmd

func (*TracingCmd) CombinedOutput 

func (c *TracingCmd) CombinedOutput() ([]byte, error)

func (*TracingCmd) Output 

func (c *TracingCmd) Output() ([]byte, error)

func (*TracingCmd) Run 

func (c *TracingCmd) Run() error

func (*TracingCmd) SetStderr 

func (c *TracingCmd) SetStderr(dst string, w io.Writer)

func (*TracingCmd) SetStdin 

func (c *TracingCmd) SetStdin(src string, r io.Reader)

func (*TracingCmd) SetStdout 

func (c *TracingCmd) SetStdout(dst string, w io.Writer)

func (*TracingCmd) Start 

func (c *TracingCmd) Start() error

func (*TracingCmd) StderrPipe 

func (c *TracingCmd) StderrPipe(dst string) (io.ReadCloser, error)

func (*TracingCmd) StdinPipe 

func (c *TracingCmd) StdinPipe(src string) (io.WriteCloser, error)

func (*TracingCmd) StdoutPipe 

func (c *TracingCmd) StdoutPipe(dst string) (io.ReadCloser, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.