kubeclient

Documentation

Index

• Constants
• Variables
• func Copy(dst, src *websocket.Conn) (int64, error)
• func CopyFrom(dst io.Writer, src *websocket.Conn) (written int64, err error)
• func CopyTo(dst *websocket.Conn, src io.Reader) (written int64, err error)
• func DefaultClientConfig(flags *pflag.FlagSet) clientcmd.ClientConfig
• func Dial(address string, tlsConfig *tls.Config) (*websocket.Conn, *http.Response, error)
• func NewUpgrader() *websocket.Upgrader
• func NewWebsocketStreamer(conn *websocket.Conn, done chan struct{}) *wsStreamer
• func RequestFromConfig(config *rest.Config, resource, name, namespace, subresource string, ...) (*http.Request, error)
• type AsyncSubresourceError
  • func (a *AsyncSubresourceError) Error() string
  • func (a *AsyncSubresourceError) GetStatusCode() int
• type Client
  • func GetClientFromRESTConfig(config *rest.Config) (Client, error)
• type RoundTripCallback
• type SerialConsoleOptions
• type StreamInterface
• type StreamOptions
• type VirtualMachineInterface
• type WebsocketRoundTripper
  • func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)

Constants

const PlainStreamProtocolName = "plain.virtualization.deckhouse.io"

const (
	WebsocketMessageBufferSize = 10240
)

Variables

var (
	Scheme = runtime.NewScheme()
	Codecs = serializer.NewCodecFactory(Scheme)
)

var GetClientFromClientConfig = func(cmdConfig clientcmd.ClientConfig) (Client, error) {
	config, err := cmdConfig.ClientConfig()
	if err != nil {
		return nil, err
	}
	return GetClientFromRESTConfig(config)
}

Functions

func Copy

func Copy(dst, src *websocket.Conn) (int64, error)

func CopyFrom

func CopyFrom(dst io.Writer, src *websocket.Conn) (written int64, err error)

func CopyTo

func CopyTo(dst *websocket.Conn, src io.Reader) (written int64, err error)

func DefaultClientConfig

func DefaultClientConfig(flags *pflag.FlagSet) clientcmd.ClientConfig

func Dial

func Dial(address string, tlsConfig *tls.Config) (*websocket.Conn, *http.Response, error)

func NewUpgrader

func NewUpgrader() *websocket.Upgrader

func NewWebsocketStreamer

func NewWebsocketStreamer(conn *websocket.Conn, done chan struct{}) *wsStreamer

func RequestFromConfig

func RequestFromConfig(config *rest.Config, resource, name, namespace, subresource string,
	queryParams url.Values) (*http.Request, error)

Types

type AsyncSubresourceError

type AsyncSubresourceError struct {
	StatusCode int
	// contains filtered or unexported fields
}

func (*AsyncSubresourceError) Error

func (a *AsyncSubresourceError) Error() string

func (*AsyncSubresourceError) GetStatusCode

func (a *AsyncSubresourceError) GetStatusCode() int

type Client

type Client interface {
	ClusterVirtualImages() virtualizationv1alpha2.ClusterVirtualImageInterface
	VirtualMachines(namespace string) VirtualMachineInterface
	VirtualImages(namespace string) virtualizationv1alpha2.VirtualImageInterface
	VirtualDisks(namespace string) virtualizationv1alpha2.VirtualDiskInterface
	VirtualMachineBlockDeviceAttachments(namespace string) virtualizationv1alpha2.VirtualMachineBlockDeviceAttachmentInterface
	VirtualMachineIPAddresses(namespace string) virtualizationv1alpha2.VirtualMachineIPAddressInterface
	VirtualMachineIPAddressLeases() virtualizationv1alpha2.VirtualMachineIPAddressLeaseInterface
	VirtualMachineOperations(namespace string) virtualizationv1alpha2.VirtualMachineOperationInterface
	VirtualMachineClasses() virtualizationv1alpha2.VirtualMachineClassInterface
}

func GetClientFromRESTConfig

func GetClientFromRESTConfig(config *rest.Config) (Client, error)

type RoundTripCallback

type RoundTripCallback func(conn *websocket.Conn, resp *http.Response, err error) error

type SerialConsoleOptions

type SerialConsoleOptions struct {
	ConnectionTimeout time.Duration
}

type StreamInterface

type StreamInterface interface {
	Stream(options StreamOptions) error
	AsConn() net.Conn
}

type StreamOptions

type StreamOptions struct {
	In  io.Reader
	Out io.Writer
}

type VirtualMachineInterface

type VirtualMachineInterface interface {
	virtualizationv1alpha2.VirtualMachineInterface
	SerialConsole(name string, options *SerialConsoleOptions) (StreamInterface, error)
	VNC(name string) (StreamInterface, error)
	PortForward(name string, opts v1alpha2.VirtualMachinePortForward) (StreamInterface, error)
	Freeze(ctx context.Context, name string, opts v1alpha2.VirtualMachineFreeze) error
	Unfreeze(ctx context.Context, name string) error
	Migrate(ctx context.Context, name string, opts v1alpha2.VirtualMachineMigrate) error
}

type WebsocketRoundTripper

type WebsocketRoundTripper struct {
	Dialer *websocket.Dialer
	Do     RoundTripCallback
}

func (*WebsocketRoundTripper) RoundTrip

func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)