datastore

May 31, 2022

Changes in this version

+ const FileSytemBinaryStoreID

+ var BinaryDataStoreProviders = cloudy.NewProviderRegistry[BinaryDataStore]()

+ var IndexerProviders = cloudy.NewProviderRegistry[Indexer[any]]()

+ var InvalidConfiguration = errors.New("invalid configuration object")

+ var JsonDataStoreProviders = cloudy.NewProviderRegistry[JsonDataStore[any]]()

+ func BinaryDataStoreTest(t *testing.T, ctx context.Context, ds BinaryDataStore)

+ func JsonDataStoreTest(t *testing.T, ctx context.Context, ds JsonDataStore[TestItem])

+ func QueryJsonDataStoreTest(t *testing.T, ctx context.Context, ds JsonDataStore[TestQueryItem])

+ type FilesystemStoreConfig struct

+ Dir string

+ Ext string

+ Perms os.FileMode

+ type TestItem struct

+ ID string

+ Name string

+ type TestQueryItem struct

+ Date1 time.Time

+ Date2 time.Time

+ ID string

+ Name string

+ ObjArr []*TestQueryItemChild

+ StrArr []string

+ Val1 int

+ Val2 int

+ type TestQueryItemChild struct

+ Name string

May 23, 2022

Changes in this version

+ var PrefixSeparator = "-"

+ var RootFSDir = ""

+ type AfterGetInterceptor interface

+ AfterGet func(ctx context.Context, dt *Datatype[T], item *T) (*T, error)

+ type AfterSaveInterceptor interface

+ AfterSave func(ctx context.Context, dt *Datatype[T], item *T) (*T, error)

+ type BeforeGetInterceptor interface

+ BeforeGet func(ctx context.Context, dt *Datatype[T], ID string) (string, error)

+ type BeforeSaveInterceptor interface

+ BeforeSave func(ctx context.Context, dt *Datatype[T], item *T) (*T, error)

+ type BinaryDataStore interface

+ Close func(ctx context.Context) error

+ Delete func(ctx context.Context, key string) error

+ Exists func(ctx context.Context, key string) (bool, error)

+ Get func(ctx context.Context, key string) ([]byte, error)

+ Open func(ctx context.Context, config interface{}) error

+ Save func(ctx context.Context, data []byte, key string) error

+ SaveStream func(ctx context.Context, data io.ReadCloser, key string) (int64, error)

+ type Datatype struct

+ AfterGet []AfterGetInterceptor[T]

+ AfterSave []AfterSaveInterceptor[T]

+ BeforeGet []BeforeGetInterceptor[T]

+ BeforeSave []BeforeSaveInterceptor[T]

+ DataStore JsonDataStore[T]

+ GetIDFunc func(dt *Datatype[T], item interface{}) string

+ IDField string

+ Indexer Indexer[T]

+ ItemType interface{}

+ Name string

+ Prefix string

+ SetIDFunc func(dt *Datatype[T], item interface{}, id string) string

+ func (dt *Datatype[T]) Delete(ctx context.Context, key string) error

+ func (dt *Datatype[T]) Exists(ctx context.Context, id string) (bool, error)

+ func (dt *Datatype[T]) GenerateID() string

+ func (dt *Datatype[T]) Get(ctx context.Context, ID string) (*T, error)

+ func (dt *Datatype[T]) GetAll(ctx context.Context) ([]*T, error)

+ func (dt *Datatype[T]) GetID(ctx context.Context, item *T) string

+ func (dt *Datatype[T]) GetRaw(ctx context.Context, ID string) (*T, error)

+ func (dt *Datatype[T]) Initialize(ctx context.Context) error

+ func (dt *Datatype[T]) NativeQuery(ctx context.Context, query interface{}) ([]T, error)

+ func (dt *Datatype[T]) Query(ctx context.Context, query *SimpleQuery) ([]*T, error)

+ func (dt *Datatype[T]) Save(ctx context.Context, item *T) (*T, error)

+ func (dt *Datatype[T]) SaveRaw(ctx context.Context, item *T) (*T, error)

+ func (dt *Datatype[T]) SetID(ctx context.Context, item interface{}, id string)

+ func (dt *Datatype[T]) Shutdown(ctx context.Context) error

+ type DatatypeCollection struct

+ var Datatypes *DatatypeCollection

+ func NewDatatypeCollection() *DatatypeCollection

+ func (dtc *DatatypeCollection) Add(dt *Datatype[any]) error

+ func (dtc *DatatypeCollection) FindByName(name string) *Datatype[any]

+ func (dtc *DatatypeCollection) FindByPrefix(prefix string) *Datatype[any]

+ func (dtc *DatatypeCollection) FindForId(id string) *Datatype[any]

+ func (dtc *DatatypeCollection) Initialize(ctx context.Context) error

+ func (dtc *DatatypeCollection) Shutdown(ctx context.Context)

+ type FilesystemStore struct

+ Dir string

+ Ext string

+ Perms os.FileMode

+ func NewFilesystemStore(ext string, dir ...string) *FilesystemStore

+ func (fs *FilesystemStore) Close(ctx context.Context) error

+ func (fs *FilesystemStore) Delete(ctx context.Context, key string) error

