repoimpl

package

Go to main page

Versions in this module

v0

v0.1.6

Mar 16, 2021

v0.1.5

Feb 25, 2021

v0.1.4

Feb 25, 2021

Changes in this version

+ type BBoltBaseTag struct

+ func NewBBoltBaseTag(b *bolt.DB, bucketName string) *BBoltBaseTag

+ func (b *BBoltBaseTag) Add(ws model.WSName, unregisteredTag *model.UnregisteredUnindexedTag) (*model.Tag, error)

+ func (b *BBoltBaseTag) AddByName(ws model.WSName, tagName string) (*model.Tag, bool, error)

+ func (b *BBoltBaseTag) AddByNames(ws model.WSName, tagNames []string) ([]*model.Tag, error)

+ func (b *BBoltBaseTag) AddWithIndex(ws model.WSName, unregisteredTagWithIndex *model.UnregisteredTag) (*model.Tag, error)

+ func (b *BBoltBaseTag) Delete(ws model.WSName, idList []model.TagID) error

+ func (b *BBoltBaseTag) ForEach(ws model.WSName, f func(tagWithIndex *model.Tag) error) error

+ func (b *BBoltBaseTag) Get(ws model.WSName, id model.TagID) (tagWithIndex *model.Tag, exist bool, err error)

+ func (b *BBoltBaseTag) ListAll(ws model.WSName) (assets []*model.Tag, err error)

+ func (b *BBoltBaseTag) ListAsSet(ws model.WSName) (set *model.TagSet, err error)

+ func (b *BBoltBaseTag) ListBy(ws model.WSName, f func(tag *model.Tag) bool) (assets []*model.Tag, err error)

+ func (b *BBoltBaseTag) ListByAsync(ws model.WSName, f func(tagWithIndex *model.Tag) bool, cap int) (assetChan <-chan *model.Tag, err error)

+ func (b *BBoltBaseTag) Save(ws model.WSName, tagWithIndex *model.Tag) (*model.Tag, error)

type BBoltTag

+ func (b *BBoltTag) AddWithIndex(ws model.WSName, tagWithIndex *model.UnregisteredTag) (*model.Tag, error)

v0.1.3

Feb 7, 2021

Changes in this version

type BBoltAsset

+ func (b *BBoltAsset) BatchUpdateByID(ws model.WSName, assets []*model.Asset) (updatedAssets, skippedAssets []*model.Asset, err error)

+ func (b *BBoltAsset) BatchUpdateByPath(ws model.WSName, assets []*model.Asset) (updatedAssets, skippedAssets []*model.Asset, err error)

+ func (b *BBoltAsset) Close() error

+ func (b *BBoltAsset) ListAsync(ctx context.Context, ws model.WSName, cap int) (assetChan <-chan *model.Asset, err error)

+ func (b *BBoltAsset) ListByIDList(ws model.WSName, idList []model.AssetID) (assets []*model.Asset, err error)

+ func (b *BBoltAsset) ListByIDListAsync(ctx context.Context, ws model.WSName, idList []model.AssetID, cap int) (assetChan <-chan *model.Asset, errChan <-chan error, err error)

+ func (b *BBoltAsset) ListByPaths(ws model.WSName, paths []string) (assets []*model.Asset, err error)

v0.1.2

Dec 9, 2020

v0.1.1

Dec 9, 2020

Changes in this version

type BBoltAsset

+ func (b *BBoltAsset) BatchAdd(ws model.WSName, assets []*model.Asset) ([]model.AssetID, error)

type BBoltTag

+ func (b *BBoltTag) AddByName(ws model.WSName, tagName string) (model.TagID, bool, error)

+ func (b *BBoltTag) AddByNames(ws model.WSName, tagNames []string) ([]model.TagID, error)

v0.1.0

Nov 15, 2020

Changes in this version

+ func NewBBoltAsset(b *bolt.DB) repository.Asset

+ func NewBBoltTag(b *bolt.DB) repository.Tag

+ func NewBBoltWorkSpace(b *bolt.DB) repository.WorkSpace

+ func NewBoltMeta(b *bolt.DB) repository.Meta

+ type BBoltAsset struct

+ func (b *BBoltAsset) Add(ws model.WSName, asset *model.Asset) (model.AssetID, error)

+ func (b *BBoltAsset) AddByFilePathIfDoesNotExist(ws model.WSName, filePath string) (model.AssetID, bool, error)

+ func (b *BBoltAsset) AddByFilePathListIfDoesNotExist(ws model.WSName, filePathList []string) ([]model.AssetID, error)

+ func (b *BBoltAsset) AddList(ws model.WSName, assets []*model.Asset) ([]model.AssetID, error)

+ func (b *BBoltAsset) BatchUpdate(ws model.WSName, assets []*model.Asset) error

+ func (b *BBoltAsset) Delete(ws model.WSName, id model.AssetID) error

+ func (b *BBoltAsset) ForEach(ws model.WSName, f func(asset *model.Asset) error) error

+ func (b *BBoltAsset) Get(ws model.WSName, id model.AssetID) (asset *model.Asset, exist bool, err error)

+ func (b *BBoltAsset) GetByPath(ws model.WSName, path string) (asset *model.Asset, exist bool, err error)

+ func (b *BBoltAsset) Has(ws model.WSName, id model.AssetID) (ok bool, err error)

+ func (b *BBoltAsset) Init(ws model.WSName) error

+ func (b *BBoltAsset) List(ctx context.Context, ws model.WSName, cap int) (assetChan <-chan *model.Asset, err error)

+ func (b *BBoltAsset) ListBy(ws model.WSName, f func(asset *model.Asset) bool) (assets []*model.Asset, err error)

+ func (b *BBoltAsset) ListByAsync(ctx context.Context, ws model.WSName, f func(asset *model.Asset) bool, cap int) (assetChan <-chan *model.Asset, err error)

+ func (b *BBoltAsset) ListByTags(ws model.WSName, tags []model.Tag) (assets []*model.Asset, err error)

+ func (b *BBoltAsset) ListRawByAsync(ctx context.Context, ws model.WSName, f func(v []byte) bool, cap int) (vc <-chan []byte, err error)

+ func (b *BBoltAsset) Revalidate(ws model.WSName) error

+ func (b *BBoltAsset) Update(ws model.WSName, asset *model.Asset) error

+ type BBoltTag struct

+ func (b *BBoltTag) Add(ws model.WSName, tagWithIndex *model.TagWithIndex) (model.TagID, error)

+ func (b *BBoltTag) ForEach(ws model.WSName, f func(tagWithIndex *model.TagWithIndex) error) error

+ func (b *BBoltTag) Get(ws model.WSName, id model.TagID) (tagWithIndex *model.TagWithIndex, exist bool, err error)

+ func (b *BBoltTag) Init(ws model.WSName) error

+ func (b *BBoltTag) ListAll(ws model.WSName) (assets []*model.TagWithIndex, err error)

+ func (b *BBoltTag) ListAsSet(ws model.WSName) (set *model.TagSet, err error)

+ func (b *BBoltTag) ListBy(ws model.WSName, f func(tag *model.TagWithIndex) bool) (assets []*model.TagWithIndex, err error)

+ func (b *BBoltTag) ListByAsync(ws model.WSName, f func(tagWithIndex *model.TagWithIndex) bool, cap int) (assetChan <-chan *model.TagWithIndex, err error)

+ func (b *BBoltTag) RecreateBucket(ws model.WSName) error

+ func (b *BBoltTag) Update(ws model.WSName, tagWithIndex *model.TagWithIndex) error

+ type BBoltWorkSpace struct

+ func (b *BBoltWorkSpace) Add(ws *model.WorkSpace) error

+ func (b *BBoltWorkSpace) Init() error

+ func (b *BBoltWorkSpace) List() (workspaces []*model.WorkSpace, err error)

+ func (b *BBoltWorkSpace) Update(ws *model.WorkSpace) error

+ type BoltMeta struct

+ func (b *BoltMeta) GetDBVersion() (v *semver.Version, exist bool, err error)

+ func (b *BoltMeta) Init() error

+ func (b *BoltMeta) SetDBVersion(version *semver.Version) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL