db

Documentation

Index

• Constants
• Variables
• func CheckOccurences(occurences []int64, numTimes int, numSecs int) (occurred bool)
• func HandleEmbeddedRecovery(forceNormal bool, forceDegraded bool, forceStandBy bool, ...)
• func HandleNullRecovery(forceNormal bool, forceDegraded bool, forceStandBy bool, ...)
• 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 (handler *NormalModeHandler) Handle()
  • func (handler *NormalModeHandler) HasThresholdReached() bool
  • func (handler *NormalModeHandler) RecordAppStart(currTime int64)
• type RecoveryDataT
• type RecoveryHandler
  • func NewRecoveryHandler(recoveryData *RecoveryDataT) RecoveryHandler
• type StandByModeHandler
  • func (handler *StandByModeHandler) Handle()
  • func (handler *StandByModeHandler) HasThresholdReached() bool
  • func (handler *StandByModeHandler) RecordAppStart(currTime int64)

Constants

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

Variables

var CurrentMode string = normalMode // default mode

Functions

func CheckOccurences

func CheckOccurences(occurences []int64, numTimes int, numSecs int) (occurred bool)

CheckOccurences : check if this occurred numTimes times in numSecs seconds

func HandleEmbeddedRecovery

func HandleEmbeddedRecovery(forceNormal bool, forceDegraded bool, forceStandBy 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 bool, forceDegraded bool, forceStandBy bool, forceMigrationMode string, currTime int64, appType string)

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

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 (handler *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
	StandbyModeStartTimes           []int64
	ReadableStandbyModeStartTimes   []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

type StandByModeHandler

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

func (*StandByModeHandler) Handle

func (handler *StandByModeHandler) Handle()

func (*StandByModeHandler) HasThresholdReached

func (handler *StandByModeHandler) HasThresholdReached() bool

func (*StandByModeHandler) RecordAppStart

func (handler *StandByModeHandler) RecordAppStart(currTime int64)