httputil

Documentation

Index

• Constants
• Variables
• func CreateTransport(auth *config.Auth, transportConfig *http.Transport, timeout time.Duration, ...) (http.RoundTripper, error)
• func GetTLSConfig(auth *config.Auth) (*tls.Config, error)
• func GuessKialiURL(r *http.Request) string
• func HttpGet(url string, auth *config.Auth, timeout time.Duration, ...) ([]byte, int, error)
• func HttpMethods() []string
• func HttpPost(url string, auth *config.Auth, body io.Reader, timeout time.Duration, ...) ([]byte, int, error)
• type PortForwarder
  • func NewPortForwarder(client *rest.Interface, clientConfig *rest.Config, ...) (*PortForwarder, error)
• type PortPool
  • func (pool *PortPool) FreePort(port int)
  • func (pool *PortPool) GetFreePort() int

Constants

const DefaultTimeout = 10 * time.Second

Variables

var Pool = &PortPool{
	LastBusyPort:  13999,
	Mutex:         &sync.Mutex{},
	PortsMap:      map[int]bool{},
	PortRangeInit: 14000,
	PortRangeSize: 1000,
}

Functions

func CreateTransport

func CreateTransport(auth *config.Auth, transportConfig *http.Transport, timeout time.Duration, customHeaders map[string]string) (http.RoundTripper, error)

Creates a new HTTP Transport with TLS, Timeouts, and optional custom headers.

Please remember that setting long timeouts is not recommended as it can make idle connections stay open for as long as 2 * timeout. This should only be done in cases where you know the request is very likely going to be reused at some point in the near future.

func GetTLSConfig

func GetTLSConfig(auth *config.Auth) (*tls.Config, error)

func GuessKialiURL

func GuessKialiURL(r *http.Request) string

func HttpGet

func HttpGet(url string, auth *config.Auth, timeout time.Duration, customHeaders map[string]string) ([]byte, int, error)

func HttpMethods

func HttpMethods() []string

func HttpPost

func HttpPost(url string, auth *config.Auth, body io.Reader, timeout time.Duration, customHeaders map[string]string) ([]byte, int, error)

HttpPost sends an HTTP Post request to the given URL and returns the response body.

Types

type PortForwarder

type PortForwarder interface {
	Start() error
	Stop()
}

func NewPortForwarder

func NewPortForwarder(client *rest.Interface, clientConfig *rest.Config, namespace, pod, address, portMap string, writer io.Writer) (*PortForwarder, error)

type PortPool

type PortPool struct {
	// lastBusyPort is a pointer to the last free port given, therefore is in use.
	LastBusyPort int

	// mutex is the mutex used to solve concurrency problems while managing the port
	Mutex sync.Locker

	// portsMap tracks whether an specific port is busy
	// portsMap[14100] = true => means that port 14100 is busy
	// portsMap[14101] = false => means that port 14101 is free
	PortsMap map[int]bool

	// portRangeInit is the first port number managed in the pool
	PortRangeInit int

	// portRangeSize is the size of the port range.
	// for example, the pool with portRangeSize 100 and portRangeInit 14000 manages
	// the ports from 14000 to 14099.
	PortRangeSize int
}

func (*PortPool) FreePort

func (pool *PortPool) FreePort(port int)

FreePort frees the port and makes it available for being pick to use.

func (*PortPool) GetFreePort

func (pool *PortPool) GetFreePort() int

GetFreePort returns a non-busy port available within the reserved port range (14100 - 14199). The returned port is instantaneously marked as busy until is not freed using the FreePort method.