zishuo/storm
1
0
Fork 0
mirror of https://github.com/asdine/storm.git synced 2025-11-02 23:04:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Multi tag support

Browse Source
This commit is contained in:
Asdine El Hrychy
2016-10-08 00:16:23 +02:00
parent 8aa16ec366
commit 617352c47f
7 changed files with 130 additions and 117 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
delete_struct.go
View File

@@ -15,28 +15,28 @@ func (n *node) DeleteStruct(data interface{}) error {
return ErrStructPtrNeeded
}
info, err := extract(&ref)
cfg, err := extract(&ref)
if err != nil {
return err
}
id, err := toBytes(info.ID.Value.Interface(), n.s.codec)
id, err := toBytes(cfg.ID.Value.Interface(), n.s.codec)
if err != nil {
return err
}
return n.readWriteTx(func(tx *bolt.Tx) error {
return n.deleteStruct(tx, info, id)
return n.deleteStruct(tx, cfg, id)
})
}
func (n *node) deleteStruct(tx *bolt.Tx, info *modelInfo, id []byte) error {
bucket := n.GetBucket(tx, info.Name)
func (n *node) deleteStruct(tx *bolt.Tx, cfg *structConfig, id []byte) error {
bucket := n.GetBucket(tx, cfg.Name)
if bucket == nil {
return ErrNotFound
}
for fieldName, idxInfo := range info.Indexes {
for fieldName, idxInfo := range cfg.Fields {
idx, err := getIndex(bucket, idxInfo.Type, fieldName)
if err != nil {
return err