mock

Documentation

Index

• type MockConfig
• type MockLegacyProvider
  • func NewMockLegacyProvider(providerConfig, nodeName, operatingSystem string, internalIP string, ...) (*MockLegacyProvider, error)
  • func NewMockLegacyProviderMockConfig(config MockConfig, nodeName, operatingSystem string, internalIP string, ...) (*MockLegacyProvider, error)
  • func (p *MockLegacyProvider) Capacity(ctx context.Context) v1.ResourceList
  • func (p *MockLegacyProvider) CreatePod(ctx context.Context, pod *v1.Pod) error
  • func (p *MockLegacyProvider) DeletePod(ctx context.Context, pod *v1.Pod) (err error)
  • func (p *MockLegacyProvider) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, ...) (io.ReadCloser, error)
  • func (p *MockLegacyProvider) GetPod(ctx context.Context, namespace, name string) (pod *v1.Pod, err error)
  • func (p *MockLegacyProvider) GetPodFullName(namespace string, pod string) string
  • func (p *MockLegacyProvider) GetPodStatus(ctx context.Context, namespace, name string) (*v1.PodStatus, error)
  • func (p *MockLegacyProvider) GetPods(ctx context.Context) ([]*v1.Pod, error)
  • func (p *MockLegacyProvider) GetStatsSummary(ctx context.Context) (*stats.Summary, error)
  • func (p *MockLegacyProvider) NodeAddresses(ctx context.Context) []v1.NodeAddress
  • func (p *MockLegacyProvider) NodeConditions(ctx context.Context) []v1.NodeCondition
  • func (p *MockLegacyProvider) NodeDaemonEndpoints(ctx context.Context) *v1.NodeDaemonEndpoints
  • func (p *MockLegacyProvider) OperatingSystem() string
  • func (p *MockLegacyProvider) RunInContainer(ctx context.Context, namespace, name, container string, cmd []string, ...) error
  • func (p *MockLegacyProvider) UpdatePod(ctx context.Context, pod *v1.Pod) error
• type MockProvider
  • func NewMockProvider(providerConfig, nodeName, operatingSystem string, internalIP string, ...) (*MockProvider, error)
  • func NewMockProviderMockConfig(config MockConfig, nodeName, operatingSystem string, internalIP string, ...) (*MockProvider, error)
  • func (p *MockProvider) NotifyPods(ctx context.Context, notifier func(*v1.Pod))

Types

type MockConfig

type MockConfig struct {
	CPU    string `json:"cpu,omitempty"`
	Memory string `json:"memory,omitempty"`
	Pods   string `json:"pods,omitempty"`
}

MockConfig contains a mock virtual-kubelet's configurable parameters.

type MockLegacyProvider

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

MockLegacyProvider implements the virtual-kubelet provider interface and stores pods in memory.

func NewMockLegacyProvider

func NewMockLegacyProvider(providerConfig, nodeName, operatingSystem string, internalIP string, daemonEndpointPort int32) (*MockLegacyProvider, error)

NewMockLegacyProvider creates a new MockLegacyProvider

func NewMockLegacyProviderMockConfig

func NewMockLegacyProviderMockConfig(config MockConfig, nodeName, operatingSystem string, internalIP string, daemonEndpointPort int32) (*MockLegacyProvider, error)

NewMockProviderMockConfig creates a new MockLegacyProvider. Mock legacy provider does not implement the new asynchronous podnotifier interface

func (*MockLegacyProvider) Capacity

func (p *MockLegacyProvider) Capacity(ctx context.Context) v1.ResourceList

Capacity returns a resource list containing the capacity limits.

func (*MockLegacyProvider) CreatePod

func (p *MockLegacyProvider) CreatePod(ctx context.Context, pod *v1.Pod) error

CreatePod accepts a Pod definition and stores it in memory.

func (*MockLegacyProvider) DeletePod

func (p *MockLegacyProvider) DeletePod(ctx context.Context, pod *v1.Pod) (err error)

DeletePod deletes the specified pod out of memory.

func (*MockLegacyProvider) GetContainerLogs

func (p *MockLegacyProvider) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, opts api.ContainerLogOpts) (io.ReadCloser, error)

GetContainerLogs retrieves the logs of a container by name from the provider.

func (*MockLegacyProvider) GetPod

func (p *MockLegacyProvider) GetPod(ctx context.Context, namespace, name string) (pod *v1.Pod, err error)

GetPod returns a pod by name that is stored in memory.

func (*MockLegacyProvider) GetPodFullName

func (p *MockLegacyProvider) GetPodFullName(namespace string, pod string) string

Get full pod name as defined in the provider context TODO: Implementation

func (*MockLegacyProvider) GetPodStatus

func (p *MockLegacyProvider) GetPodStatus(ctx context.Context, namespace, name string) (*v1.PodStatus, error)

GetPodStatus returns the status of a pod by name that is "running". returns nil if a pod by that name is not found.

func (*MockLegacyProvider) GetPods

func (p *MockLegacyProvider) GetPods(ctx context.Context) ([]*v1.Pod, error)

GetPods returns a list of all pods known to be "running".

func (*MockLegacyProvider) GetStatsSummary

func (p *MockLegacyProvider) GetStatsSummary(ctx context.Context) (*stats.Summary, error)

GetStatsSummary returns dummy stats for all pods known by this provider.

func (*MockLegacyProvider) NodeAddresses

func (p *MockLegacyProvider) NodeAddresses(ctx context.Context) []v1.NodeAddress

NodeAddresses returns a list of addresses for the node status within Kubernetes.

func (*MockLegacyProvider) NodeConditions

func (p *MockLegacyProvider) NodeConditions(ctx context.Context) []v1.NodeCondition

NodeConditions returns a list of conditions (Ready, OutOfDisk, etc), for updates to the node status within Kubernetes.

func (*MockLegacyProvider) NodeDaemonEndpoints

func (p *MockLegacyProvider) NodeDaemonEndpoints(ctx context.Context) *v1.NodeDaemonEndpoints

NodeDaemonEndpoints returns NodeDaemonEndpoints for the node status within Kubernetes.

func (*MockLegacyProvider) OperatingSystem

func (p *MockLegacyProvider) OperatingSystem() string

func (*MockLegacyProvider) RunInContainer

func (p *MockLegacyProvider) RunInContainer(ctx context.Context, namespace, name, container string, cmd []string, attach api.AttachIO) error

RunInContainer executes a command in a container in the pod, copying data between in/out/err and the container's stdin/stdout/stderr.

func (*MockLegacyProvider) UpdatePod

func (p *MockLegacyProvider) UpdatePod(ctx context.Context, pod *v1.Pod) error

UpdatePod accepts a Pod definition and updates its reference.

type MockProvider

type MockProvider struct {
	*MockLegacyProvider
}

MockProvider is like MockLegacyProvider, but implements the PodNotifier interface

func NewMockProvider

func NewMockProvider(providerConfig, nodeName, operatingSystem string, internalIP string, daemonEndpointPort int32) (*MockProvider, error)

NewMockProvider creates a new MockProvider, which implements the PodNotifier interface

func NewMockProviderMockConfig

func NewMockProviderMockConfig(config MockConfig, nodeName, operatingSystem string, internalIP string, daemonEndpointPort int32) (*MockProvider, error)

NewMockProviderMockConfig creates a new MockProvider with the given config

func (*MockProvider) NotifyPods

func (p *MockProvider) NotifyPods(ctx context.Context, notifier func(*v1.Pod))

NotifyPods is called to set a pod notifier callback function. This should be called before any operations are done within the provider.