storage

package

v0.0.3 Latest Latest Go to latest Published: Jan 11, 2023 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type IDStorage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewIDStorage() *IDStorage

func (r *IDStorage) Add(id int64)

func (r *IDStorage) Count() int

func (r *IDStorage) Delete(id int64)

func (r *IDStorage) ThreadUnsafeData() map[int64]struct{}

type LockableIDStorage interface {
	RLock()
	RUnlock()
	ThreadUnsafeData() map[int64]struct{}
}

type RecordsByID struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRecordsByID() *RecordsByID

func (r *RecordsByID) Count() int

func (r *RecordsByID) Delete(id int64)

func (r *RecordsByID) Get(id int64) record.Record

func (r *RecordsByID) GetAllData() []record.Record

func (r *RecordsByID) GetData(stores []LockableIDStorage) []record.Record

func (r *RecordsByID) GetIDStorage() LockableIDStorage

func (r *RecordsByID) Set(id int64, item record.Record)