kubernetes/test/images/agnhost/nettest/nettest.go

var port …

var peerCount …

var service …

var namespace …

var delayShutdown …

var CmdNettest …

func init() { … }

type State …

func (s *State) doneContactingPeers() { … }

// serveStatus returns "pass", "running", or "fail".
func (s *State) serveStatus(w http.ResponseWriter, r *http.Request) { … }

// serveRead writes our json encoded state
func (s *State) serveRead(w http.ResponseWriter, r *http.Request) { … }

type WritePost …

type WriteResp …

// serveWrite records the contact in our state.
func (s *State) serveWrite(w http.ResponseWriter, r *http.Request) { … }

// appendErr adds err to the list, if err is not nil. s must be locked.
func (s *State) appendErr(err error) { … }

// Logf writes to the log message list. s must not be locked.
// s's Log member will drop an old message if it would otherwise
// become longer than 500 messages.
func (s *State) Logf(format string, args ...interface{ … }

// s must not be locked
func (s *State) appendSuccessfulSend(toHostname string) { … }

var state …

func main(cmd *cobra.Command, args []string) { … }

// Find all sibling pods in the service and post to their /write handler.
func contactOthers(state *State) { … }

// getWebserverEndpoints returns the webserver endpoints as a set of String, each in the format like "http://{ip}:{port}"
func getWebserverEndpoints(client clientset.Interface) sets.String { … }

// contactSingle dials the address 'e' and tries to POST to its /write address.
func contactSingle(e string, state *State) { … }