consul

Documentation

Index

• func NewStateBackend(log zerolog.Logger, path string, client *api.Client) 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(log zerolog.Logger, path string, client *api.Client) scale.Backend

Types

type StateBackend

type StateBackend struct {
	// 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()