kubeclient

package

v1.0.0 Latest Latest Go to latest Published: Sep 11, 2025 License: Apache-2.0 Imports: 29 Imported by: 4

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/deckhouse/virtualization

Links

Open Source Insights

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 WebsocketRoundTripper
- func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)

Constants ¶

View Source

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

View Source

const (
	WebsocketMessageBufferSize = 10240
)

Variables ¶

View Source

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

View Source

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) virtualizationv1alpha2.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
	VirtualMachineMACAddresses(namespace string) virtualizationv1alpha2.VirtualMachineMACAddressInterface
	VirtualMachineMACAddressLeases() virtualizationv1alpha2.VirtualMachineMACAddressLeaseInterface
}

func GetClientFromRESTConfig ¶

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

type RoundTripCallback ¶

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

type WebsocketRoundTripper ¶

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

func (*WebsocketRoundTripper) RoundTrip ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL