mongo

package
v0.0.0-...-b482172 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2025 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init 

func Init(r *repo.Container) error

func New 

func New(ctx context.Context, mc *mongo.Client, databaseName string, useTransaction bool, acRepo *accountrepo.Container) (*repo.Container, error)

func NewAsset 

func NewAsset(client *mongox.Client) repo.Asset

func NewAssetFile 

func NewAssetFile(client *mongox.Client) repo.AssetFile

func NewAssetUpload 

func NewAssetUpload(client *mongox.Client) repo.AssetUpload

func NewEvent 

func NewEvent(client *mongox.Client) repo.Event

func NewGroup 

func NewGroup(client *mongox.Client) repo.Group

func NewIntegration 

func NewIntegration(client *mongox.Client) repo.Integration

func NewItem 

func NewItem(client *mongox.Client) repo.Item

func NewLock 

func NewLock(c *mongo.Collection) (repo.Lock, error)

func NewModel 

func NewModel(client *mongox.Client) repo.Model

func NewProject 

func NewProject(client *mongox.Client) repo.Project

func NewRequest 

func NewRequest(client *mongox.Client) repo.Request

func NewSchema 

func NewSchema(client *mongox.Client) repo.Schema

func NewThread 

func NewThread(client *mongox.Client) repo.Thread

func NewView 

func NewView(client *mongox.Client) repo.View

func NewWithDB 

func NewWithDB(ctx context.Context, db *mongo.Database, useTransaction bool, acRepo *accountrepo.Container) (*repo.Container, error)

func NewWorkspaceSettings 

func NewWorkspaceSettings(client *mongox.Client) repo.WorkspaceSettings

Types

type Asset 

type Asset struct {
	// contains filtered or unexported fields
}

func (*Asset) Delete 

func (r *Asset) Delete(ctx context.Context, id id.AssetID) error

func (*Asset) Filtered 

func (r *Asset) Filtered(f repo.ProjectFilter) repo.Asset

func (*Asset) FindByID 

func (r *Asset) FindByID(ctx context.Context, id id.AssetID) (*asset.Asset, error)

func (*Asset) FindByIDs 

func (r *Asset) FindByIDs(ctx context.Context, ids id.AssetIDList) ([]*asset.Asset, error)

func (*Asset) FindByProject 

func (r *Asset) FindByProject(ctx context.Context, id id.ProjectID, uFilter repo.AssetFilter) ([]*asset.Asset, *usecasex.PageInfo, error)

func (*Asset) Init 

func (r *Asset) Init() error

func (*Asset) Save 

func (r *Asset) Save(ctx context.Context, asset *asset.Asset) error

func (*Asset) UpdateProject 

func (r *Asset) UpdateProject(ctx context.Context, from, to id.ProjectID) error

type AssetFile 

type AssetFile struct {
	// contains filtered or unexported fields
}

func (*AssetFile) Filtered 

func (r *AssetFile) Filtered(f repo.ProjectFilter) repo.Asset

func (*AssetFile) FindByID 

func (r *AssetFile) FindByID(ctx context.Context, id id.AssetID) (*asset.File, error)

func (*AssetFile) FindByIDs 

func (r *AssetFile) FindByIDs(ctx context.Context, ids id.AssetIDList) (map[id.AssetID]*asset.File, error)

func (*AssetFile) Init 

func (r *AssetFile) Init() error

func (*AssetFile) Save 

func (r *AssetFile) Save(ctx context.Context, id id.AssetID, file *asset.File) error

func (*AssetFile) SaveFlat 

func (r *AssetFile) SaveFlat(ctx context.Context, id id.AssetID, parent *asset.File, files []*asset.File) error

type AssetUpload 

type AssetUpload struct {
	// contains filtered or unexported fields
}

func (*AssetUpload) FindByID 

func (r *AssetUpload) FindByID(ctx context.Context, uuid string) (*asset.Upload, error)

func (*AssetUpload) Init 

func (r *AssetUpload) Init() error

func (*AssetUpload) Save 

func (r *AssetUpload) Save(ctx context.Context, upload *asset.Upload) error

type Event 

type Event struct {
	// contains filtered or unexported fields
}

func (*Event) FindByID 

func (r *Event) FindByID(ctx context.Context, eventID id.EventID) (*event.Event[any], error)

func (*Event) Init 

func (r *Event) Init() error

func (*Event) Save 

func (r *Event) Save(ctx context.Context, ev *event.Event[any]) error

func (*Event) SaveAll 

func (r *Event) SaveAll(ctx context.Context, ev event.List) error

type Group 

type Group struct {
	// contains filtered or unexported fields
}

func (*Group) Filtered 

