Documentation
¶
Index ¶
- Constants
- func GetCpuLimitFromCgroup(cgroupParent string) (int32, error)
- func GetMemeoryLimitFromCgroup(cgroupParent string) (int32, error)
- func NewClientTLSFromFile(certFile, serverName string) (credentials.TransportCredentials, error)
- func ParseCommonAnnotations(annotations map[string]string) *annotationConfig
- type Client
- type PodData
- func (p *PodData) AddContLogPath(cont string, path string)
- func (p *PodData) AttachVol(vol string) (string, error)
- func (p *PodData) Filter(filter *kubeapi.PodSandboxFilter) (bool, string)
- func (p *PodData) GetContLogPath(cont string) (string, bool)
- func (p *PodData) GetPodState() kubeapi.PodSandboxState
- func (p *PodData) GetSandbox() *kubeapi.PodSandbox
- func (p *PodData) Lock()
- func (p *PodData) NeedMount(vol string) bool
- func (p *PodData) PodStatus() *kubeapi.PodSandboxStatus
- func (p *PodData) RLock()
- func (p *PodData) RUnlock()
- func (p *PodData) RemovePod() error
- func (p *PodData) StopPod() error
- func (p *PodData) Unlock()
- func (p *PodData) UpdatePodState()
- type ProviderData
- type RealClient
- func (c *RealClient) AddRoute(req *common.AddRouteRequest) (*common.AddRouteResponse, error)
- func (c *RealClient) Attach(req *kubeapi.AttachRequest) (*kubeapi.AttachResponse, error)
- func (c *RealClient) Close()
- func (c *RealClient) ContainerStatus(req *kubeapi.ContainerStatusRequest) (*kubeapi.ContainerStatusResponse, error)
- func (c *RealClient) CopyFile(file string) error
- func (c *RealClient) CreateContainer(req *kubeapi.CreateContainerRequest) (*kubeapi.CreateContainerResponse, error)
- func (c *RealClient) Exec(req *kubeapi.ExecRequest) (*kubeapi.ExecResponse, error)
- func (c *RealClient) ExecSync(req *kubeapi.ExecSyncRequest) (*kubeapi.ExecSyncResponse, error)
- func (c *RealClient) GetMetric(req *common.GetMetricsRequest) (*common.GetMetricsResponse, error)
- func (c *RealClient) GetPodIP() (string, error)
- func (c *RealClient) GetSandboxConfig() (*kubeapi.PodSandboxConfig, error)
- func (c *RealClient) ListContainers(req *kubeapi.ListContainersRequest) (*kubeapi.ListContainersResponse, error)
- func (c *RealClient) MountFs(source string, target string, fstype string, readOnly bool) error
- func (c *RealClient) PortForward(req *kubeapi.PortForwardRequest) (*kubeapi.PortForwardResponse, error)
- func (c *RealClient) Ready() error
- func (c *RealClient) RemoveContainer(req *kubeapi.RemoveContainerRequest) (*kubeapi.RemoveContainerResponse, error)
- func (c *RealClient) RunCmd(req *common.RunCmdRequest) error
- func (c *RealClient) SaveLogs(container string, path string) error
- func (c *RealClient) SetHostname(hostname string) error
- func (c *RealClient) SetPodIP(ip string) error
- func (c *RealClient) SetSandboxConfig(config *kubeapi.PodSandboxConfig) error
- func (c *RealClient) StartContainer(req *kubeapi.StartContainerRequest) (*kubeapi.StartContainerResponse, error)
- func (c *RealClient) StartProxy() error
- func (c *RealClient) StopContainer(req *kubeapi.StopContainerRequest) (*kubeapi.StopContainerResponse, error)
- func (c *RealClient) UnmountFs(target string) error
- func (c *RealClient) Version() (*kubeapi.VersionResponse, error)
Constants ¶
View Source
const (
MiB = 1024 * 1024
)
Variables ¶
This section is empty.
Functions ¶
func GetCpuLimitFromCgroup ¶
func GetMemeoryLimitFromCgroup ¶
GetMemeoryLimitFromCgroup get the memory limit from given cgroupParent
func NewClientTLSFromFile ¶
func NewClientTLSFromFile(certFile, serverName string) (credentials.TransportCredentials, error)
NewClientTLSFromFile constructs a TLS from the input certificate file for client.
func ParseCommonAnnotations ¶
Types ¶
type Client ¶
type Client 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) Exec(req *kubeapi.ExecRequest) (*kubeapi.ExecResponse, error) Attach(req *kubeapi.AttachRequest) (*kubeapi.AttachResponse, error) PortForward(req *kubeapi.PortForwardRequest) (*kubeapi.PortForwardResponse, error) StartProxy() error RunCmd(req *common.RunCmdRequest) error SetPodIP(ip string) error GetPodIP() (string, error) SetSandboxConfig(config *kubeapi.PodSandboxConfig) error GetSandboxConfig() (*kubeapi.PodSandboxConfig, error) CopyFile(file string) error MountFs(source string, target string, fstype string, readOnly bool) error UnmountFs(target string) error SetHostname(hostname string) error Close() Version() (*kubeapi.VersionResponse, error) Ready() error SaveLogs(container string, path string) error GetMetric(req *common.GetMetricsRequest) (*common.GetMetricsResponse, error) AddRoute(req *common.AddRouteRequest) (*common.AddRouteResponse, error) }
func CreateFakeClient ¶
func CreateRealClient ¶
type PodData ¶
type PodData struct { VM lvm.VirtualMachine Id string Metadata *kubeapi.PodSandboxMetadata Annotations map[string]string Labels map[string]string CreatedAt int64 Ip string Linux *kubeapi.LinuxPodSandboxConfig Client Client PodState kubeapi.PodSandboxState Booted bool BootLock sync.Mutex ProviderData ProviderData ContLogs map[string]string // contains filtered or unexported fields }
func NewPodData ¶
func NewPodData(vm lvm.VirtualMachine, id string, meta *kubeapi.PodSandboxMetadata, anno map[string]string, labels map[string]string, ip string, linux *kubeapi.LinuxPodSandboxConfig, client Client, booted bool, providerData ProviderData) *PodData
func (*PodData) AddContLogPath ¶
func (*PodData) GetPodState ¶
func (p *PodData) GetPodState() kubeapi.PodSandboxState
func (*PodData) GetSandbox ¶
func (p *PodData) GetSandbox() *kubeapi.PodSandbox
func (*PodData) PodStatus ¶
func (p *PodData) PodStatus() *kubeapi.PodSandboxStatus
func (*PodData) UpdatePodState ¶
func (p *PodData) UpdatePodState()
type ProviderData ¶
type RealClient ¶
type RealClient struct {
// contains filtered or unexported fields
}
func (*RealClient) AddRoute ¶
func (c *RealClient) AddRoute(req *common.AddRouteRequest) (*common.AddRouteResponse, error)
func (*RealClient) Attach ¶
func (c *RealClient) Attach(req *kubeapi.AttachRequest) (*kubeapi.AttachResponse, error)
func (*RealClient) Close ¶
func (c *RealClient) Close()
func (*RealClient) ContainerStatus ¶
func (c *RealClient) ContainerStatus(req *kubeapi.ContainerStatusRequest) (*kubeapi.ContainerStatusResponse, error)
func (*RealClient) CopyFile ¶
func (c *RealClient) CopyFile(file string) error
func (*RealClient) CreateContainer ¶
func (c *RealClient) CreateContainer(req *kubeapi.CreateContainerRequest) (*kubeapi.CreateContainerResponse, error)
func (*RealClient) Exec ¶
func (c *RealClient) Exec(req *kubeapi.ExecRequest) (*kubeapi.ExecResponse, error)
func (*RealClient) ExecSync ¶
func (c *RealClient) ExecSync(req *kubeapi.ExecSyncRequest) (*kubeapi.ExecSyncResponse, error)
func (*RealClient) GetMetric ¶
func (c *RealClient) GetMetric(req *common.GetMetricsRequest) (*common.GetMetricsResponse, error)
func (*RealClient) GetPodIP ¶
func (c *RealClient) GetPodIP() (string, error)
func (*RealClient) GetSandboxConfig ¶
func (c *RealClient) GetSandboxConfig() (*kubeapi.PodSandboxConfig, error)
func (*RealClient) ListContainers ¶
func (c *RealClient) ListContainers(req *kubeapi.ListContainersRequest) (*kubeapi.ListContainersResponse, error)
func (*RealClient) PortForward ¶
func (c *RealClient) PortForward(req *kubeapi.PortForwardRequest) (*kubeapi.PortForwardResponse, error)
func (*RealClient) Ready ¶
func (c *RealClient) Ready() error
func (*RealClient) RemoveContainer ¶
func (c *RealClient) RemoveContainer(req *kubeapi.RemoveContainerRequest) (*kubeapi.RemoveContainerResponse, error)
func (*RealClient) RunCmd ¶
func (c *RealClient) RunCmd(req *common.RunCmdRequest) error
func (*RealClient) SetHostname ¶
func (c *RealClient) SetHostname(hostname string) error
func (*RealClient) SetPodIP ¶
func (c *RealClient) SetPodIP(ip string) error
func (*RealClient) SetSandboxConfig ¶
func (c *RealClient) SetSandboxConfig(config *kubeapi.PodSandboxConfig) error
func (*RealClient) StartContainer ¶
func (c *RealClient) StartContainer(req *kubeapi.StartContainerRequest) (*kubeapi.StartContainerResponse, error)
func (*RealClient) StartProxy ¶
func (c *RealClient) StartProxy() error
func (*RealClient) StopContainer ¶
func (c *RealClient) StopContainer(req *kubeapi.StopContainerRequest) (*kubeapi.StopContainerResponse, error)
func (*RealClient) UnmountFs ¶
func (c *RealClient) UnmountFs(target string) error
func (*RealClient) Version ¶
func (c *RealClient) Version() (*kubeapi.VersionResponse, error)
Click to show internal directories.
Click to hide internal directories.