container

Documentation

Index

• type JobContainer
  • func NewJobContainer(initialCapacity int) *JobContainer
  • func (c *JobContainer) AddJob(job domain.Job)
  • func (c *JobContainer) All() []domain.Job
  • func (c *JobContainer) Count() int
  • func (c *JobContainer) Get(i int) *domain.Job
  • func (c *JobContainer) JobByName(n string) (*domain.Job, error)
• type NodeContainer
  • func NewNodeContainer(initialCapacity int) *NodeContainer
  • func (c *NodeContainer) AddNode(node domain.Node)
  • func (c *NodeContainer) Count() int
  • func (c *NodeContainer) Get(i int) *domain.Node
  • func (c *NodeContainer) NodeByName(name string) (*domain.Node, error)
  • func (c *NodeContainer) NodeCandidatesForJob(job *domain.Job) []*domain.Node
  • func (c *NodeContainer) NodesByFilter(filter (func(*domain.Node) bool)) []*domain.Node
  • func (c *NodeContainer) NodesForJob(job *domain.Job) []*domain.Node
  • func (c *NodeContainer) NodesWithStatus(status domain.NodeStatus) []*domain.Node

Types

type JobContainer

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

func NewJobContainer

func NewJobContainer(initialCapacity int) *JobContainer

func (*JobContainer) AddJob

func (c *JobContainer) AddJob(job domain.Job)

func (*JobContainer) All

func (c *JobContainer) All() []domain.Job

func (*JobContainer) Count

func (c *JobContainer) Count() int

func (*JobContainer) Get

func (c *JobContainer) Get(i int) *domain.Job

func (*JobContainer) JobByName

func (c *JobContainer) JobByName(n string) (*domain.Job, error)

type NodeContainer

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

func NewNodeContainer

func NewNodeContainer(initialCapacity int) *NodeContainer

func (*NodeContainer) AddNode

func (c *NodeContainer) AddNode(node domain.Node)

func (*NodeContainer) Count

func (c *NodeContainer) Count() int

func (*NodeContainer) Get

func (c *NodeContainer) Get(i int) *domain.Node

func (*NodeContainer) NodeByName

func (c *NodeContainer) NodeByName(name string) (*domain.Node, error)

func (*NodeContainer) NodeCandidatesForJob

func (c *NodeContainer) NodeCandidatesForJob(job *domain.Job) []*domain.Node

func (*NodeContainer) NodesByFilter

func (c *NodeContainer) NodesByFilter(filter func(*domain.Node) bool) []*domain.Node

func (*NodeContainer) NodesForJob

func (c *NodeContainer) NodesForJob(job *domain.Job) []*domain.Node

func (*NodeContainer) NodesWithStatus

func (c *NodeContainer) NodesWithStatus(status domain.NodeStatus) []*domain.Node