sqldb

Documentation

Index

• Constants
• type SQLDB
  • func NewSQLDB(db helpers.QueryableDB, convergenceWorkersSize int, updateWorkersSize int, ...) *SQLDB
  • func (db *SQLDB) ActualLRPs(ctx context.Context, logger lager.Logger, filter models.ActualLRPFilter) ([]*models.ActualLRP, error)
  • func (db *SQLDB) CancelTask(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, *models.Task, string, error)
  • func (db *SQLDB) ChangeActualLRPPresence(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey, ...) (before *models.ActualLRP, after *models.ActualLRP, err error)
  • func (db *SQLDB) ClaimActualLRP(ctx context.Context, logger lager.Logger, processGuid string, index int32, ...) (*models.ActualLRP, *models.ActualLRP, error)
  • func (db *SQLDB) CompleteTask(ctx context.Context, logger lager.Logger, taskGuid, cellID string, failed bool, ...) (*models.Task, *models.Task, error)
  • func (sqldb *SQLDB) ConvergeLRPs(ctx context.Context, logger lager.Logger, cellSet models.CellSet) db.ConvergenceResult
  • func (sqldb *SQLDB) ConvergeTasks(ctx context.Context, logger lager.Logger, cellSet models.CellSet, ...) db.TaskConvergenceResult
  • func (db *SQLDB) CountActualLRPsByState(ctx context.Context, logger lager.Logger) (...)
  • func (db *SQLDB) CountDesiredInstances(ctx context.Context, logger lager.Logger) int
  • func (db *SQLDB) CrashActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey, ...) (*models.ActualLRP, *models.ActualLRP, bool, error)
  • func (db *SQLDB) CreateConfigurationsTable(ctx context.Context, logger lager.Logger) error
  • func (db *SQLDB) CreateUnclaimedActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey) (*models.ActualLRP, error)
  • func (db *SQLDB) DeleteTask(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, error)
  • func (db *SQLDB) DesireLRP(ctx context.Context, logger lager.Logger, desiredLRP *models.DesiredLRP) error
  • func (db *SQLDB) DesireTask(ctx context.Context, logger lager.Logger, taskDef *models.TaskDefinition, ...) (*models.Task, error)
  • func (db *SQLDB) DesiredLRPByProcessGuid(ctx context.Context, logger lager.Logger, processGuid string) (*models.DesiredLRP, error)
  • func (db *SQLDB) DesiredLRPRoutingInfos(ctx context.Context, logger lager.Logger, filter models.DesiredLRPFilter) ([]*models.DesiredLRP, error)
  • func (db *SQLDB) DesiredLRPSchedulingInfoByProcessGuid(ctx context.Context, logger lager.Logger, processGuid string) (*models.DesiredLRPSchedulingInfo, error)
  • func (db *SQLDB) DesiredLRPSchedulingInfos(ctx context.Context, logger lager.Logger, filter models.DesiredLRPFilter) ([]*models.DesiredLRPSchedulingInfo, error)
  • func (db *SQLDB) DesiredLRPs(ctx context.Context, logger lager.Logger, filter models.DesiredLRPFilter) ([]*models.DesiredLRP, error)
  • func (db *SQLDB) EncryptionKeyLabel(ctx context.Context, logger lager.Logger) (string, error)
  • func (db *SQLDB) EvacuateActualLRP(ctx context.Context, logger lager.Logger, lrpKey *models.ActualLRPKey, ...) (*models.ActualLRP, error)
  • func (db *SQLDB) FailActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey, ...) (*models.ActualLRP, *models.ActualLRP, error)
  • func (db *SQLDB) FailTask(ctx context.Context, logger lager.Logger, taskGuid, failureReason string) (*models.Task, *models.Task, error)
  • func (db *SQLDB) FreshDomains(ctx context.Context, logger lager.Logger) ([]string, error)
  • func (db *SQLDB) PerformEncryption(ctx context.Context, logger lager.Logger) error
  • func (db *SQLDB) PromoteSuspectActualLRP(ctx context.Context, logger lager.Logger, processGuid string, index int32) (*models.ActualLRP, *models.ActualLRP, *models.ActualLRP, error)
  • func (db *SQLDB) RejectTask(ctx context.Context, logger lager.Logger, taskGuid, rejectionReason string) (*models.Task, *models.Task, error)
  • func (db *SQLDB) RemoveActualLRP(ctx context.Context, logger lager.Logger, processGuid string, index int32, ...) error
  • func (db *SQLDB) RemoveDesiredLRP(ctx context.Context, logger lager.Logger, processGuid string) error
  • func (db *SQLDB) RemoveEvacuatingActualLRP(ctx context.Context, logger lager.Logger, lrpKey *models.ActualLRPKey, ...) error
  • func (db *SQLDB) RemoveSuspectActualLRP(ctx context.Context, logger lager.Logger, lrpKey *models.ActualLRPKey) (*models.ActualLRP, error)
  • func (db *SQLDB) ResolvingTask(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, *models.Task, error)
  • func (db *SQLDB) SetEncryptionKeyLabel(ctx context.Context, logger lager.Logger, label string) error
  • func (db *SQLDB) SetVersion(tx helpers.Tx, ctx context.Context, logger lager.Logger, ...) error
  • func (db *SQLDB) StartActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey, ...) (*models.ActualLRP, *models.ActualLRP, error)
  • func (db *SQLDB) StartTask(ctx context.Context, logger lager.Logger, taskGuid, cellId string) (*models.Task, *models.Task, bool, error)
  • func (db *SQLDB) TaskByGuid(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, error)
  • func (db *SQLDB) Tasks(ctx context.Context, logger lager.Logger, filter models.TaskFilter) ([]*models.Task, error)
  • func (db *SQLDB) UnclaimActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey) (*models.ActualLRP, *models.ActualLRP, error)
  • func (db *SQLDB) UpdateDesiredLRP(ctx context.Context, logger lager.Logger, processGuid string, ...) (*models.DesiredLRP, error)
  • func (db *SQLDB) UpsertDomain(ctx context.Context, logger lager.Logger, domain string, ttl uint32) error
  • func (db *SQLDB) Version(tx helpers.Tx, ctx context.Context, logger lager.Logger) (*models.Version, error)

