Documentation ¶
Index ¶
- Constants
- type AppendBucket
- func (ab *AppendBucket) Delete(filePaths, queries []string, data *gjson.Result) (recordsDeletedCnt int, errList []error)
- func (ab *AppendBucket) Find(filePaths []string, queries []string, data *gjson.Result) (string, error)
- func (ab *AppendBucket) Insert(filePath string, data *gjson.Result) error
- func (ab *AppendBucket) Update(filePaths []string, queries []string, data *gjson.Result) (*gjson.Result, []error)
- type Bucket
- type MediaStore
- type PackBucket
- func (pb *PackBucket) Delete(filePaths []string, queries []string, data *gjson.Result) (int, []error)
- func (pb *PackBucket) DeleteMedia(filePath string, recordID string) error
- func (pb *PackBucket) Find(filePaths []string, queries []string, data *gjson.Result) (string, error)
- func (pb *PackBucket) Insert(filePath string, data *gjson.Result) error
- func (pb *PackBucket) ReadMedia(filePath string, recordID string) ([]byte, *gjson.Result, error)
- func (pb *PackBucket) Reorg(filePaths []string) (errList []error)
- func (pb *PackBucket) ReorgFile(filePath string) error
- func (pb *PackBucket) Update(filePaths []string, queries []string, data *gjson.Result) (*gjson.Result, []error)
- func (pb *PackBucket) UpdateMedia(filePath string, recordID string, mediaData []byte, rs *gjson.Result) error
- func (pb *PackBucket) UpsertMedia(filePath string, recordID string, mediaData []byte, rs *gjson.Result) (string, error)
- func (pb *PackBucket) WriteMedia(filePath string, mediaData []byte, rs *gjson.Result) (string, error)
- type PathProvider
- type Securable
- type SimpleBucket
- func (sb *SimpleBucket) Delete(filePaths, queries []string, data *gjson.Result) (recordsDeletedCnt int, errList []error)
- func (sb *SimpleBucket) Find(filePaths []string, queries []string, data *gjson.Result) (string, error)
- func (sb *SimpleBucket) Insert(filePath string, data *gjson.Result) error
- func (sb *SimpleBucket) Update(filePaths []string, queries []string, data *gjson.Result) (*gjson.Result, []error)
- type Store
Constants ¶
View Source
const ( PathSeperator = "/" DynamicPathPrefix = "$$" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppendBucket ¶
type AppendBucket struct {
Bucket
}
func NewAppendBucket ¶
func (*AppendBucket) Delete ¶
func (*AppendBucket) Find ¶
type Bucket ¶
type Bucket struct { BucketID string `json:"bucketId"` IsDynamicName bool `json:"isDynamicName"` BucketNameQuery string `json:"bucketNameQuery"` // TODO: rename to Indexex Indexes []string `json:"indices"` BucketPath string `json:"bucketPath"` SecurityProvider securityprovider.SecurityProvider }
func (*Bucket) GetPath ¶
ResolveName - returns bucket name
func (*Bucket) Secure ¶
func (bucket *Bucket) Secure(securityprovider securityprovider.SecurityProvider)
type MediaStore ¶
type MediaStore interface { WriteMedia(filePath string, mediaData []byte, rs *gjson.Result) (string, error) ReadMedia(filePath string, recordID string) ([]byte, *gjson.Result, error) UpdateMedia(filePath string, recordID string, mediaData []byte, rs *gjson.Result) (err error) UpsertMedia(filePath string, recordID string, mediaData []byte, rs *gjson.Result) (string, error) }
type PackBucket ¶
type PackBucket struct { Bucket InFileIndexSchemaMap map[string]filetype.InFileIndex `json:"inFileIndexMap"` // contains filtered or unexported fields }
func NewPackBucket ¶
func NewPackBucket(bucketNameQuery string, isDynamicName bool, bucketPath string, inFileIndexSchemaMap map[string]filetype.InFileIndex) (*PackBucket, error)
func (*PackBucket) Delete ¶
func (*PackBucket) DeleteMedia ¶
func (pb *PackBucket) DeleteMedia(filePath string, recordID string) error
func (*PackBucket) Find ¶
func (*PackBucket) Insert ¶
func (pb *PackBucket) Insert(filePath string, data *gjson.Result) error
TODO: add fdb index data call
func (*PackBucket) ReadMedia ¶
func (*PackBucket) Reorg ¶
func (pb *PackBucket) Reorg(filePaths []string) (errList []error)
func (*PackBucket) ReorgFile ¶
func (pb *PackBucket) ReorgFile(filePath string) error
func (*PackBucket) Update ¶
func (*PackBucket) UpdateMedia ¶
func (*PackBucket) UpsertMedia ¶
type Securable ¶
type Securable interface {
Secure(securityprovider.SecurityProvider)
}
type SimpleBucket ¶
type SimpleBucket struct { Bucket // TODO: implement lazy EnableLazy bool // contains filtered or unexported fields }
func NewSimpleBucket ¶
func (*SimpleBucket) Delete ¶
func (*SimpleBucket) Find ¶
Click to show internal directories.
Click to hide internal directories.