db

Documentation

Index

• Constants
• Variables
• func CheckOccurrences(occurrences []int64, numTimes, numSecs int) (occurred bool)
• func HandleEmbeddedRecovery(forceNormal, forceDegraded bool, forceMigrationMode string, currTime int64, ...)
• func HandleNullRecovery(forceNormal, forceDegraded bool, forceMigrationMode string, currTime int64, ...)
• func Init()
• func IsNormalMode() bool
• func IsValidMigrationMode(migrationMode string) bool
• type DegradedModeHandler
  • func (handler *DegradedModeHandler) Handle()
  • func (handler *DegradedModeHandler) HasThresholdReached() bool
  • func (handler *DegradedModeHandler) RecordAppStart(currTime int64)
• type MigrationModeHandler
  • func (handler *MigrationModeHandler) Handle()
  • func (handler *MigrationModeHandler) HasThresholdReached() bool
  • func (handler *MigrationModeHandler) RecordAppStart(currTime int64)
• type NormalModeHandler
  • func (*NormalModeHandler) Handle()
  • func (handler *NormalModeHandler) HasThresholdReached() bool
  • func (handler *NormalModeHandler) RecordAppStart(currTime int64)
• type RecoveryDataT
• type RecoveryHandler
  • func NewRecoveryHandler(recoveryData *RecoveryDataT) RecoveryHandler

Constants

const (
	EXPORT        = "export"
	IMPORT        = "import"
	IMPORT_EXPORT = "import-export"
)

Variables

var (
	CurrentMode = normalMode // default mode

)

Functions

func CheckOccurrences

func CheckOccurrences(occurrences []int64, numTimes, numSecs int) (occurred bool)

CheckOccurrences : check if this occurred numTimes times in numSecs seconds

func HandleEmbeddedRecovery

func HandleEmbeddedRecovery(forceNormal, forceDegraded bool, forceMigrationMode string, currTime int64, appType string)

HandleEmbeddedRecovery decides the recovery Mode in which app should run based on earlier crashes

func HandleNullRecovery

func HandleNullRecovery(forceNormal, forceDegraded bool, forceMigrationMode string, currTime int64, appType string)

HandleNullRecovery decides the recovery Mode (normal/migration) in which app should run

func Init

func Init()

func IsNormalMode

func IsNormalMode() bool

IsNormalMode checks if the current mode is normal

func IsValidMigrationMode

func IsValidMigrationMode(migrationMode string) bool

Types

type DegradedModeHandler

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

func (*DegradedModeHandler) Handle

func (handler *DegradedModeHandler) Handle()

func (*DegradedModeHandler) HasThresholdReached

func (handler *DegradedModeHandler) HasThresholdReached() bool

func (*DegradedModeHandler) RecordAppStart

func (handler *DegradedModeHandler) RecordAppStart(currTime int64)

type MigrationModeHandler

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

func (*MigrationModeHandler) Handle

func (handler *MigrationModeHandler) Handle()

func (*MigrationModeHandler) HasThresholdReached

func (handler *MigrationModeHandler) HasThresholdReached() bool

func (*MigrationModeHandler) RecordAppStart

func (handler *MigrationModeHandler) RecordAppStart(currTime int64)

type NormalModeHandler

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

func (*NormalModeHandler) Handle

func (*NormalModeHandler) Handle()

func (*NormalModeHandler) HasThresholdReached

func (handler *NormalModeHandler) HasThresholdReached() bool

func (*NormalModeHandler) RecordAppStart

func (handler *NormalModeHandler) RecordAppStart(currTime int64)

type RecoveryDataT

type RecoveryDataT struct {
	StartTimes                      []int64
	ReadableStartTimes              []string
	DegradedModeStartTimes          []int64
	ReadableDegradedModeStartTimes  []string
	MigrationModeStartTimes         []int64
	ReadableMigrationModeStartTimes []string
	Mode                            string
}

RecoveryDataT : DS to store the recovery process data

type RecoveryHandler

type RecoveryHandler interface {
	RecordAppStart(int64)
	HasThresholdReached() bool
	Handle()
}

func NewRecoveryHandler

func NewRecoveryHandler(recoveryData *RecoveryDataT) RecoveryHandler