store

Documentation

Index

• Variables
• type RealStore
  • func NewStore(config *config.Config, adapter storeadapter.StoreAdapter, logger lager.Logger) *RealStore
  • func (store *RealStore) AppKey(appGuid string, appVersion string) string
  • func (store *RealStore) BumpActualFreshness(timestamp time.Time) error
  • func (store *RealStore) Compact() error
  • func (store *RealStore) DeletePendingStartMessages(messages ...models.PendingStartMessage) error
  • func (store *RealStore) DeletePendingStopMessages(messages ...models.PendingStopMessage) error
  • func (store *RealStore) GetApp(appGuid string, appVersion string) (*models.App, error)
  • func (store *RealStore) GetApps() (results map[string]*models.App, err error)
  • func (store *RealStore) GetDeaCache() (map[string]struct{}, error)
  • func (store *RealStore) GetInstanceHeartbeats() (results []models.InstanceHeartbeat, err error)
  • func (store *RealStore) GetInstanceHeartbeatsForApp(appGuid string, appVersion string) (results []models.InstanceHeartbeat, err error)
  • func (store *RealStore) GetMetric(metric string) (float64, error)
  • func (store *RealStore) GetPendingStartMessages() (map[string]models.PendingStartMessage, error)
  • func (store *RealStore) GetPendingStopMessages() (map[string]models.PendingStopMessage, error)
  • func (store *RealStore) IsActualStateFresh(currentTime time.Time) (bool, error)
  • func (store *RealStore) RevokeActualFreshness() error
  • func (store *RealStore) SaveCrashCounts(crashCounts ...models.CrashCount) error
  • func (store *RealStore) SaveMetric(metric string, value float64) error
  • func (store *RealStore) SavePendingStartMessages(messages ...models.PendingStartMessage) error
  • func (store *RealStore) SavePendingStopMessages(messages ...models.PendingStopMessage) error
  • func (store *RealStore) SchemaRoot() string
  • func (store *RealStore) SyncHeartbeats(incomingHeartbeats ...*models.Heartbeat) ([]models.InstanceHeartbeat, error)
  • func (store *RealStore) VerifyFreshness(time time.Time) error
• type Store
• type Storeable

Variables

var ActualIsNotFreshError = errors.New("Actual state is not fresh")

var AppNotFoundError = errors.New("App not found")

Types

type RealStore

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

func NewStore

func NewStore(config *config.Config, adapter storeadapter.StoreAdapter, logger lager.Logger) *RealStore

func (*RealStore) AppKey

func (store *RealStore) AppKey(appGuid string, appVersion string) string

func (*RealStore) BumpActualFreshness

func (store *RealStore) BumpActualFreshness(timestamp time.Time) error

func (*RealStore) Compact

func (store *RealStore) Compact() error

func (*RealStore) DeletePendingStartMessages

func (store *RealStore) DeletePendingStartMessages(messages ...models.PendingStartMessage) error

func (*RealStore) DeletePendingStopMessages

func (store *RealStore) DeletePendingStopMessages(messages ...models.PendingStopMessage) error

func (*RealStore) GetApp

func (store *RealStore) GetApp(appGuid string, appVersion string) (*models.App, error)

func (*RealStore) GetApps

func (store *RealStore) GetApps() (results map[string]*models.App, err error)

func (*RealStore) GetDeaCache

func (store *RealStore) GetDeaCache() (map[string]struct{}, error)

func (*RealStore) GetInstanceHeartbeats

func (store *RealStore) GetInstanceHeartbeats() (results []models.InstanceHeartbeat, err error)

func (*RealStore) GetInstanceHeartbeatsForApp

func (store *RealStore) GetInstanceHeartbeatsForApp(appGuid string, appVersion string) (results []models.InstanceHeartbeat, err error)

func (*RealStore) GetMetric

func (store *RealStore) GetMetric(metric string) (float64, error)

func (*RealStore) GetPendingStartMessages

func (store *RealStore) GetPendingStartMessages() (map[string]models.PendingStartMessage, error)

func (*RealStore) GetPendingStopMessages

func (store *RealStore) GetPendingStopMessages() (map[string]models.PendingStopMessage, error)

func (*RealStore) IsActualStateFresh

func (store *RealStore) IsActualStateFresh(currentTime time.Time) (bool, error)

func (*RealStore) RevokeActualFreshness

func (store *RealStore) RevokeActualFreshness() error

func (*RealStore) SaveCrashCounts

func (store *RealStore) SaveCrashCounts(crashCounts ...models.CrashCount) error

func (*RealStore) SaveMetric

func (store *RealStore) SaveMetric(metric string, value float64) error

func (*RealStore) SavePendingStartMessages

func (store *RealStore) SavePendingStartMessages(messages ...models.PendingStartMessage) error

func (*RealStore) SavePendingStopMessages

func (store *RealStore) SavePendingStopMessages(messages ...models.PendingStopMessage) error

func (*RealStore) SchemaRoot

func (store *RealStore) SchemaRoot() string

func (*RealStore) SyncHeartbeats

func (store *RealStore) SyncHeartbeats(incomingHeartbeats ...*models.Heartbeat) ([]models.InstanceHeartbeat, error)

func (*RealStore) VerifyFreshness

func (store *RealStore) VerifyFreshness(time time.Time) error

type Store

type Store interface {
	BumpActualFreshness(timestamp time.Time) error
	RevokeActualFreshness() error

	IsActualStateFresh(time.Time) (bool, error)

	VerifyFreshness(time.Time) error

	AppKey(appGuid string, appVersion string) string
	GetApps() (map[string]*models.App, error)
	GetApp(appGuid string, appVersion string) (*models.App, error)

	SyncHeartbeats(heartbeat ...*models.Heartbeat) ([]models.InstanceHeartbeat, error)
	GetInstanceHeartbeats() (results []models.InstanceHeartbeat, err error)
	GetInstanceHeartbeatsForApp(appGuid string, appVersion string) (results []models.InstanceHeartbeat, err error)

	SaveCrashCounts(crashCounts ...models.CrashCount) error

	SavePendingStartMessages(startMessages ...models.PendingStartMessage) error
	GetPendingStartMessages() (map[string]models.PendingStartMessage, error)
	DeletePendingStartMessages(startMessages ...models.PendingStartMessage) error

	SavePendingStopMessages(stopMessages ...models.PendingStopMessage) error
	GetPendingStopMessages() (map[string]models.PendingStopMessage, error)
	DeletePendingStopMessages(stopMessages ...models.PendingStopMessage) error

	SaveMetric(metric string, value float64) error
	GetMetric(metric string) (float64, error)

	Compact() error

	GetDeaCache() (map[string]struct{}, error)
}

type Storeable

type Storeable interface {
	StoreKey() string
	ToJSON() []byte
}