connectivity

type CheckCmd struct {
	// contains filtered or unexported fields
}

type CheckOption func(cmd *CheckCmd)

type Checker struct {
	ReverseDirection bool
	Protocol         string // "tcp" or "udp"

	CheckSNAT       bool
	RetriesDisabled bool
	StaggerStartBy  time.Duration

	// OnFail, if set, will be called instead of ginkgo.Fail().  (Useful for testing the checker itself.)
	OnFail func(msg string)
	// contains filtered or unexported fields
}

type CheckerOpt func(*Checker)

type ConnConfig struct {
	ConnType string
	ConnID   string
}

type ConnectionSource interface {
	PreRetryCleanup(ip, port, protocol string, opts ...CheckOption)
	CanConnectTo(ip, port, protocol string, opts ...CheckOption) *Result
	SourceName() string
	SourceIPs() []string
}

type ConnectionTarget interface {
	ToMatcher(explicitPort ...uint16) *Matcher
}

type ExpPacketLoss struct {
	Duration   time.Duration // how long test will run
	MaxPercent float64       // 10 means 10%. -1 means field not valid.
	MaxNumber  int           // 10 means 10 packets. -1 means field not valid.
}

type Expectation struct {
	From               ConnectionSource // Workload or Container
	To                 *Matcher         // Workload or IP, + port
	Expected           Expected
	ExpSrcIPs          []string
	ExpectedPacketLoss ExpPacketLoss

	ErrorStr string
	// contains filtered or unexported fields
}

type ExpectationOption func(e *Expectation)

type Expected bool

type MTUPair struct {
	Start int
	End   int
}

type Matcher struct {
	IP, Port, TargetName, Protocol string
}

type PersistentConnection struct {
	sync.Mutex

	RuntimeName         string
	Runtime             Runtime
	Name                string
	Protocol            string
	IP                  string
	Port                int
	SourcePort          int
	MonitorConnectivity bool
	NamespacePath       string
	Timeout             time.Duration
	// contains filtered or unexported fields
}

type Request struct {
	Timestamp    time.Time
	ID           string
	Payload      string
	SendSize     int
	ResponseSize int
}

type Response struct {
	Timestamp time.Time

	SourceAddr string
	ServerAddr string

	Request  Request
	ErrorStr string
}

type Result struct {
	LastResponse Response
	Stats        Stats
	ClientMTU    MTUPair
}

type Runtime interface {
	ExecMayFail(cmd ...string) error
}

type Stats struct {
	RequestsSent      int
	ResponsesReceived int
}

type TargetIP string // Just so we can define methods on it...

type TargetIPv4AsIPv6 string