memory

Documentation

Index

• func NewStateBackend() scale.Backend
• type StateBackend
  • func (s *StateBackend) GetLatestScalingEvent(job, group string) (*state.ScalingEvent, error)
  • func (s *StateBackend) GetLatestScalingEvents() (map[string]*state.ScalingEvent, error)
  • func (s *StateBackend) GetScalingEvent(id uuid.UUID) (map[string]*state.ScalingEvent, error)
  • func (s *StateBackend) GetScalingEvents() (map[uuid.UUID]map[string]*state.ScalingEvent, error)
  • func (s *StateBackend) PutScalingEvent(job string, event *state.ScalingEventMessage) error
  • func (s *StateBackend) RunGarbageCollection()

Functions

func NewStateBackend

func NewStateBackend() scale.Backend

Types

type StateBackend

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

func (*StateBackend) GetLatestScalingEvent

func (s *StateBackend) GetLatestScalingEvent(job, group string) (*state.ScalingEvent, error)

func (*StateBackend) GetLatestScalingEvents

func (s *StateBackend) GetLatestScalingEvents() (map[string]*state.ScalingEvent, error)

func (*StateBackend) GetScalingEvent

func (s *StateBackend) GetScalingEvent(id uuid.UUID) (map[string]*state.ScalingEvent, error)

func (*StateBackend) GetScalingEvents

func (s *StateBackend) GetScalingEvents() (map[uuid.UUID]map[string]*state.ScalingEvent, error)

func (*StateBackend) PutScalingEvent

func (s *StateBackend) PutScalingEvent(job string, event *state.ScalingEventMessage) error

func (*StateBackend) RunGarbageCollection

func (s *StateBackend) RunGarbageCollection()