memory

Documentation

Index

• func NewJobScalingPolicies() backend.PolicyBackend
• type PolicyBackend
  • func (p *PolicyBackend) DeleteJobGroupPolicy(job, group string) error
  • func (p *PolicyBackend) DeleteJobPolicy(job string) error
  • func (p *PolicyBackend) GetJobGroupPolicy(job, group string) (*policy.GroupScalingPolicy, error)
  • func (p *PolicyBackend) GetJobPolicy(job string) (map[string]*policy.GroupScalingPolicy, error)
  • func (p *PolicyBackend) GetPolicies() (map[string]map[string]*policy.GroupScalingPolicy, error)
  • func (p *PolicyBackend) PutJobGroupPolicy(job, group string, policies *policy.GroupScalingPolicy) error
  • func (p *PolicyBackend) PutJobPolicy(job string, policies map[string]*policy.GroupScalingPolicy) error

Functions

func NewJobScalingPolicies

func NewJobScalingPolicies() backend.PolicyBackend

Types

type PolicyBackend

type PolicyBackend struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*PolicyBackend) DeleteJobGroupPolicy

func (p *PolicyBackend) DeleteJobGroupPolicy(job, group string) error

func (*PolicyBackend) DeleteJobPolicy

func (p *PolicyBackend) DeleteJobPolicy(job string) error

func (*PolicyBackend) GetJobGroupPolicy

func (p *PolicyBackend) GetJobGroupPolicy(job, group string) (*policy.GroupScalingPolicy, error)

func (*PolicyBackend) GetJobPolicy

func (p *PolicyBackend) GetJobPolicy(job string) (map[string]*policy.GroupScalingPolicy, error)

func (*PolicyBackend) GetPolicies

func (p *PolicyBackend) GetPolicies() (map[string]map[string]*policy.GroupScalingPolicy, error)

func (*PolicyBackend) PutJobGroupPolicy

func (p *PolicyBackend) PutJobGroupPolicy(job, group string, policies *policy.GroupScalingPolicy) error

func (*PolicyBackend) PutJobPolicy

func (p *PolicyBackend) PutJobPolicy(job string, policies map[string]*policy.GroupScalingPolicy) error