v4

package

v0.1.4 Latest Latest Go to latest Published: Apr 4, 2023 License: MPL-2.0 Imports: 4 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

Repository

github.com/hyp3rd/hypercache

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	// ShardCount is the number of shards used by the map.
	ShardCount = 32
	// ShardCount32 is the number of shards used by the map pre-casted to uint32 to avoid performance issues.
	ShardCount32 uint32 = uint32(ShardCount)
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ConcurrentMap ¶

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

ConcurrentMap is a "thread" safe map of type string:*types.Item. To avoid lock bottlenecks this map is divided into several (ShardCount) map shards.

func New ¶

func New() ConcurrentMap

New creates a new concurrent map.

func (ConcurrentMap) Clear ¶

func (m ConcurrentMap) Clear()

Clear removes all items from map.

func (*ConcurrentMap) Count ¶

func (m *ConcurrentMap) Count() int

Count returns the number of items in the map.

func (*ConcurrentMap) Get ¶

func (m *ConcurrentMap) Get(key string) (*types.Item, bool)

Get retrieves an element from map under given key.

func (*ConcurrentMap) GetShard ¶

func (m *ConcurrentMap) GetShard(key string) *ConcurrentMapShard

GetShard returns shard under given key.

func (*ConcurrentMap) Has ¶

func (m *ConcurrentMap) Has(key string) bool

Has checks if key is present in the map.

func (ConcurrentMap) IterBuffered ¶

func (m ConcurrentMap) IterBuffered() <-chan Tuple

IterBuffered returns a buffered iterator which could be used in a for range loop.

func (*ConcurrentMap) Pop ¶

func (m *ConcurrentMap) Pop(key string) (*types.Item, bool)

Pop removes an element from the map and returns it.

func (*ConcurrentMap) Remove ¶

func (m *ConcurrentMap) Remove(key string)

Remove removes the value under the specified key.

func (*ConcurrentMap) Set ¶

func (m *ConcurrentMap) Set(key string, value *types.Item)

Set sets the given value under the specified key.

type ConcurrentMapShard ¶

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

ConcurrentMapShard is a "thread" safe string to `*types.Item` map shard.

type Tuple ¶

type Tuple struct {
	Key string
	Val types.Item
}

Tuple is used by the IterBuffered functions to wrap two variables together over a channel,

Source Files ¶

View all Source files

cmap.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL