Documentation
¶
Index ¶
- Constants
- type 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) 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) 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(ctx context.Context, logger lager.Logger, version *models.Version) 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(ctx context.Context, logger lager.Logger) (*models.Version, error)
Constants ¶
View Source
const EncryptionKeyID = "encryption_key_label"
View Source
const (
Truncated = "(truncated)"
)
View Source
const VersionID = "version"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*SQLDB) CancelTask ¶
func (*SQLDB) ChangeActualLRPPresence ¶
func (*SQLDB) ClaimActualLRP ¶
func (*SQLDB) CompleteTask ¶
func (*SQLDB) ConvergeLRPs ¶
func (*SQLDB) ConvergeTasks ¶
func (*SQLDB) CountActualLRPsByState ¶
func (*SQLDB) CountDesiredInstances ¶
func (*SQLDB) CrashActualLRP ¶
func (*SQLDB) CreateConfigurationsTable ¶
func (*SQLDB) CreateUnclaimedActualLRP ¶
func (*SQLDB) DeleteTask ¶
func (*SQLDB) DesireTask ¶
func (*SQLDB) DesiredLRPByProcessGuid ¶
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 (*SQLDB) EvacuateActualLRP ¶
func (db *SQLDB) EvacuateActualLRP( ctx context.Context, logger lager.Logger, lrpKey *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey, netInfo *models.ActualLRPNetInfo, internalRoutes []*models.ActualLRPInternalRoute, ) (*models.ActualLRP, error)
func (*SQLDB) FailActualLRP ¶
func (*SQLDB) FreshDomains ¶
func (*SQLDB) PerformEncryption ¶
func (*SQLDB) RejectTask ¶
func (*SQLDB) RemoveActualLRP ¶
func (*SQLDB) RemoveDesiredLRP ¶
func (*SQLDB) RemoveEvacuatingActualLRP ¶
func (db *SQLDB) RemoveEvacuatingActualLRP(ctx context.Context, logger lager.Logger, lrpKey *models.ActualLRPKey, instanceKey *models.ActualLRPInstanceKey) error
func (*SQLDB) RemoveSuspectActualLRP ¶
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 (*SQLDB) SetVersion ¶
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, ) (*models.ActualLRP, *models.ActualLRP, error)
func (*SQLDB) TaskByGuid ¶
func (*SQLDB) UnclaimActualLRP ¶
func (*SQLDB) UpdateDesiredLRP ¶
func (*SQLDB) UpsertDomain ¶
Source Files
¶
Directories
¶
Path | Synopsis |
---|---|
fakesqldriverfakes
Code generated by counterfeiter.
|
Code generated by counterfeiter. |
helpersfakes
Code generated by counterfeiter.
|
Code generated by counterfeiter. |
monitor/monitorfakes
Code generated by counterfeiter.
|
Code generated by counterfeiter. |
Click to show internal directories.
Click to hide internal directories.