func (r *Group) Filtered(filter repo.ProjectFilter) repo.Group

func (*Group) FindByID 

func (r *Group) FindByID(ctx context.Context, gid id.GroupID) (*group.Group, error)

func (*Group) FindByIDs 

func (r *Group) FindByIDs(ctx context.Context, list id.GroupIDList) (group.List, error)

func (*Group) FindByKey 

func (r *Group) FindByKey(ctx context.Context, projectID id.ProjectID, key string) (*group.Group, error)

func (*Group) FindByProject 

func (r *Group) FindByProject(ctx context.Context, pid id.ProjectID) (group.List, error)

func (*Group) Init 

func (r *Group) Init() error

func (*Group) Remove 

func (r *Group) Remove(ctx context.Context, groupID id.GroupID) error

func (*Group) Save 

func (r *Group) Save(ctx context.Context, group *group.Group) error

func (*Group) SaveAll 

func (r *Group) SaveAll(ctx context.Context, list group.List) error

type Integration 

type Integration struct {
	// contains filtered or unexported fields
}

func (*Integration) FindByID 

func (r *Integration) FindByID(ctx context.Context, integrationID id.IntegrationID) (*integration.Integration, error)

func (*Integration) FindByIDs 

func (r *Integration) FindByIDs(ctx context.Context, ids id.IntegrationIDList) (integration.List, error)

func (*Integration) FindByToken 

func (r *Integration) FindByToken(ctx context.Context, token string) (*integration.Integration, error)

func (*Integration) FindByUser 

func (r *Integration) FindByUser(ctx context.Context, userID accountdomain.UserID) (integration.List, error)

func (*Integration) Init 

func (r *Integration) Init() error

func (*Integration) Remove 

func (r *Integration) Remove(ctx context.Context, integrationID id.IntegrationID) error

func (*Integration) Save 

func (r *Integration) Save(ctx context.Context, integration *integration.Integration) error

type Item 

type Item struct {
	// contains filtered or unexported fields
}

func (*Item) Archive 

func (r *Item) Archive(ctx context.Context, id id.ItemID, pid id.ProjectID, b bool) error

func (*Item) Filtered 

func (r *Item) Filtered(f repo.ProjectFilter) repo.Item

func (*Item) FindAllVersionsByID 

func (r *Item) FindAllVersionsByID(ctx context.Context, itemID id.ItemID) (item.VersionedList, error)

func (*Item) FindAllVersionsByIDs 

func (r *Item) FindAllVersionsByIDs(ctx context.Context, ids id.ItemIDList) (item.VersionedList, error)

func (*Item) FindByAssets 

func (r *Item) FindByAssets(ctx context.Context, al id.AssetIDList, ref *version.Ref) (item.VersionedList, error)

func (*Item) FindByID 

func (r *Item) FindByID(ctx context.Context, id id.ItemID, ref *version.Ref) (item.Versioned, error)

func (*Item) FindByIDs 

func (r *Item) FindByIDs(ctx context.Context, ids id.ItemIDList, ref *version.Ref) (item.VersionedList, error)

func (*Item) FindByModel 

func (r *Item) FindByModel(ctx context.Context, modelID id.ModelID, ref *version.Ref, sort *usecasex.Sort, pagination *usecasex.Pagination) (item.VersionedList, *usecasex.PageInfo, error)

func (*Item) FindByModelAndValue 

func (r *Item) FindByModelAndValue(ctx context.Context, modelID id.ModelID, fields []repo.FieldAndValue, ref *version.Ref) (item.VersionedList, error)

func (*Item) FindBySchema 

func (r *Item) FindBySchema(ctx context.Context, schemaID id.SchemaID, ref *version.Ref, sort *usecasex.Sort, pagination *usecasex.Pagination) (item.VersionedList, *usecasex.PageInfo, error)

func (*Item) FindVersionByID 

func (r *Item) FindVersionByID(ctx context.Context, itemID id.ItemID, ver version.VersionOrRef) (item.Versioned, error)

func (*Item) Init 

func (r *Item) Init() error

func (*Item) IsArchived 

func (r *Item) IsArchived(ctx context.Context, id id.ItemID) (bool, error)

func (*Item) LastModifiedByModel 

func (r *Item) LastModifiedByModel(ctx context.Context, modelID id.ModelID) (time.Time, error)

func (*Item) Remove 

func (r *Item) Remove(ctx context.Context, id id.ItemID) error

func (*Item) Save 

func (r *Item) Save(ctx context.Context, item *item.Item) error

func (*Item) SaveAll 

func (r *Item) SaveAll(ctx context.Context, items item.List) error

func (*Item) Search 

func (r *Item) Search(ctx context.Context, sp schema.Package, query *item.Query, pagination *usecasex.Pagination) (item.VersionedList, *usecasex.PageInfo, error)

func (*Item) UpdateRef 

func (r *Item) UpdateRef(ctx context.Context, item id.ItemID, ref version.Ref, vr *version.VersionOrRef) error

type Lock 

type Lock struct {
	// contains filtered or unexported fields
}

func (*Lock) Lock 

func (r *Lock) Lock(ctx context.Context, name string) error

func (*Lock) Unlock 

func (r *Lock) Unlock(ctx context.Context, name string) error

type Model 

type Model struct {
	// contains filtered or unexported fields
}

func (*Model) CountByProject 

func (r *Model) CountByProject(ctx context.Context, projectID id.ProjectID) (int, error)

func (*Model) Filtered 

func (r *Model) Filtered(f repo.ProjectFilter) repo.Model

func (*Model) FindByID 

func (r *Model) FindByID(ctx context.Context, modelID id.ModelID) (*model.Model, error)

func (*Model) FindByIDOrKey 

func (r *Model) FindByIDOrKey(ctx context.Context, projectID id.ProjectID, q model.IDOrKey) (*model.Model, error)

func (*Model) FindByIDs 

func (r *Model) FindByIDs(ctx context.Context, ids id.ModelIDList) (model.List, error)

func (*Model) FindByKey 

func (r *Model) FindByKey(ctx context.Context, projectID id.ProjectID, key string) (*model.Model, error)

func (*Model) FindByProject 

func (r *Model) FindByProject(ctx context.Context, pid id.ProjectID, pagination *usecasex.Pagination) (model.List, *usecasex.PageInfo, error)

func (*Model) FindByProjectAndKeyword 

func (r *Model) FindByProjectAndKeyword(ctx context.Context, pid id.ProjectID, k string, pagination *usecasex.Pagination) (model.List, *usecasex.PageInfo, error)

func (*Model) FindBySchema 

func (r *Model) FindBySchema(ctx context.Context, schemaID id.SchemaID) (*model.Model, error)

func (*Model) Init 

func (r *Model) Init() error

func (*Model) Remove 

func (r *Model) Remove(ctx context.Context, modelID id.ModelID) error

func (*Model) Save 

func (r *Model) Save(ctx context.Context, model *model.Model) error

func (*Model) SaveAll 

func (r *Model) SaveAll(ctx context.Context, list model.List) error

type ProjectRepo 

type ProjectRepo struct {
	// contains filtered or unexported fields
}

func (*ProjectRepo) CountByWorkspace 

func (r *ProjectRepo) CountByWorkspace(ctx context.Context, workspace accountdomain.WorkspaceID) (int, error)

func (*ProjectRepo) Filtered 

func (r *ProjectRepo) Filtered(f repo.WorkspaceFilter) repo.Project

func (*ProjectRepo) FindByID 

func (r *ProjectRepo) FindByID(ctx context.Context, id id.ProjectID) (*project.Project, error)

func (*ProjectRepo) FindByIDOrAlias 

func (r *ProjectRepo) FindByIDOrAlias(ctx context.Context, id project.IDOrAlias) (*project.Project, error)

func (*ProjectRepo) FindByIDs 

func (r *ProjectRepo) FindByIDs(ctx context.Context, ids id.ProjectIDList) (project.List, error)

func (*ProjectRepo) FindByPublicAPIToken 

func (r *ProjectRepo) FindByPublicAPIToken(ctx context.Context, token string) (*project.Project, error)

func (*ProjectRepo) FindByPublicName 

func (r *ProjectRepo) FindByPublicName(ctx context.Context, name string) (*project.Project, error)

func (*ProjectRepo) FindByWorkspaces 

func (r *ProjectRepo) FindByWorkspaces(ctx context.Context, ids accountdomain.WorkspaceIDList, pagination *usecasex.Pagination) (project.List, *usecasex.PageInfo, error)

func (*ProjectRepo) Init 

func (r *ProjectRepo) Init() error

func (*ProjectRepo) Remove 

func (r *ProjectRepo) Remove(ctx context.Context, id id.ProjectID) error

func (*ProjectRepo) Save 

func (r *ProjectRepo) Save(ctx context.Context, project *project.Project) error

type Request 

type Request struct {
	// contains filtered or unexported fields
}

func (*Request) Filtered 

func (r *Request) Filtered(f repo.ProjectFilter) repo.Request

func (*Request) FindByID 

func (r *Request) FindByID(ctx context.Context, id id.RequestID) (*request.Request, error)

func (*Request) FindByIDs 

func (r *Request) FindByIDs(ctx context.Context, ids id.RequestIDList) (request.List, error)

