lib_gc_cache_source

type ICacheSource interface {
	InitSource() error
	CloseSource() error
	AddData(key, value *[]byte) error
	AddMData(data *[][]byte) error
	GetData(key *[]byte) (*[]byte, error)
	MGetData(keys *[][]byte) (*[][]byte, error)
	DeleteData(key *[]byte) (bool, error)

	// Hash methdos to manage index keys
	AddToHash(hash *string, key, value *[]byte) error
	GetKeysFromHash(hash *string) (*[][]byte, error)
	RemoveKeyFromHash(hash *string, key *[]byte) error
	RemoveHash(hash *string) error
}

type ICacheSourceContainer interface {
	AddICacheSoure(key string, cacheSource ICacheSource) error
	GetICacheSource(key string) (ICacheSource, error)
	RemoveICacheSource(key string) error
}

type MapCache struct {
	// contains filtered or unexported fields
}

type PipelineAppener interface {
	AppendToPipeline() (map[string]int, error)
	GetKeys() *[][]byte
}

type PipelineFlusher interface {
	AppendToPipeLine(appener PipelineAppener) error
	ManagePipeLineBySize() error
	ManagePipeLineByIntervalOfTime() error
	FlushPipeLine() error
}

type PipelinedActionAddData struct {
	// contains filtered or unexported fields
}

type PipelinedActionAddMData struct {
	Data *[][]byte
}

type PipelinedActionAddToHash struct {
	Hash  *string
	Key   *[]byte
	Value *[]byte
}

type PipelinedActionRemoveData struct {
	// contains filtered or unexported fields
}

type PipelinedActionRemoveFromHash struct {
	Hash *string
	Key  *[]byte
}

type PipelinedChanges struct {
	PendingChanges_chan chan PipelineAppener
	PendingChanges      FIFO.Fifo
}