Constants

const EncryptionKeyID = "encryption_key_label"

const (
	Truncated = "(truncated)"
)

const VersionID = "version"

Types

type SQLDB

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

func NewSQLDB

func NewSQLDB(
	db helpers.QueryableDB,
	convergenceWorkersSize int,
	updateWorkersSize int,
	cryptor encryption.Cryptor,
	guidProvider guidprovider.GUIDProvider,
	clock clock.Clock,
	flavor string,
	metronClient loggingclient.IngressClient,
) *SQLDB

func (*SQLDB) ActualLRPs

func (db *SQLDB) ActualLRPs(ctx context.Context, logger lager.Logger, filter models.ActualLRPFilter) ([]*models.ActualLRP, error)

func (*SQLDB) CancelTask

func (db *SQLDB) CancelTask(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, *models.Task, string, error)

func (*SQLDB) ChangeActualLRPPresence

func (db *SQLDB) ChangeActualLRPPresence(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey, from, to models.ActualLRP_Presence) (before *models.ActualLRP, after *models.ActualLRP, err error)

func (*SQLDB) ClaimActualLRP

func (db *SQLDB) ClaimActualLRP(ctx context.Context, logger lager.Logger, processGuid string, index int32, instanceKey *models.ActualLRPInstanceKey) (*models.ActualLRP, *models.ActualLRP, error)

func (*SQLDB) CompleteTask

func (db *SQLDB) CompleteTask(ctx context.Context, logger lager.Logger, taskGuid, cellID string, failed bool, failureReason, taskResult string) (*models.Task, *models.Task, error)

func (*SQLDB) ConvergeLRPs

