storage

Aug 24, 2023

Changes in this version

+ var ErrDataNotExist = errors.New("data not exist")

type Storage

+ func New(warehouse W) *Storage[K, D, W]

+ func (slf *Storage[K, D, W]) Create(key K, data D) error

+ func (slf *Storage[K, D, W]) Flush(errHandle func(data []byte, err error) time.Duration)

+ func (slf *Storage[K, D, W]) LoadMigrationData(data []byte) error

+ func (slf *Storage[K, D, W]) Migrate(keys ...K) (data []byte, err error)

+ func (slf *Storage[Key, D, W]) Query(key Key) (v D, err error)

+ type Warehouse interface

+ Create func(key K, data []byte) error

+ GenerateZero func() D

+ Init func() (map[K][]byte, error)

+ Query func(key K) (data []byte, err error)

+ Save func(key K, data []byte) error

Jul 25, 2023

Changes in this version

+ const DefaultBodyFieldName

+ type Data struct

+ func (slf *Data[Body]) Handle(handler func(data Body))

+ type Set struct

+ func NewSet(zero Body, getIndex func(data Body) PrimaryKey, ...) *Set[PrimaryKey, Body]

+ func (slf *Set[PrimaryKey, Body]) Get(index PrimaryKey) (*Data[Body], error)

+ func (slf *Set[PrimaryKey, Body]) New() *Data[Body]

+ func (slf *Set[PrimaryKey, Body]) Save(data *Data[Body]) error

+ func (slf *Set[PrimaryKey, Body]) Set(data *Data[Body])

+ func (slf *Set[PrimaryKey, Body]) Struct(data *Data[Body]) (any, error)

+ type SetOption func(set *Set[PrimaryKey, Body])

+ func WithBodyName(name string) SetOption[PrimaryKey, Body]

+ func WithBodyTag(tags ...string) SetOption[PrimaryKey, Body]

+ func WithIndex(name string, getValue func(data Body) Index) SetOption[PrimaryKey, Body]

+ func WithTagIndex(name string, tags []string, getValue func(data Body) Index) SetOption[PrimaryKey, Body]

+ type Storage interface

+ Load func(index PrimaryKey) (Body, error)

+ Save func(set *Set[PrimaryKey, Body], index PrimaryKey, data any) error

Jul 19, 2023

Changes in this version

+ func SaveAll(errorHandle func(err error) bool, retryInterval time.Duration)

+ type GlobalData struct

+ func NewGlobalData(name string, storage GlobalDataStorage[T]) *GlobalData[T]

+ func (slf *GlobalData[T]) GetData() T

+ func (slf *GlobalData[T]) GetName() string

+ func (slf *GlobalData[T]) Handle(handler func(name string, data T)) *GlobalData[T]

+ func (slf *GlobalData[T]) HandleWithCallback(handler func(name string, data T) error, callback func(err error)) *GlobalData[T]

+ func (slf *GlobalData[T]) LoadData()

+ func (slf *GlobalData[T]) SaveData() error

+ type GlobalDataStorage interface

+ Load func(name string) T

+ Save func(name string, data T) error

+ type IndexData struct

+ func NewIndexData(name string, storage IndexDataStorage[I, T]) *IndexData[I, T]

+ func (slf *IndexData[I, T]) DeleteAllData() *IndexData[I, T]

+ func (slf *IndexData[I, T]) DeleteData(index I) *IndexData[I, T]

+ func (slf *IndexData[I, T]) GetAllData() map[I]T

+ func (slf *IndexData[I, T]) GetData(index I) T

+ func (slf *IndexData[I, T]) GetName() string

+ func (slf *IndexData[I, T]) Handle(index I, handler func(name string, index I, data T)) *IndexData[I, T]

+ func (slf *IndexData[I, T]) HandleWithCallback(index I, handler func(name string, index I, data T) error, ...) *IndexData[I, T]

+ func (slf *IndexData[I, T]) LoadAllData()

+ func (slf *IndexData[I, T]) LoadData(index I)

+ func (slf *IndexData[I, T]) SaveAllData(errHandle func(err error) bool, retryInterval time.Duration)

+ func (slf *IndexData[I, T]) SaveData(index I) error

+ type IndexDataItem interface

+ GetIndex func() I

+ type IndexDataStorage interface

+ Delete func(name string, index I)

+ DeleteAll func(name string)

+ Load func(name string, index I) T

+ LoadAll func(name string) map[I]T

+ Save func(name string, index I, data T) error

+ SaveAll func(name string, data map[I]T, errHandle func(err error) bool, ...)