utils

Documentation

Index

• Constants
• Variables
• func CalcTerminalColumnsCount() int
• func ExtractBasicAuthLoginAndPassFromRequest(r *http.Request) (login, pass string, err error)
• func ExtractPortAndHost(input string) (port int, host string)
• func GetPortByScheme(scheme string) int
• func GetSchemeByPort(port int) string
• func ReadPassword() ([]byte, error)
• func RemovePortFromURL(rawURL string) string
• func RunSSH(args []string) error
• type Auth
• type BaseClient
  • func (c *BaseClient) Call(req *http.Request, target interface{}, errTarget error) (resp *http.Response, err error)
  • func (c *BaseClient) WithAuth(a Auth)
• type BearerAuth
  • func (ba *BearerAuth) AuthRequest(req *http.Request) error
• type FallbackAuth
  • func (fa *FallbackAuth) AuthRequest(req *http.Request) error
• type Output
• type PasswordScanner
• type PortScheme
• type PromptReader
  • func (pr *PromptReader) Output(text string)
  • func (pr *PromptReader) ReadPassword() (string, error)
  • func (pr *PromptReader) ReadString() (string, error)
• type Scanner
• type StorageBasicAuth
  • func (sba *StorageBasicAuth) AuthRequest(req *http.Request) error
• type WsClient
  • func NewWsClient(ctx context.Context, wsURLBuilder WsURLBuilder) (wsc *WsClient, err error)
  • func (wc *WsClient) Close() error
  • func (wc *WsClient) Read() (msg []byte, err error)
  • func (wc *WsClient) Write(inputMsg []byte) (n int, err error)
• type WsURLBuilder

Constants

const (
	SSH   = "ssh"
	RDP   = "rdp"
	VNC   = "vnc"
	HTTP  = "http"
	HTTPS = "https"
)

const (
	InterruptMessage = "command interrupted, exiting"
)

Variables

var PortSchemesMap = []PortScheme{
	{
		Port:   22,
		Scheme: SSH,
	},
	{
		Port:   3389,
		Scheme: RDP,
	},
	{
		Port:   5900,
		Scheme: VNC,
	},
	{
		Port:   80,
		Scheme: HTTP,
	},
	{
		Port:   443,
		Scheme: HTTPS,
	},
}

Functions

func CalcTerminalColumnsCount

func CalcTerminalColumnsCount() int

func ExtractBasicAuthLoginAndPassFromRequest

func ExtractBasicAuthLoginAndPassFromRequest(r *http.Request) (login, pass string, err error)

func ExtractPortAndHost

func ExtractPortAndHost(input string) (port int, host string)

func GetPortByScheme

func GetPortByScheme(scheme string) int

func GetSchemeByPort

func GetSchemeByPort(port int) string

func ReadPassword

func ReadPassword() ([]byte, error)

func RemovePortFromURL

func RemovePortFromURL(rawURL string) string

func RunSSH

func RunSSH(args []string) error

Types

type Auth

type Auth interface {
	AuthRequest(r *http.Request) error
}

type BaseClient

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

func (*BaseClient) Call

func (c *BaseClient) Call(req *http.Request, target interface{}, errTarget error) (resp *http.Response, err error)

func (*BaseClient) WithAuth

func (c *BaseClient) WithAuth(a Auth)

type BearerAuth

type BearerAuth struct {
	TokenProvider func() (string, error)
}

func (*BearerAuth) AuthRequest

func (ba *BearerAuth) AuthRequest(req *http.Request) error

type FallbackAuth

type FallbackAuth struct {
	PrimaryAuth  Auth
	FallbackAuth Auth
}

func (*FallbackAuth) AuthRequest

func (fa *FallbackAuth) AuthRequest(req *http.Request) error

type Output

type Output struct {
	Payload []byte
	Error   error
}

type PasswordScanner

type PasswordScanner func() ([]byte, error)

type PortScheme

type PortScheme struct {
	Port   int
	Scheme string
}

type PromptReader

type PromptReader struct {
	Sc              Scanner
	SigChan         chan os.Signal
	PasswordScanner PasswordScanner
}

func (*PromptReader) Output

func (pr *PromptReader) Output(text string)

func (*PromptReader) ReadPassword

func (pr *PromptReader) ReadPassword() (string, error)

func (*PromptReader) ReadString

func (pr *PromptReader) ReadString() (string, error)

type Scanner

type Scanner interface {
	Scan() bool
	Text() string
	Err() error
}

type StorageBasicAuth

type StorageBasicAuth struct {
	AuthProvider func() (login, pass string, err error)
}

func (*StorageBasicAuth) AuthRequest

func (sba *StorageBasicAuth) AuthRequest(req *http.Request) error

type WsClient

type WsClient struct {
	WsURLBuilder WsURLBuilder
	Conn         *websocket.Conn
}

func NewWsClient

func NewWsClient(ctx context.Context, wsURLBuilder WsURLBuilder) (wsc *WsClient, err error)

func (*WsClient) Close

func (wc *WsClient) Close() error

func (*WsClient) Read

func (wc *WsClient) Read() (msg []byte, err error)

func (*WsClient) Write

func (wc *WsClient) Write(inputMsg []byte) (n int, err error)

type WsURLBuilder

type WsURLBuilder func(ctx context.Context) (url string, err error)