cloudflared1

package
v1.0.28 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 13, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Driver 

type Driver struct {
	Conf             *models.Config
	DriverCredential *models.DriverCredentials
	DB               *cfd1.DB
}

Driver is the Cloudflare D1 project driver.

func GetDriver 

func GetDriver(cfg *models.Config, cred *models.DriverCredentials, boundExec cfd1.BoundExecFunc) (*Driver, error)

GetDriver opens a project cloudflared1 driver.

func (*Driver) AddDocumentToProject 

func (d *Driver) AddDocumentToProject(ctx context.Context, param *models.CommonSystemParams, doc *types.DefaultDocumentStructure) (interface{}, error)

func (*Driver) AddFieldToModel 

func (d *Driver) AddFieldToModel(ctx context.Context, param *models.CommonSystemParams, isUpdate bool, parentField string) (*models.ModelType, error)

func (*Driver) AddModel 

func (d *Driver) AddModel(ctx context.Context, project *models.Project, model *models.ModelType) (*models.ProjectSchema, error)

func (*Driver) AddRelationFields 

func (d *Driver) AddRelationFields(ctx context.Context, from *models.ConnectionType, to *models.ConnectionType) error

func (*Driver) AddTeamMetaInfo 

func (d *Driver) AddTeamMetaInfo(ctx context.Context, docs []*models.SystemUser) ([]*models.SystemUser, error)

func (*Driver) AggregateDocOfProject 

func (d *Driver) AggregateDocOfProject(ctx context.Context, param *models.CommonSystemParams) (interface{}, error)

func (*Driver) AggregateDocOfProjectBytes 

func (d *Driver) AggregateDocOfProjectBytes(ctx context.Context, param *models.CommonSystemParams) ([]byte, error)

func (*Driver) CheckOneToOneRelationExists 

func (d *Driver) CheckOneToOneRelationExists(ctx context.Context, param *models.ConnectDisconnectParam) (bool, error)

func (*Driver) CheckTableOrCollectionExists 

func (d *Driver) CheckTableOrCollectionExists(ctx context.Context, param *models.CommonSystemParams) (bool, error)

func (*Driver) ConnectBuilder 

func (d *Driver) ConnectBuilder(ctx context.Context, param *models.CommonSystemParams) error

func (*Driver) ConvertModel 

func (d *Driver) ConvertModel(ctx context.Context, project *models.Project, modelName string) error

func (*Driver) CountDocOfProject 

func (d *Driver) CountDocOfProject(ctx context.Context, param *models.CommonSystemParams) (interface{}, error)

func (*Driver) CountDocOfProjectBytes 

func (d *Driver) CountDocOfProjectBytes(ctx context.Context, param *models.CommonSystemParams) ([]byte, error)

func (*Driver) CountMultiDocumentOfProject 

func (d *Driver) CountMultiDocumentOfProject(ctx context.Context, param *models.CommonSystemParams, previewModel bool) (int, error)

func (*Driver) CountProjectAuthUsersByRole 

func (d *Driver) CountProjectAuthUsersByRole(ctx context.Context, tenantID string) (map[string]int, error)

func (*Driver) CreateIndex 

func (d *Driver) CreateIndex(ctx context.Context, param *models.CommonSystemParams, fieldName string, parentField string) error

func (*Driver) CreateProjectAuthUser 

func (d *Driver) CreateProjectAuthUser(ctx context.Context, user *models.ProjectAuthUser) (*models.ProjectAuthUser, error)

func (*Driver) CreateProjectFile 

func (d *Driver) CreateProjectFile(ctx context.Context, file *models.ProjectFile) (*models.ProjectFile, error)

func (*Driver) CreateRelation 

func (d *Driver) CreateRelation(ctx context.Context, projectId string, relation *models.EdgeRelation) error

func (*Driver) CreateTableOrCollection 

func (d *Driver) CreateTableOrCollection(ctx context.Context, param *models.CommonSystemParams, indexes []string) error

func (*Driver) DeleteDocumentFromProject 

func (d *Driver) DeleteDocumentFromProject(ctx context.Context, param *models.CommonSystemParams) error

func (*Driver) DeleteDocumentRelation 

func (d *Driver) DeleteDocumentRelation(ctx context.Context, param *models.CommonSystemParams) error

func (*Driver) DeleteDocumentsFromProject 

func (d *Driver) DeleteDocumentsFromProject(ctx context.Context, param *models.CommonSystemParams) error

