dbsession

Documentation

Index

• type Factory
  • func NewFactory(connection *dbr.Connection, secretKey string) (Factory, error)
• type ReadSession
• type ReadWriteSession
• type Transaction
• type WriteSession
• type WriteSessionWithinTransaction

Types

type Factory

type Factory interface {
	NewReadSession() ReadSession
	NewWriteSession() WriteSession
	NewReadWriteSession() ReadWriteSession
	NewSessionWithinTransaction() (WriteSessionWithinTransaction, dberrors.Error)
}

func NewFactory

func NewFactory(connection *dbr.Connection, secretKey string) (Factory, error)

type ReadSession

type ReadSession interface {
	GetCluster(runtimeID string) (model.Cluster, dberrors.Error)
	GetOperation(operationID string) (model.Operation, dberrors.Error)
	GetLastOperation(runtimeID string) (model.Operation, dberrors.Error)
	GetGardenerClusterByName(name string) (model.Cluster, dberrors.Error)
	GetTenant(runtimeID string) (string, dberrors.Error)
	ListInProgressOperations() ([]model.Operation, dberrors.Error)
	GetRuntimeUpgrade(operationId string) (model.RuntimeUpgrade, dberrors.Error)
	GetTenantForOperation(operationID string) (string, dberrors.Error)
	InProgressOperationsCount() (model.OperationsCount, dberrors.Error)
}

type ReadWriteSession

type ReadWriteSession interface {
	ReadSession
	WriteSession
}

type Transaction

type Transaction interface {
	Commit() dberrors.Error
	RollbackUnlessCommitted()
}

type WriteSession

type WriteSession interface {
	InsertCluster(cluster model.Cluster) dberrors.Error
	InsertGardenerConfig(config model.GardenerConfig) dberrors.Error
	UpdateGardenerClusterConfig(config model.GardenerConfig) dberrors.Error
	InsertAdministrators(clusterId string, administrators []string) dberrors.Error
	InsertOperation(operation model.Operation) dberrors.Error
	UpdateOperationState(operationID string, message string, state model.OperationState, endTime time.Time) dberrors.Error
	UpdateOperationLastError(operationID, msg, reason, component string) dberrors.Error
	TransitionOperation(operationID string, message string, stage model.OperationStage, transitionTime time.Time) dberrors.Error
	UpdateKubeconfig(runtimeID string, kubeconfig string) dberrors.Error
	DeleteCluster(runtimeID string) dberrors.Error
	MarkClusterAsDeleted(runtimeID string) dberrors.Error
	UpdateTenant(runtimeID string, tenant string) dberrors.Error
	UpdateKubernetesVersion(runtimeID string, version string) dberrors.Error
	UpdateShootNetworkingFilterDisabled(runtimeID string, shootNetworkingFilterDisabled *bool) dberrors.Error
}

type WriteSessionWithinTransaction

type WriteSessionWithinTransaction interface {
	WriteSession
	Transaction
}