vmserver

package
v0.0.0-...-0cd89e8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 11, 2016 License: GPL-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// the mark-for-masquerade chain
	// TODO: clean up this logic in kube-proxy
	KubeMarkMasqChain utiliptables.Chain = "KUBE-MARK-MASQ"

	// the mark-for-drop chain
	KubeMarkDropChain utiliptables.Chain = "KUBE-MARK-DROP"

	// kubernetes postrouting rules
	KubePostroutingChain utiliptables.Chain = "KUBE-POSTROUTING"

	// kubernetes firewall rules
	KubeFirewallChain utiliptables.Chain = "KUBE-FIREWALL"
)

Variables

View Source 
var (
	MasqueradeBit = int32(14)
	DropBit       = int32(15)
	OOMScoreAdj   = int32(qos.KubeProxyOOMScoreAdj)
)
View Source 
var (
	ContainerProviders containerProviderRegistry
)

Functions

This section is empty.

Types

type ContainerProvider 

type ContainerProvider interface {
	CreateContainer(req *kubeapi.CreateContainerRequest) (*kubeapi.CreateContainerResponse, error)
	StartContainer(req *kubeapi.StartContainerRequest) (*kubeapi.StartContainerResponse, error)
	StopContainer(req *kubeapi.StopContainerRequest) (*kubeapi.StopContainerResponse, error)
	RemoveContainer(req *kubeapi.RemoveContainerRequest) (*kubeapi.RemoveContainerResponse, error)
	ListContainers(req *kubeapi.ListContainersRequest) (*kubeapi.ListContainersResponse, error)
	ContainerStatus(req *kubeapi.ContainerStatusRequest) (*kubeapi.ContainerStatusResponse, error)
	ExecSync(req *kubeapi.ExecSyncRequest) (*kubeapi.ExecSyncResponse, error)
	GetStreamingRuntime() streaming.Runtime
	Logs(req *common.LogsRequest, stream common.VMServer_LogsServer) error
}

func NewContainerProvider 

func NewContainerProvider(provider *string) (ContainerProvider, error)

type VMserver 

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

func NewVMServer 

func NewVMServer(cert *string, key *string, contProvider ContainerProvider) (*VMserver, error)

func (*VMserver) AddRoute 

func (m *VMserver) AddRoute(ctx context.Context, req *common.AddRouteRequest) (*common.AddRouteResponse, error)

func (*VMserver) Attach 

func (m *VMserver) Attach(ctx context.Context, req *kubeapi.AttachRequest) (*kubeapi.AttachResponse, error)

func (*VMserver) ContainerStats 

func (m *VMserver) ContainerStats(ctx context.Context, req *kubeapi.ContainerStatsRequest) (*kubeapi.ContainerStatsResponse, error)

TODO

func (*VMserver) ContainerStatus 

func (m *VMserver) ContainerStatus(ctx context.Context, req *kubeapi.ContainerStatusRequest) (*kubeapi.ContainerStatusResponse, error)

func (*VMserver) CopyFile 

func (m *VMserver) CopyFile(ctx context.Context, req *common.CopyFileRequest) (*common.CopyFileResponse, error)

func (*VMserver) CreateContainer 

func (m *VMserver) CreateContainer(ctx context.Context, req *kubeapi.CreateContainerRequest) (*kubeapi.CreateContainerResponse, error)

func (*VMserver) Exec 

func (m *VMserver) Exec(ctx context.Context, req *kubeapi.ExecRequest) (*kubeapi.ExecResponse, error)

func (*VMserver) ExecSync 

func (m *VMserver) ExecSync(ctx context.Context, req *kubeapi.ExecSyncRequest) (*kubeapi.ExecSyncResponse, error)

func (*VMserver) GetMetrics 

func (m *VMserver) GetMetrics(ctx context.Context, req *common.GetMetricsRequest) (*common.GetMetricsResponse, error)

func (*VMserver) GetPodIP 

func (m *VMserver) GetPodIP(ctx context.Context, req *common.GetIPRequest) (*common.GetIPResponse, error)

func (*VMserver) GetSandboxConfig 

func (m *VMserver) GetSandboxConfig(ctx context.Context, req *common.GetSandboxConfigRequest) (*common.GetSandboxConfigResponse, error)

func (*VMserver) ListContainerStats 

func (m *VMserver) ListContainerStats(ctx context.Context, req *kubeapi.ListContainerStatsRequest) (*kubeapi.ListContainerStatsResponse, error)

func (*VMserver) ListContainers 

func (m *VMserver) ListContainers(ctx context.Context, req *kubeapi.ListContainersRequest) (*kubeapi.ListContainersResponse, error)

func (*VMserver) ListPodSandbox 

func (m *VMserver) ListPodSandbox(ctx context.Context, req *kubeapi.ListPodSandboxRequest) (*kubeapi.ListPodSandboxResponse, error)

func (*VMserver) Logs 

func (m *VMserver) Logs(req *common.LogsRequest, stream common.VMServer_LogsServer) error

func (*VMserver) MountFs 

func (m *VMserver) MountFs(ctx context.Context, req *common.MountFsRequest) (*common.MountFsResponse, error)

func (*VMserver) PodSandboxStatus 

func (m *VMserver) PodSandboxStatus(ctx context.Context, req *kubeapi.PodSandboxStatusRequest) (*kubeapi.PodSandboxStatusResponse, error)

func (*VMserver) PortForward 

func (m *VMserver) PortForward(ctx context.Context, req *kubeapi.PortForwardRequest) (*kubeapi.PortForwardResponse, error)

In traditional kubernetes land this has to nsenter the network namespace of the pod, in Infranetes, there's only one namespace

func (*VMserver) RemoveContainer 

func (m *VMserver) RemoveContainer(ctx context.Context, req *kubeapi.RemoveContainerRequest) (*kubeapi.RemoveContainerResponse, error)

func (*VMserver) RemovePodSandbox 

func (m *VMserver) RemovePodSandbox(ctx context.Context, req *kubeapi.RemovePodSandboxRequest) (*kubeapi.RemovePodSandboxResponse, error)

func (*VMserver) RunCmd 

func (m *VMserver) RunCmd(ctx context.Context, req *common.RunCmdRequest) (*common.RunCmdResponse, error)

func (*VMserver) RunPodSandbox 

func (m *VMserver) RunPodSandbox(ctx context.Context, req *kubeapi.RunPodSandboxRequest) (*kubeapi.RunPodSandboxResponse, error)

func (*VMserver) Serve 

func (s *VMserver) Serve(port int) error

func (*VMserver) SetHostname 

func (m *VMserver) SetHostname(ctx context.Context, req *common.SetHostnameRequest) (*common.SetHostnameResponse, error)

func (*VMserver) SetPodIP 

func (m *VMserver) SetPodIP(ctx context.Context, req *common.SetIPRequest) (*common.SetIPResponse, error)

func (*VMserver) SetSandboxConfig 

func (m *VMserver) SetSandboxConfig(ctx context.Context, req *common.SetSandboxConfigRequest) (*common.SetSandboxConfigResponse, error)

func (*VMserver) StartContainer 

func (m *VMserver) StartContainer(ctx context.Context, req *kubeapi.StartContainerRequest) (*kubeapi.StartContainerResponse, error)

func (*VMserver) StartProxy 

func (m *VMserver) StartProxy(ctx context.Context, req *common.StartProxyRequest) (*common.StartProxyResponse, error)

func (*VMserver) Status 

func (m *VMserver) Status(ctx context.Context, req *kubeapi.StatusRequest) (*kubeapi.StatusResponse, error)

func (*VMserver) StopContainer 

func (m *VMserver) StopContainer(ctx context.Context, req *kubeapi.StopContainerRequest) (*kubeapi.StopContainerResponse, error)

func (*VMserver) StopPodSandbox 

func (m *VMserver) StopPodSandbox(ctx context.Context, req *kubeapi.StopPodSandboxRequest) (*kubeapi.StopPodSandboxResponse, error)

func (*VMserver) UnmountFs 

func (m *VMserver) UnmountFs(ctx context.Context, req *common.UnmountFsRequest) (*common.UnmountFsResponse, error)

func (*VMserver) UpdateRuntimeConfig 

func (m *VMserver) UpdateRuntimeConfig(ctx context.Context, req *kubeapi.UpdateRuntimeConfigRequest) (*kubeapi.UpdateRuntimeConfigResponse, error)

func (*VMserver) Version 

func (s *VMserver) Version(ctx context.Context, req *kubeapi.VersionRequest) (*kubeapi.VersionResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.