bucket

Documentation

Index

• Constants
• type AppendBucket
  • func NewAppendBucket(bucketNameQuery string, isDynamicName bool, isLazyEnable bool, ...) (*AppendBucket, error)
  • 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
  • func (bucket *Bucket) AddIndex(index *index.Index) error
  • func (bucket *Bucket) GetPath(rs *gjson.Result) (string, error)
  • func (bucket *Bucket) Secure(securityprovider securityprovider.SecurityProvider)
• type MediaStore
• type PackBucket
  • func NewPackBucket(bucketNameQuery string, isDynamicName bool, bucketPath string, ...) (*PackBucket, error)
  • 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 NewSimpleBucket(bucketNameQuery string, isDynamicName bool, isLazyEnable bool, ...) (*SimpleBucket, error)
  • 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

const (
	PathSeperator     = "/"
	DynamicPathPrefix = "$$"
)

Types

type AppendBucket

type AppendBucket struct {
	Bucket
}

func NewAppendBucket

func NewAppendBucket(bucketNameQuery string, isDynamicName bool, isLazyEnable bool, bucketPath string) (*AppendBucket, error)

func (*AppendBucket) Delete

func (ab *AppendBucket) Delete(filePaths, queries []string, data *gjson.Result) (recordsDeletedCnt int, errList []error)

func (*AppendBucket) Find

func (ab *AppendBucket) Find(filePaths []string, queries []string, data *gjson.Result) (string, error)

func (*AppendBucket) Insert

func (ab *AppendBucket) Insert(filePath string, data *gjson.Result) error

func (*AppendBucket) Update

func (ab *AppendBucket) Update(filePaths []string, queries []string, data *gjson.Result) (*gjson.Result, []error)

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) AddIndex

func (bucket *Bucket) AddIndex(index *index.Index) error

func (*Bucket) GetPath

func (bucket *Bucket) GetPath(rs *gjson.Result) (string, error)

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 (pb *PackBucket) Delete(filePaths []string, queries []string, data *gjson.Result) (int, []error)

func (*PackBucket) DeleteMedia

func (pb *PackBucket) DeleteMedia(filePath string, recordID string) error

func (*PackBucket) Find

func (pb *PackBucket) Find(filePaths []string, queries []string, data *gjson.Result) (string, error)

func (*PackBucket) Insert

func (pb *PackBucket) Insert(filePath string, data *gjson.Result) error

TODO: add fdb index data call

func (*PackBucket) ReadMedia

func (pb *PackBucket) ReadMedia(filePath string, recordID string) ([]byte, *gjson.Result, error)

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 (pb *PackBucket) Update(filePaths []string, queries []string, data *gjson.Result) (*gjson.Result, []error)

func (*PackBucket) UpdateMedia

func (pb *PackBucket) UpdateMedia(filePath string, recordID string, mediaData []byte, rs *gjson.Result) error

func (*PackBucket) UpsertMedia

func (pb *PackBucket) UpsertMedia(filePath string, recordID string, mediaData []byte, rs *gjson.Result) (string, error)

func (*PackBucket) WriteMedia

func (pb *PackBucket) WriteMedia(filePath string, mediaData []byte, rs *gjson.Result) (string, error)

type PathProvider

type PathProvider interface {
	GetPath(rs *gjson.Result) (string, error)
}

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 NewSimpleBucket(bucketNameQuery string, isDynamicName bool, isLazyEnable bool, bucketPath string) (*SimpleBucket, error)

func (*SimpleBucket) Delete

func (sb *SimpleBucket) Delete(filePaths, queries []string, data *gjson.Result) (recordsDeletedCnt int, errList []error)

func (*SimpleBucket) Find

func (sb *SimpleBucket) Find(filePaths []string, queries []string, data *gjson.Result) (string, error)

func (*SimpleBucket) Insert

func (sb *SimpleBucket) Insert(filePath string, data *gjson.Result) error

func (*SimpleBucket) Update

func (sb *SimpleBucket) Update(filePaths []string, queries []string, data *gjson.Result) (*gjson.Result, []error)

type Store

type Store interface {
	Insert(string, *gjson.Result) error
	Find([]string, []string, *gjson.Result) (string, error)
	Update([]string, []string, *gjson.Result) (*gjson.Result, []error)
	Delete([]string, []string, *gjson.Result) (int, []error)
}