func (*Request) FindByItems 

func (r *Request) FindByItems(ctx context.Context, list id.ItemIDList, uFilter *repo.RequestFilter) (request.List, error)

func (*Request) FindByProject 

func (r *Request) FindByProject(ctx context.Context, id id.ProjectID, uFilter repo.RequestFilter, sort *usecasex.Sort, page *usecasex.Pagination) (request.List, *usecasex.PageInfo, error)

func (*Request) Init 

func (r *Request) Init() error

func (*Request) Remove 

func (r *Request) Remove(ctx context.Context, id id.RequestID) error

func (*Request) Save 

func (r *Request) Save(ctx context.Context, request *request.Request) error

func (*Request) SaveAll 

func (r *Request) SaveAll(ctx context.Context, pid id.ProjectID, requests request.List) error

type Schema 

type Schema struct {
	// contains filtered or unexported fields
}

func (*Schema) Filtered 

func (r *Schema) Filtered(f repo.WorkspaceFilter) repo.Schema

func (*Schema) FindByID 

func (r *Schema) FindByID(ctx context.Context, schemaID id.SchemaID) (*schema.Schema, error)

func (*Schema) FindByIDs 

func (r *Schema) FindByIDs(ctx context.Context, ids id.SchemaIDList) (schema.List, error)

func (*Schema) Init 

func (r *Schema) Init() error

func (*Schema) Remove 

func (r *Schema) Remove(ctx context.Context, schemaID id.SchemaID) error

func (*Schema) Save 

func (r *Schema) Save(ctx context.Context, schema *schema.Schema) error

type ThreadRepo 

type ThreadRepo struct {
	// contains filtered or unexported fields
}

func (*ThreadRepo) Filtered 

func (r *ThreadRepo) Filtered(f repo.WorkspaceFilter) repo.Thread

func (*ThreadRepo) FindByID 

func (r *ThreadRepo) FindByID(ctx context.Context, id id.ThreadID) (*thread.Thread, error)

func (*ThreadRepo) FindByIDs 

func (r *ThreadRepo) FindByIDs(ctx context.Context, ids id.ThreadIDList) ([]*thread.Thread, error)

func (*ThreadRepo) Init 

func (r *ThreadRepo) Init() error

func (*ThreadRepo) Save 

func (r *ThreadRepo) Save(ctx context.Context, thread *thread.Thread) error

func (*ThreadRepo) SaveAll 

func (r *ThreadRepo) SaveAll(ctx context.Context, threads thread.List) error

type View 

type View struct {
	// contains filtered or unexported fields
}

func (*View) Filtered 

func (r *View) Filtered(f repo.ProjectFilter) repo.View

func (*View) FindByID 

func (r *View) FindByID(ctx context.Context, viewID id.ViewID) (*view.View, error)

func (*View) FindByIDs 

func (r *View) FindByIDs(ctx context.Context, ids id.ViewIDList) (view.List, error)

func (*View) FindByModel 

func (r *View) FindByModel(ctx context.Context, modelID view.ModelID) (view.List, error)

func (*View) Init 

func (r *View) Init() error

func (*View) Remove 

func (r *View) Remove(ctx context.Context, viewID id.ViewID) error

func (*View) Save 

func (r *View) Save(ctx context.Context, view *view.View) error

func (*View) SaveAll 

func (r *View) SaveAll(ctx context.Context, list view.List) error

type WorkspaceSettingsRepo 

type WorkspaceSettingsRepo struct {
	// contains filtered or unexported fields
}

func (*WorkspaceSettingsRepo) Filtered 

func (r *WorkspaceSettingsRepo) Filtered(f repo.WorkspaceFilter) repo.WorkspaceSettings

func (*WorkspaceSettingsRepo) FindByID 

func (r *WorkspaceSettingsRepo) FindByID(ctx context.Context, wid accountdomain.WorkspaceID) (*workspacesettings.WorkspaceSettings, error)

func (*WorkspaceSettingsRepo) FindByIDs 

func (r *WorkspaceSettingsRepo) FindByIDs(ctx context.Context, ids accountdomain.WorkspaceIDList) (workspacesettings.List, error)

func (*WorkspaceSettingsRepo) Init 

func (r *WorkspaceSettingsRepo) Init() error

func (*WorkspaceSettingsRepo) Remove 

func (r *WorkspaceSettingsRepo) Remove(ctx context.Context, wid accountdomain.WorkspaceID) error

func (*WorkspaceSettingsRepo) Save 

func (r *WorkspaceSettingsRepo) Save(ctx context.Context, ws *workspacesettings.WorkspaceSettings) error

Source Files

View all Source files

Directories

Path Synopsis

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.