dbsession

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

type ReadSession interface {
	FindAllInstancesJoinedWithOperation(prct ...predicate.Predicate) ([]internal.InstanceWithOperation, dberr.Error)
	GetInstanceByID(instanceID string) (internal.Instance, dberr.Error)
	GetOperationByID(opID string) (dbmodel.OperationDTO, dberr.Error)
	GetOperationsInProgressByType(operationType dbmodel.OperationType) ([]dbmodel.OperationDTO, dberr.Error)
	GetOperationByTypeAndInstanceID(inID string, opType dbmodel.OperationType) (dbmodel.OperationDTO, dberr.Error)
	GetLMSTenant(name, region string) (dbmodel.LMSTenantDTO, dberr.Error)
}

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

type WriteSession interface {
	InsertInstance(instance internal.Instance) dberr.Error
	InsertOperation(dto dbmodel.OperationDTO) dberr.Error
	UpdateInstance(instance internal.Instance) dberr.Error
	UpdateOperation(instance dbmodel.OperationDTO) dberr.Error
	InsertLMSTenant(dto dbmodel.LMSTenantDTO) dberr.Error
	DeleteInstance(instanceID string) dberr.Error
}

type WriteSessionWithinTransaction interface {
	WriteSession
	Transaction
}