persistence

Oct 15, 2020

Changes in this version

type IdentifiableMemoryPersistence

+ func (c *IdentifiableMemoryPersistence) GetIndexById(id interface{}) int

Jul 10, 2020

Changes in this version

type MemoryPersistence

+ MaxPageSize int

+ func (c *MemoryPersistence) Create(correlationId string, item interface{}) (result interface{}, err error)

+ func (c *MemoryPersistence) DeleteByFilter(correlationId string, filterFunc func(interface{}) bool) (err error)

+ func (c *MemoryPersistence) GetCountByFilter(correlationId string, filterFunc func(interface{}) bool) (count int64, err error)

+ func (c *MemoryPersistence) GetListByFilter(correlationId string, filterFunc func(interface{}) bool, ...) (results []interface{}, err error)

+ func (c *MemoryPersistence) GetOneRandom(correlationId string, filterFunc func(interface{}) bool) (result interface{}, err error)

+ func (c *MemoryPersistence) GetPageByFilter(correlationId string, filterFunc func(interface{}) bool, ...) (page *cdata.DataPage, err error)

May 19, 2020

Changes in this version

type IdentifiableMemoryPersistence

+ func (c *IdentifiableMemoryPersistence) GetCountByFilter(correlationId string, filterFunc func(interface{}) bool) (count int64, err error)

Feb 11, 2020

Changes in this version

+ func CloneObjectForResult(src interface{}, proto reflect.Type) interface

+ func FromIds(ids []string) []interface

+ func ToPublicArray(values []interface{}) []map[string]interface

+ func ToPublicMap(value interface{}) map[string]interface

Dec 24, 2019

Changes in this version

+ func CloneObject(item interface{}) interface

+ func CompareValues(value1 interface{}, value2 interface{}) bool

+ func GenerateObjectId(item *interface{})

+ func GetObjectId(item interface{}) interface

+ func GetProperty(obj interface{}, name string) interface

+ func SetObjectId(item *interface{}, id interface{})

+ func SetProperty(obj interface{}, name string, value interface{})

+ type FilePersistence struct

+ Persister *JsonFilePersister

+ func NewFilePersistence(prototype reflect.Type, persister *JsonFilePersister) *FilePersistence

+ func (c *FilePersistence) Configure(conf config.ConfigParams)

+ type IFilteredPageReader interface

+ GetPageByFilter func(correlation_id string, filter data.FilterParams, paging data.PagingParams, ...) (page interface{}, err error)

+ type IFilteredReader interface

+ GetListByFilter func(correlation_id string, filter data.FilterParams, sort data.SortParams) (items []interface{}, err error)

+ type IGetter interface

+ GetOneById func(correlation_id string, id interface{}) (item interface{}, err error)

+ type ILoader interface

+ Load func(correlation_id string) (items []interface{}, err error)

+ type IPartialUpdater interface

+ UpdatePartially func(correlation_id string, id interface{}, data data.AnyValueMap) (item interface{}, err error)

+ type IQuerablePageReader interface

+ GetPageByQuery func(correlation_id string, query string, paging data.PagingParams, ...) (page interface{}, err error)

+ type IQuerableReader interface

+ GetListByQuery func(correlation_id string, query string, sort data.SortParams) (items []interface{}, err error)

+ type ISaver interface

+ Save func(correlation_id string, items []interface{}) error

+ type ISetter interface

+ Set func(correlation_id string, item interface{}) (value interface{}, err error)

+ type IWriter interface

+ Create func(correlation_id string, item interface{}) (value interface{}, err error)

+ DeleteById func(correlation_id string, id interface{}) (value interface{}, err error)

+ Update func(correlation_id string, item interface{}) (value interface{}, err error)

+ type IdentifiableFilePersistence struct

+ Persister *JsonFilePersister

+ func NewIdentifiableFilePersistence(prototype reflect.Type, persister *JsonFilePersister) *IdentifiableFilePersistence

+ func (c *IdentifiableFilePersistence) Configure(config config.ConfigParams)

+ type IdentifiableMemoryPersistence struct

+ MaxPageSize int

+ func NewIdentifiableMemoryPersistence(prototype reflect.Type) (c *IdentifiableMemoryPersistence)

+ func (c *IdentifiableMemoryPersistence) Configure(config config.ConfigParams)

+ func (c *IdentifiableMemoryPersistence) Create(correlationId string, item interface{}) (result interface{}, err error)

+ func (c *IdentifiableMemoryPersistence) DeleteByFilter(correlationId string, filterFunc func(interface{}) bool) (err error)

+ func (c *IdentifiableMemoryPersistence) DeleteById(correlationId string, id interface{}) (result interface{}, err error)

+ func (c *IdentifiableMemoryPersistence) DeleteByIds(correlationId string, ids []interface{}) (err error)

+ func (c *IdentifiableMemoryPersistence) GetListByFilter(correlationId string, filterFunc func(interface{}) bool, ...) (results []interface{}, err error)

+ func (c *IdentifiableMemoryPersistence) GetListByIds(correlationId string, ids []interface{}) (result []interface{}, err error)

+ func (c *IdentifiableMemoryPersistence) GetOneById(correlationId string, id interface{}) (result interface{}, err error)

+ func (c *IdentifiableMemoryPersistence) GetOneRandom(correlationId string, filterFunc func(interface{}) bool) (result interface{}, err error)

+ func (c *IdentifiableMemoryPersistence) GetPageByFilter(correlationId string, filterFunc func(interface{}) bool, ...) (page cdata.DataPage, err error)

+ func (c *IdentifiableMemoryPersistence) Set(correlationId string, item interface{}) (result interface{}, err error)

+ func (c *IdentifiableMemoryPersistence) Update(correlationId string, item interface{}) (result interface{}, err error)

+ func (c *IdentifiableMemoryPersistence) UpdatePartially(correlationId string, id interface{}, data cdata.AnyValueMap) (result interface{}, err error)

+ type JsonFilePersister struct

+ Prototype reflect.Type

+ func NewJsonFilePersister(prototype reflect.Type, path string) *JsonFilePersister

+ func (c *JsonFilePersister) Configure(config config.ConfigParams)

+ func (c *JsonFilePersister) Load(correlation_id string) (data []interface{}, err error)

+ func (c *JsonFilePersister) Path() string

+ func (c *JsonFilePersister) Save(correlationId string, items []interface{}) error

+ func (c *JsonFilePersister) SetPath(value string)

+ type MemoryPersistence struct

+ Items []interface{}

+ Loader ILoader

+ Lock sync.RWMutex

+ Logger *log.CompositeLogger

+ Prototype reflect.Type

+ Saver ISaver

+ func NewMemoryPersistence(prototype reflect.Type) *MemoryPersistence

+ func (c *MemoryPersistence) Clear(correlationId string) error

+ func (c *MemoryPersistence) Close(correlationId string) error

+ func (c *MemoryPersistence) IsOpen() bool

+ func (c *MemoryPersistence) Open(correlationId string) error

+ func (c *MemoryPersistence) Save(correlationId string) error

+ func (c *MemoryPersistence) SetReferences(references refer.IReferences)