func (*Driver) DeleteProject 

func (d *Driver) DeleteProject(ctx context.Context, projectID string) error

func (*Driver) DeleteProjectAuthUser 

func (d *Driver) DeleteProjectAuthUser(ctx context.Context, userID string) error

func (*Driver) DeleteProjectBase 

func (d *Driver) DeleteProjectBase(ctx context.Context, param *models.CommonSystemParams) error

func (*Driver) DeleteProjectFiles 

func (d *Driver) DeleteProjectFiles(ctx context.Context, ids []string) error

func (*Driver) DeleteRelation 

func (d *Driver) DeleteRelation(ctx context.Context, param *models.ConnectDisconnectParam, id string) error

func (*Driver) DeleteRelationDocuments 

func (d *Driver) DeleteRelationDocuments(ctx context.Context, projectId string, from *models.ConnectionType, to *models.ConnectionType) error

func (*Driver) DisconnectBuilder 

func (d *Driver) DisconnectBuilder(ctx context.Context, param *models.CommonSystemParams) error

func (*Driver) DropField 

func (d *Driver) DropField(ctx context.Context, param *models.CommonSystemParams) error

func (*Driver) DropIndex 

func (d *Driver) DropIndex(ctx context.Context, param *models.CommonSystemParams, indexName string) error

func (*Driver) DropModel 

func (d *Driver) DropModel(ctx context.Context, project *models.Project, modelName string) error

func (*Driver) EnsureFilesTable 

func (d *Driver) EnsureFilesTable(ctx context.Context) error

func (*Driver) EnsureRelationArtifactsFromSchema 

func (d *Driver) EnsureRelationArtifactsFromSchema(ctx context.Context, modelsList []*models.ModelType) error

EnsureRelationArtifactsFromSchema creates missing D1 relation tables and foreign keys. Each relation is applied once from its forward connection, in the same argument order as addRelation.

func (*Driver) EnsureUsersTable 

func (d *Driver) EnsureUsersTable(ctx context.Context) error

func (*Driver) GetAllRelationDocumentsOfSingleDocument 

func (d *Driver) GetAllRelationDocumentsOfSingleDocument(ctx context.Context, from string, arg *models.CommonSystemParams) (interface{}, error)

func (*Driver) GetLoggedInProjectUser 

func (d *Driver) GetLoggedInProjectUser(ctx context.Context, param *models.CommonSystemParams) (*types.DefaultDocumentStructure, error)

func (*Driver) GetProjectAuthUser 

func (d *Driver) GetProjectAuthUser(ctx context.Context, userID string) (*models.ProjectAuthUser, error)

func (*Driver) GetProjectAuthUserByUsername 

func (d *Driver) GetProjectAuthUserByUsername(ctx context.Context, username string) (*models.ProjectAuthUser, error)

func (*Driver) GetProjectFile 

func (d *Driver) GetProjectFile(ctx context.Context, fileID string) (*models.ProjectFile, error)

func (*Driver) GetProjectUser 

func (d *Driver) GetProjectUser(ctx context.Context, phone, email, projectId string) (*types.DefaultDocumentStructure, error)

func (*Driver) GetProjectUsers 

func (d *Driver) GetProjectUsers(ctx context.Context, projectId string, keys []string) (map[string]*types.DefaultDocumentStructure, error)

func (*Driver) GetRelationDocument 

func (d *Driver) GetRelationDocument(ctx context.Context, param *models.ConnectDisconnectParam) (*models.EdgeRelation, error)

func (*Driver) GetRelationIds 

func (d *Driver) GetRelationIds(ctx context.Context, param *models.ConnectDisconnectParam) ([]string, error)

func (*Driver) GetSingleProjectDocument 

func (d *Driver) GetSingleProjectDocument(ctx context.Context, param *models.CommonSystemParams) (*types.DefaultDocumentStructure, error)

func (*Driver) GetSingleProjectDocumentBytes 

func (d *Driver) GetSingleProjectDocumentBytes(ctx context.Context, param *models.CommonSystemParams) ([]byte, error)

func (*Driver) GetSingleProjectDocumentRevisions 

func (d *Driver) GetSingleProjectDocumentRevisions(ctx context.Context, param *models.CommonSystemParams) ([]*models.DocumentRevisionHistory, error)

func (*Driver) GetSingleRawDocumentFromProject 

