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
• type PortForwarder
  • func NewPortForwarder(client *rest.Interface, clientConfig *rest.Config, ...) (*PortForwarder, error)
• type PortPool
  • func (pool *PortPool) FreePort(port int) (err error)
  • 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) (http.RoundTripper, error)

Creates a new HTTP Transport with TLS and Timeouts.

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) ([]byte, int, error)

func HttpMethods

func HttpMethods() []string

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.Mutex

	// 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) (err error)

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.