kubernetes/test/images/agnhost/netexec/netexec.go

var httpPort …

var udpPort …

var sctpPort …

var shellPath …

var serverReady …

var certFile …

var privKeyFile …

var httpOverride …

var udpListenAddresses …

var delayShutdown …

const bindToAny …

var CmdNetexec …

func init() { … }

type atomicBool …

// set sets the int32 to the given boolean.
func (a *atomicBool) set(value bool) { … }

// get returns true if the int32 == 1
func (a *atomicBool) get() bool { … }

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

func addRoutes(mux *http.ServeMux, sigTermReceived chan struct{ … }

func startServer(server *http.Server, exitCh chan shutdownRequest, fn func() error) { … }

func rootHandler(w http.ResponseWriter, r *http.Request) { … }

func echoHandler(w http.ResponseWriter, r *http.Request) { … }

func clientIPHandler(w http.ResponseWriter, r *http.Request) { … }

func headerHandler(w http.ResponseWriter, r *http.Request) { … }

type shutdownRequest …

func exitHandler(w http.ResponseWriter, r *http.Request, exitCh chan<- shutdownRequest) { … }

func hostnameHandler(w http.ResponseWriter, r *http.Request) { … }

// healthHandler response with a 200 if the UDP server is ready. It also serves
// as a health check of the HTTP server by virtue of being a HTTP handler.
func healthzHandler(w http.ResponseWriter, r *http.Request) { … }

// readyzHandler response with a 200 if the UDP server is ready. It serves as a readyz that will return a 503
// once a sig-term has been received.   This allows for graceful removal from endpoints during a pod delete flow.
func readyzHandler(sigTermReceived chan struct{ … }

func shutdownHandler(w http.ResponseWriter, r *http.Request) { … }

func dialHandler(w http.ResponseWriter, r *http.Request) { … }

func dialHTTP(request string, addr net.Addr) (string, error) { … }

func createHTTPClient(transport *http.Transport) *http.Client { … }

func dialUDP(request string, addr net.Addr) (string, error) { … }

func dialSCTP(request string, addr net.Addr) (string, error) { … }

func shellHandler(w http.ResponseWriter, r *http.Request) { … }

func uploadHandler(w http.ResponseWriter, r *http.Request) { … }

func hostNameHandler(w http.ResponseWriter, r *http.Request) { … }

func redirectHandler(w http.ResponseWriter, r *http.Request) { … }

// udp server supports the hostName, echo and clientIP commands.
func startUDPServer(address string, udpPort int) { … }

// sctp server supports the hostName, echo and clientIP commands.
func startSCTPServer(sctpPort int) { … }

func getHostName() string { … }

func assertNoError(err error, detail string) { … }

func parseAddresses(addresses string) ([]string, error) { … }