context

Documentation

Index

• func NewFakeClusterContext(clusterId string) context.ClusterContext
• type FakeClusterContext
  • func (c *FakeClusterContext) AddAnnotation(pod *v1.Pod, annotations map[string]string) error
  • func (c *FakeClusterContext) AddPodEventHandler(handler cache.ResourceEventHandlerFuncs)
  • func (c *FakeClusterContext) DeletePods(pods []*v1.Pod)
  • func (c *FakeClusterContext) GetActiveBatchPods() ([]*v1.Pod, error)
  • func (c *FakeClusterContext) GetAllPods() ([]*v1.Pod, error)
  • func (c *FakeClusterContext) GetBatchPods() ([]*v1.Pod, error)
  • func (c *FakeClusterContext) GetClusterId() string
  • func (c *FakeClusterContext) GetNodes() ([]*v1.Node, error)
  • func (FakeClusterContext) Stop()
  • func (c *FakeClusterContext) SubmitPod(pod *v1.Pod, owner string) (*v1.Pod, error)

Functions

func NewFakeClusterContext

func NewFakeClusterContext(clusterId string) context.ClusterContext

Types

type FakeClusterContext

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

func (*FakeClusterContext) AddAnnotation

func (c *FakeClusterContext) AddAnnotation(pod *v1.Pod, annotations map[string]string) error

func (*FakeClusterContext) AddPodEventHandler

func (c *FakeClusterContext) AddPodEventHandler(handler cache.ResourceEventHandlerFuncs)

func (*FakeClusterContext) DeletePods

func (c *FakeClusterContext) DeletePods(pods []*v1.Pod)

func (*FakeClusterContext) GetActiveBatchPods

func (c *FakeClusterContext) GetActiveBatchPods() ([]*v1.Pod, error)

func (*FakeClusterContext) GetAllPods

func (c *FakeClusterContext) GetAllPods() ([]*v1.Pod, error)

func (*FakeClusterContext) GetBatchPods

func (c *FakeClusterContext) GetBatchPods() ([]*v1.Pod, error)

func (*FakeClusterContext) GetClusterId

func (c *FakeClusterContext) GetClusterId() string

func (*FakeClusterContext) GetNodes

func (c *FakeClusterContext) GetNodes() ([]*v1.Node, error)

func (FakeClusterContext) Stop

func (FakeClusterContext) Stop()

func (*FakeClusterContext) SubmitPod

func (c *FakeClusterContext) SubmitPod(pod *v1.Pod, owner string) (*v1.Pod, error)