func (d *Driver) GetSingleRawDocumentFromProject(ctx context.Context, param *models.CommonSystemParams) (interface{}, error)

func (*Driver) InitProjectBase 

func (d *Driver) InitProjectBase(ctx context.Context, param *models.CommonSystemParams, indexes []string) error

func (*Driver) ListProjectAuthUsersByEmail 

func (d *Driver) ListProjectAuthUsersByEmail(ctx context.Context, tenantID, email string) ([]*models.ProjectAuthUser, error)

func (*Driver) ListProjectAuthUsersByGoogleSub 

func (d *Driver) ListProjectAuthUsersByGoogleSub(ctx context.Context, tenantID, googleSub string) ([]*models.ProjectAuthUser, error)

func (*Driver) ListProjectAuthUsersByOAuthSub 

func (d *Driver) ListProjectAuthUsersByOAuthSub(ctx context.Context, tenantID, provider, oauthSub string) ([]*models.ProjectAuthUser, error)

func (*Driver) ListProjectAuthUsersByPhone 

func (d *Driver) ListProjectAuthUsersByPhone(ctx context.Context, tenantID, phone string) ([]*models.ProjectAuthUser, error)

func (*Driver) ListTableColumnNames 

func (d *Driver) ListTableColumnNames(ctx context.Context, tableName string) ([]string, error)

ListTableColumnNames implements interfaces.PhysicalTableColumnLister (read-only health).

func (*Driver) MigrateRelationCardinality 

func (d *Driver) MigrateRelationCardinality(ctx context.Context, req *relationmigrate.Request) (*relationmigrate.Receipt, error)

func (*Driver) NewInsertableRelations 

func (d *Driver) NewInsertableRelations(ctx context.Context, param *models.ConnectDisconnectParam) ([]string, error)

func (*Driver) PreviewRelationCardinalityMigration 

func (d *Driver) PreviewRelationCardinalityMigration(ctx context.Context, req *relationmigrate.Request) (*relationmigrate.Preview, error)

func (*Driver) QueryMultiDocumentOfProject 

func (d *Driver) QueryMultiDocumentOfProject(ctx context.Context, param *models.CommonSystemParams) ([]*types.DefaultDocumentStructure, error)

func (*Driver) QueryMultiDocumentOfProjectBytes 

func (d *Driver) QueryMultiDocumentOfProjectBytes(ctx context.Context, param *models.CommonSystemParams) ([]byte, error)

func (*Driver) RelationshipDataLoader 

func (d *Driver) RelationshipDataLoader(ctx context.Context, param *models.CommonSystemParams, connection map[string]interface{}) (interface{}, error)

func (*Driver) RelationshipDataLoaderBytes 

func (d *Driver) RelationshipDataLoaderBytes(ctx context.Context, param *models.CommonSystemParams, connection map[string]interface{}) ([]byte, error)

func (*Driver) RenameField 

func (d *Driver) RenameField(ctx context.Context, oldFieldName string, parentField string, param *models.CommonSystemParams) error

func (*Driver) RenameModel 

func (d *Driver) RenameModel(ctx context.Context, project *models.Project, modelName, newName string) error

func (*Driver) SearchProjectAuthUsers 

func (d *Driver) SearchProjectAuthUsers(ctx context.Context, tenantID, q string, limit, offset int) ([]*models.ProjectAuthUser, int, error)

func (*Driver) SearchProjectFiles 

func (d *Driver) SearchProjectFiles(ctx context.Context, param *models.CommonSystemParams) (*models.SearchResponse[models.ProjectFile], error)

func (*Driver) SumProjectFilesSize 

func (d *Driver) SumProjectFilesSize(ctx context.Context) (int64, error)

func (*Driver) TransferProject 

func (d *Driver) TransferProject(ctx context.Context, userId, from, to string) error

func (*Driver) UpdateDocumentOfProject 

func (d *Driver) UpdateDocumentOfProject(ctx context.Context, param *models.CommonSystemParams, doc *types.DefaultDocumentStructure, replace bool) error

func (*Driver) UpdateProjectAuthUser 

func (d *Driver) UpdateProjectAuthUser(ctx context.Context, user *models.ProjectAuthUser) error

func (*Driver) VerifyRelationCardinalityMigration 

func (d *Driver) VerifyRelationCardinalityMigration(ctx context.Context, req *relationmigrate.Request) (*relationmigrate.Receipt, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.