test

Documentation

Index

• type Cluster
  • func (c *Cluster) Allocate(ctx context.Context, req reflow.Requirements, labels pool.Labels) (pool.Alloc, error)
  • func (c *Cluster) CanAllocate(r reflow.Resources) (bool, error)
  • func (r *Cluster) Flags(flags *flag.FlagSet)
  • func (c *Cluster) GetName() string
  • func (c *Cluster) Init() error
  • func (c *Cluster) MaxAlloc() reflow.Resources

Types

type Cluster

type Cluster struct {
	*ec2cluster.Cluster
}

Cluster is a fake cluster infra provider and should be used only in tests.

func (*Cluster) Allocate

func (c *Cluster) Allocate(ctx context.Context, req reflow.Requirements, labels pool.Labels) (pool.Alloc, error)

Allocate is a no op.

func (*Cluster) CanAllocate

func (c *Cluster) CanAllocate(r reflow.Resources) (bool, error)

func (*Cluster) Flags

func (r *Cluster) Flags(flags *flag.FlagSet)

Flags implements infra.Provider

func (*Cluster) GetName

func (c *Cluster) GetName() string

GetName implements runner.Cluster

func (*Cluster) Init

func (c *Cluster) Init() error

Init implements infra.Provider.

func (*Cluster) MaxAlloc

func (c *Cluster) MaxAlloc() reflow.Resources

MaxAlloc returns the max resources which can be obtained in a single alloc from this cluster.