func (sqldb *SQLDB) ConvergeLRPs(ctx context.Context, logger lager.Logger, cellSet models.CellSet) db.ConvergenceResult

func (*SQLDB) ConvergeTasks

func (sqldb *SQLDB) ConvergeTasks(ctx context.Context, logger lager.Logger, cellSet models.CellSet, kickTasksDuration, expirePendingTaskDuration, expireCompletedTaskDuration time.Duration) db.TaskConvergenceResult

func (*SQLDB) CountActualLRPsByState

func (db *SQLDB) CountActualLRPsByState(ctx context.Context, logger lager.Logger) (claimedCount, unclaimedCount, runningCount, crashedCount, crashingDesiredCount int)

func (*SQLDB) CountDesiredInstances

func (db *SQLDB) CountDesiredInstances(ctx context.Context, logger lager.Logger) int

func (*SQLDB) CrashActualLRP

func (db *SQLDB) CrashActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey, crashReason string) (*models.ActualLRP, *models.ActualLRP, bool, error)

func (*SQLDB) CreateConfigurationsTable

func (db *SQLDB) CreateConfigurationsTable(ctx context.Context, logger lager.Logger) error

func (*SQLDB) CreateUnclaimedActualLRP

func (db *SQLDB) CreateUnclaimedActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey) (*models.ActualLRP, error)

func (*SQLDB) DeleteTask

func (db *SQLDB) DeleteTask(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, error)

func (*SQLDB) DesireLRP

func (db *SQLDB) DesireLRP(ctx context.Context, logger lager.Logger, desiredLRP *models.DesiredLRP) error

func (*SQLDB) DesireTask

func (db *SQLDB) DesireTask(ctx context.Context, logger lager.Logger, taskDef *models.TaskDefinition, taskGuid, domain string) (*models.Task, error)

func (*SQLDB) DesiredLRPByProcessGuid

func (db *SQLDB) DesiredLRPByProcessGuid(ctx context.Context, logger lager.Logger, processGuid string) (*models.DesiredLRP, error)

func (*SQLDB) DesiredLRPRoutingInfos

func (db *SQLDB) DesiredLRPRoutingInfos(ctx context.Context, logger lager.Logger, filter models.DesiredLRPFilter) ([]*models.DesiredLRP, error)

func (*SQLDB) DesiredLRPSchedulingInfoByProcessGuid

func (db *SQLDB) DesiredLRPSchedulingInfoByProcessGuid(ctx context.Context, logger lager.Logger, processGuid string) (*models.DesiredLRPSchedulingInfo, error)

func (*SQLDB) DesiredLRPSchedulingInfos

func (db *SQLDB) DesiredLRPSchedulingInfos(ctx context.Context, logger lager.Logger, filter models.DesiredLRPFilter) ([]*models.DesiredLRPSchedulingInfo, error)

func (*SQLDB) DesiredLRPs

func (db *SQLDB) DesiredLRPs(ctx context.Context, logger lager.Logger, filter models.DesiredLRPFilter) ([]*models.DesiredLRP, error)

func (*SQLDB) EncryptionKeyLabel

func (db *SQLDB) EncryptionKeyLabel(ctx context.Context, logger lager.Logger) (string, error)

func (*SQLDB) EvacuateActualLRP

func (db *SQLDB) EvacuateActualLRP(
	ctx context.Context,
	logger lager.Logger,
	lrpKey *models.ActualLRPKey,
	instanceKey *models.ActualLRPInstanceKey,
	netInfo *models.ActualLRPNetInfo,
	internalRoutes []*models.ActualLRPInternalRoute,
	metricTags map[string]string,
	routable bool,
	availabilityZone string,
) (*models.ActualLRP, error)

func (*SQLDB) FailActualLRP

func (db *SQLDB) FailActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey, placementError string) (*models.ActualLRP, *models.ActualLRP, error)

func (*SQLDB) FailTask