+ func (fs *FilesystemStore) Exists(ctx context.Context, key string) (bool, error)

+ func (fs *FilesystemStore) Get(ctx context.Context, key string) ([]byte, error)

+ func (fs *FilesystemStore) Init() error

+ func (fs *FilesystemStore) Open(ctx context.Context, config interface{}) error

+ func (fs *FilesystemStore) Save(ctx context.Context, data []byte, key string) error

+ func (fs *FilesystemStore) SaveStream(ctx context.Context, data io.ReadCloser, key string) (int64, error)

+ type Filetype struct

+ type IdGenerator struct

+ func (idgen *IdGenerator[T]) BeforeSave(ctx context.Context, dt *Datatype[T], item *T) (*T, error)

+ type InMemoryStore struct

+ func NewInMemoryStore() *InMemoryStore

+ func (mem *InMemoryStore) Close(ctx context.Context) error

+ func (mem *InMemoryStore) Delete(ctx context.Context, key string) error

+ func (mem *InMemoryStore) Exists(ctx context.Context, key string) (bool, error)

+ func (mem *InMemoryStore) Get(ctx context.Context, key string) ([]byte, error)

+ func (mem *InMemoryStore) Open(ctx context.Context, config interface{}) error

+ func (mem *InMemoryStore) Save(ctx context.Context, data []byte, key string) error

+ func (mem *InMemoryStore) SaveStream(ctx context.Context, data io.ReadCloser, key string) (int64, error)

+ type Indexer interface

+ Close func(ctx context.Context) error

+ Index func(ctx context.Context, id string, data []byte) error

+ Open func(ctx context.Context, config interface{}) error

+ Remove func(ctx context.Context, id string) error

+ Search func(ctx context.Context, query interface{}) ([]T, error)

+ type JsonDataStore interface

+ Close func(ctx context.Context) error

+ Delete func(ctx context.Context, key string) error

+ Exists func(ctx context.Context, key string) (bool, error)

+ Get func(ctx context.Context, key string) (*T, error)

+ GetAll func(ctx context.Context) ([]*T, error)

+ Open func(ctx context.Context, config interface{}) error

+ Query func(ctx context.Context, query *SimpleQuery) ([]*T, error)

+ Save func(ctx context.Context, item *T, key string) error

+ type JsonDataStoreAdapter struct

+ DS BinaryDataStore

+ Model T

+ func ToJsonDataStore(ds BinaryDataStore) *JsonDataStoreAdapter[T]

+ func (j *JsonDataStoreAdapter[T]) Get(ctx context.Context, key string) (T, error)

+ func (j *JsonDataStoreAdapter[T]) Save(ctx context.Context, item T, key string) error

+ type LoadInput struct

+ Ctx context.Context

+ Id string

+ User string

+ type LoadOutput struct

+ Ctx context.Context

+ Id string

+ Item interface{}

+ User string

+ type NativeQuerable interface

+ NativeQuery func(ctx context.Context, query interface{}) (interface{}, error)

+ type SimpleQuery struct

+ Colums []string

+ Conditions *SimpleQueryConditionGroup

+ Offset int

+ Size int

+ SortBy []*SortBy

+ func NewQuery() *SimpleQuery

+ type SimpleQueryCondition struct

+ Data []string

+ DataMap map[string]interface{}

+ Type string

+ func (sqc *SimpleQueryCondition) GetDate(key string) (val time.Time)

+ func (sqc *SimpleQueryCondition) GetFloat(key string) float64

+ func (sqc *SimpleQueryCondition) GetInt(key string) int

+ func (sqc *SimpleQueryCondition) GetString(key string) string

+ func (sqc *SimpleQueryCondition) GetStringArr(key string) []string

+ func (sqc *SimpleQueryCondition) Set(key string, value interface{})

+ type SimpleQueryConditionGroup struct

+ Conditions []*SimpleQueryCondition

+ Groups []*SimpleQueryConditionGroup

+ Operator string

+ func (cg *SimpleQueryConditionGroup) After(field string, value time.Time)

+ func (cg *SimpleQueryConditionGroup) And() *SimpleQueryConditionGroup

+ func (cg *SimpleQueryConditionGroup) Before(field string, value time.Time)

+ func (cg *SimpleQueryConditionGroup) Between(field string, gte string, lte string)

+ func (cg *SimpleQueryConditionGroup) Contains(field string, value string)

+ func (cg *SimpleQueryConditionGroup) Equals(field string, value string)

+ func (cg *SimpleQueryConditionGroup) Exists(field string, value string)

+ func (cg *SimpleQueryConditionGroup) GreaterThan(field string, value string)

+ func (cg *SimpleQueryConditionGroup) GreaterThanOrEqual(field string, value string)

+ func (cg *SimpleQueryConditionGroup) Includes(field string, values []string)

+ func (cg *SimpleQueryConditionGroup) LessThan(field string, value string)

+ func (cg *SimpleQueryConditionGroup) LessThanOrEqual(field string, value string)

+ func (cg *SimpleQueryConditionGroup) Not() *SimpleQueryConditionGroup

+ func (cg *SimpleQueryConditionGroup) Or() *SimpleQueryConditionGroup

+ type SortBy struct

+ Descending bool

+ Field string