cache

package

v0.19.4 Latest Latest Go to latest Published: Aug 27, 2017 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var BOLT_HEAD_CACHE_BUCKET = []byte("head_cache")

View Source

var BOLT_HEAD_CACHE_KEY = []byte("head")

View Source

var BOLT_INDEX_CACHE_BUCKET = []byte("index_cache")

View Source

var BOLT_MEMORY_IMAGE_BUCKET = []byte("memory_image")

View Source

var BOLT_MEMORY_IMAGE_INDEX_KEY = []byte("current_index")

View Source

var BOLT_NAMESPACE_CACHE_BUCKET = []byte("namespace_cache")

View Source

var DATA_KEY = []byte("data")

View Source

var NANO_TIMESTAMP_KEY = []byte("nano_timestamp")

View Source

var TIMESTAMP_KEY = []byte("timestamp")

func MakeResidentBufferQueue(buffSize int) api.RequestPriorityQueue

func MakeResidentHeadCache() api.HeadCache

func MakeResidentIndexCache(buffSize int) api.IndexCache

func MakeResidentMemoryCache(indexBufferSize, namespaceBufferSize int) api.Cache

func MakeResidentMemoryImage() api.MemoryImage

MakeResidentMemoryImage makes an non-ACID api.MemoryImage implementation that is only suitable for tests.

func MakeResidentNamespaceCache(buffSize int) api.NamespaceCache

type BoltFactory struct {
	BoltOptions
}

func MakeBoltFactory(options BoltOptions) (BoltFactory, error)

func (factory BoltFactory) MakeCache() (api.Cache, error)

func (factory BoltFactory) MakeMemoryImage() (api.MemoryImage, error)

type BoltOptions struct {
	DBOptions    *bolt.Options
	FilePath     string
	Mode         os.FileMode
	Db           *bolt.DB
	MaxCacheSize int
}

type Union struct {
	HeadCache      api.HeadCache
	IndexCache     api.IndexCache
	NamespaceCache api.NamespaceCache
}

func (cache Union) CloseCache() error

func (cache Union) GetHead() (crdt.IPFSPath, error)

func (cache Union) GetIndex(indexAddr crdt.IPFSPath) (crdt.Index, error)

func (cache Union) GetNamespace(namespaceAddr crdt.IPFSPath) (crdt.Namespace, error)

func (cache Union) SetHead(head crdt.IPFSPath) error

func (cache Union) SetIndex(indexAddr crdt.IPFSPath, index crdt.Index) error

func (cache Union) SetNamespace(namespaceAddr crdt.IPFSPath, namespace crdt.Namespace) error