func (db *SQLDB) FailTask(ctx context.Context, logger lager.Logger, taskGuid, failureReason string) (*models.Task, *models.Task, error)

func (*SQLDB) FreshDomains

func (db *SQLDB) FreshDomains(ctx context.Context, logger lager.Logger) ([]string, error)

func (*SQLDB) PerformEncryption

func (db *SQLDB) PerformEncryption(ctx context.Context, logger lager.Logger) error

func (*SQLDB) PromoteSuspectActualLRP

func (db *SQLDB) PromoteSuspectActualLRP(ctx context.Context, logger lager.Logger, processGuid string, index int32) (*models.ActualLRP, *models.ActualLRP, *models.ActualLRP, error)

func (*SQLDB) RejectTask

func (db *SQLDB) RejectTask(ctx context.Context, logger lager.Logger, taskGuid, rejectionReason string) (*models.Task, *models.Task, error)

func (*SQLDB) RemoveActualLRP

func (db *SQLDB) RemoveActualLRP(ctx context.Context, logger lager.Logger, processGuid string, index int32, instanceKey *models.ActualLRPInstanceKey) error

func (*SQLDB) RemoveDesiredLRP

func (db *SQLDB) RemoveDesiredLRP(ctx context.Context, logger lager.Logger, processGuid string) error

func (*SQLDB) RemoveEvacuatingActualLRP

func (db *SQLDB) RemoveEvacuatingActualLRP(ctx context.Context, logger lager.Logger, lrpKey *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey) error

func (*SQLDB) RemoveSuspectActualLRP

func (db *SQLDB) RemoveSuspectActualLRP(ctx context.Context, logger lager.Logger, lrpKey *models.ActualLRPKey) (*models.ActualLRP, error)

func (*SQLDB) ResolvingTask

func (db *SQLDB) ResolvingTask(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, *models.Task, error)

The stager calls this when it wants to claim a completed task. This ensures that only one stager ever attempts to handle a completed task

func (*SQLDB) SetEncryptionKeyLabel

func (db *SQLDB) SetEncryptionKeyLabel(ctx context.Context, logger lager.Logger, label string) error

func (*SQLDB) SetVersion

func (db *SQLDB) SetVersion(tx helpers.Tx, ctx context.Context, logger lager.Logger, version *models.Version) error

func (*SQLDB) StartActualLRP

func (db *SQLDB) StartActualLRP(
	ctx context.Context,
	logger lager.Logger,
	key *models.ActualLRPKey,
	instanceKey *models.ActualLRPInstanceKey,
	netInfo *models.ActualLRPNetInfo,
	internalRoutes []*models.ActualLRPInternalRoute,
	metricTags map[string]string,
	routable bool,
	availabilityZone string,
) (*models.ActualLRP, *models.ActualLRP, error)

func (*SQLDB) StartTask

func (db *SQLDB) StartTask(ctx context.Context, logger lager.Logger, taskGuid, cellId string) (*models.Task, *models.Task, bool, error)

func (*SQLDB) TaskByGuid

func (db *SQLDB) TaskByGuid(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, error)

func (*SQLDB) Tasks

func (db *SQLDB) Tasks(ctx context.Context, logger lager.Logger, filter models.TaskFilter) ([]*models.Task, error)

func (*SQLDB) UnclaimActualLRP

func (db *SQLDB) UnclaimActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey) (*models.ActualLRP, *models.ActualLRP, error)

func (*SQLDB) UpdateDesiredLRP

func (db *SQLDB) UpdateDesiredLRP(ctx context.Context, logger lager.Logger, processGuid string, update *models.DesiredLRPUpdate) (*models.DesiredLRP, error)

func (*SQLDB) UpsertDomain

func (db *SQLDB) UpsertDomain(ctx context.Context, logger lager.Logger, domain string, ttl uint32) error

func (*SQLDB) Version

func (db *SQLDB) Version(tx helpers.Tx, ctx context.Context, logger lager.Logger) (*models.Version, error)