Documentation ¶
Index ¶
- type DataRepository
- func (r *DataRepository) CreateCollection(databaseId string, newCollection repositorymodels.Collection) (repositorymodels.Collection, repositorymodels.RepositoryStatus)
- func (r *DataRepository) CreateDatabase(newDatabase repositorymodels.Database) (repositorymodels.Database, repositorymodels.RepositoryStatus)
- func (r *DataRepository) CreateDocument(databaseId string, collectionId string, document map[string]interface{}) (repositorymodels.Document, repositorymodels.RepositoryStatus)
- func (r *DataRepository) CreateStoredProcedure(databaseId string, collectionId string, sp repositorymodels.StoredProcedure) (repositorymodels.StoredProcedure, repositorymodels.RepositoryStatus)
- func (r *DataRepository) CreateTrigger(databaseId string, collectionId string, trigger repositorymodels.Trigger) (repositorymodels.Trigger, repositorymodels.RepositoryStatus)
- func (r *DataRepository) CreateUserDefinedFunction(databaseId string, collectionId string, ...) (repositorymodels.UserDefinedFunction, repositorymodels.RepositoryStatus)
- func (r *DataRepository) DeleteCollection(databaseId string, collectionId string) repositorymodels.RepositoryStatus
- func (r *DataRepository) DeleteDatabase(id string) repositorymodels.RepositoryStatus
- func (r *DataRepository) DeleteDocument(databaseId string, collectionId string, documentId string) repositorymodels.RepositoryStatus
- func (r *DataRepository) DeleteStoredProcedure(databaseId string, collectionId string, spId string) repositorymodels.RepositoryStatus
- func (r *DataRepository) DeleteTrigger(databaseId string, collectionId string, triggerId string) repositorymodels.RepositoryStatus
- func (r *DataRepository) DeleteUserDefinedFunction(databaseId string, collectionId string, udfId string) repositorymodels.RepositoryStatus
- func (r *DataRepository) ExecuteQueryDocuments(databaseId string, collectionId string, query string, ...) ([]memoryexecutor.RowType, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetAllCollections(databaseId string) ([]repositorymodels.Collection, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetAllDatabases() ([]repositorymodels.Database, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetAllDocuments(databaseId string, collectionId string) ([]repositorymodels.Document, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetAllStoredProcedures(databaseId string, collectionId string) ([]repositorymodels.StoredProcedure, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetAllTriggers(databaseId string, collectionId string) ([]repositorymodels.Trigger, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetAllUserDefinedFunctions(databaseId string, collectionId string) ([]repositorymodels.UserDefinedFunction, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetCollection(databaseId string, collectionId string) (repositorymodels.Collection, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetDatabase(id string) (repositorymodels.Database, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetDocument(databaseId string, collectionId string, documentId string) (repositorymodels.Document, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetPartitionKeyRanges(databaseId string, collectionId string) ([]repositorymodels.PartitionKeyRange, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetState() (string, error)
- func (r *DataRepository) GetStoredProcedure(databaseId string, collectionId string, spId string) (repositorymodels.StoredProcedure, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetTrigger(databaseId string, collectionId string, triggerId string) (repositorymodels.Trigger, repositorymodels.RepositoryStatus)
- func (r *DataRepository) GetUserDefinedFunction(databaseId string, collectionId string, udfId string) (repositorymodels.UserDefinedFunction, repositorymodels.RepositoryStatus)
- func (r *DataRepository) InitializeRepository()
- func (r *DataRepository) LoadStateFS(filePath string)
- func (r *DataRepository) LoadStateJSON(jsonData string) error
- func (r *DataRepository) SaveStateFS(filePath string)
- type RepositoryOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataRepository ¶ added in v0.1.12
type DataRepository struct {
// contains filtered or unexported fields
}
func NewDataRepository ¶ added in v0.1.12
func NewDataRepository(options RepositoryOptions) *DataRepository
func (*DataRepository) CreateCollection ¶ added in v0.1.12
func (r *DataRepository) CreateCollection(databaseId string, newCollection repositorymodels.Collection) (repositorymodels.Collection, repositorymodels.RepositoryStatus)
func (*DataRepository) CreateDatabase ¶ added in v0.1.12
func (r *DataRepository) CreateDatabase(newDatabase repositorymodels.Database) (repositorymodels.Database, repositorymodels.RepositoryStatus)
func (*DataRepository) CreateDocument ¶ added in v0.1.12
func (r *DataRepository) CreateDocument(databaseId string, collectionId string, document map[string]interface{}) (repositorymodels.Document, repositorymodels.RepositoryStatus)
func (*DataRepository) CreateStoredProcedure ¶ added in v0.1.13
func (r *DataRepository) CreateStoredProcedure(databaseId string, collectionId string, sp repositorymodels.StoredProcedure) (repositorymodels.StoredProcedure, repositorymodels.RepositoryStatus)
func (*DataRepository) CreateTrigger ¶ added in v0.1.13
func (r *DataRepository) CreateTrigger(databaseId string, collectionId string, trigger repositorymodels.Trigger) (repositorymodels.Trigger, repositorymodels.RepositoryStatus)
func (*DataRepository) CreateUserDefinedFunction ¶ added in v0.1.13
func (r *DataRepository) CreateUserDefinedFunction(databaseId string, collectionId string, udf repositorymodels.UserDefinedFunction) (repositorymodels.UserDefinedFunction, repositorymodels.RepositoryStatus)
func (*DataRepository) DeleteCollection ¶ added in v0.1.12
func (r *DataRepository) DeleteCollection(databaseId string, collectionId string) repositorymodels.RepositoryStatus
func (*DataRepository) DeleteDatabase ¶ added in v0.1.12
func (r *DataRepository) DeleteDatabase(id string) repositorymodels.RepositoryStatus
func (*DataRepository) DeleteDocument ¶ added in v0.1.12
func (r *DataRepository) DeleteDocument(databaseId string, collectionId string, documentId string) repositorymodels.RepositoryStatus
func (*DataRepository) DeleteStoredProcedure ¶ added in v0.1.13
func (r *DataRepository) DeleteStoredProcedure(databaseId string, collectionId string, spId string) repositorymodels.RepositoryStatus
func (*DataRepository) DeleteTrigger ¶ added in v0.1.13
func (r *DataRepository) DeleteTrigger(databaseId string, collectionId string, triggerId string) repositorymodels.RepositoryStatus
func (*DataRepository) DeleteUserDefinedFunction ¶ added in v0.1.13
func (r *DataRepository) DeleteUserDefinedFunction(databaseId string, collectionId string, udfId string) repositorymodels.RepositoryStatus
func (*DataRepository) ExecuteQueryDocuments ¶ added in v0.1.12
func (r *DataRepository) ExecuteQueryDocuments(databaseId string, collectionId string, query string, queryParameters map[string]interface{}) ([]memoryexecutor.RowType, repositorymodels.RepositoryStatus)
func (*DataRepository) GetAllCollections ¶ added in v0.1.12
func (r *DataRepository) GetAllCollections(databaseId string) ([]repositorymodels.Collection, repositorymodels.RepositoryStatus)
func (*DataRepository) GetAllDatabases ¶ added in v0.1.12
func (r *DataRepository) GetAllDatabases() ([]repositorymodels.Database, repositorymodels.RepositoryStatus)
func (*DataRepository) GetAllDocuments ¶ added in v0.1.12
func (r *DataRepository) GetAllDocuments(databaseId string, collectionId string) ([]repositorymodels.Document, repositorymodels.RepositoryStatus)
func (*DataRepository) GetAllStoredProcedures ¶ added in v0.1.12
func (r *DataRepository) GetAllStoredProcedures(databaseId string, collectionId string) ([]repositorymodels.StoredProcedure, repositorymodels.RepositoryStatus)
func (*DataRepository) GetAllTriggers ¶ added in v0.1.12
func (r *DataRepository) GetAllTriggers(databaseId string, collectionId string) ([]repositorymodels.Trigger, repositorymodels.RepositoryStatus)
func (*DataRepository) GetAllUserDefinedFunctions ¶ added in v0.1.12
func (r *DataRepository) GetAllUserDefinedFunctions(databaseId string, collectionId string) ([]repositorymodels.UserDefinedFunction, repositorymodels.RepositoryStatus)
func (*DataRepository) GetCollection ¶ added in v0.1.12
func (r *DataRepository) GetCollection(databaseId string, collectionId string) (repositorymodels.Collection, repositorymodels.RepositoryStatus)
func (*DataRepository) GetDatabase ¶ added in v0.1.12
func (r *DataRepository) GetDatabase(id string) (repositorymodels.Database, repositorymodels.RepositoryStatus)
func (*DataRepository) GetDocument ¶ added in v0.1.12
func (r *DataRepository) GetDocument(databaseId string, collectionId string, documentId string) (repositorymodels.Document, repositorymodels.RepositoryStatus)
func (*DataRepository) GetPartitionKeyRanges ¶ added in v0.1.12
func (r *DataRepository) GetPartitionKeyRanges(databaseId string, collectionId string) ([]repositorymodels.PartitionKeyRange, repositorymodels.RepositoryStatus)
I have no idea what this is tbh
func (*DataRepository) GetState ¶ added in v0.1.12
func (r *DataRepository) GetState() (string, error)
func (*DataRepository) GetStoredProcedure ¶ added in v0.1.13
func (r *DataRepository) GetStoredProcedure(databaseId string, collectionId string, spId string) (repositorymodels.StoredProcedure, repositorymodels.RepositoryStatus)
func (*DataRepository) GetTrigger ¶ added in v0.1.13
func (r *DataRepository) GetTrigger(databaseId string, collectionId string, triggerId string) (repositorymodels.Trigger, repositorymodels.RepositoryStatus)
func (*DataRepository) GetUserDefinedFunction ¶ added in v0.1.13
func (r *DataRepository) GetUserDefinedFunction(databaseId string, collectionId string, udfId string) (repositorymodels.UserDefinedFunction, repositorymodels.RepositoryStatus)
func (*DataRepository) InitializeRepository ¶ added in v0.1.12
func (r *DataRepository) InitializeRepository()
func (*DataRepository) LoadStateFS ¶ added in v0.1.12
func (r *DataRepository) LoadStateFS(filePath string)
func (*DataRepository) LoadStateJSON ¶ added in v0.1.12
func (r *DataRepository) LoadStateJSON(jsonData string) error
func (*DataRepository) SaveStateFS ¶ added in v0.1.12
func (r *DataRepository) SaveStateFS(filePath string)
type RepositoryOptions ¶ added in v0.1.12
Click to show internal directories.
Click to hide internal directories.