cmap_string_session

package

v1.0.0 Latest Latest Go to latest Published: Mar 12, 2024 License: Apache-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

This section is empty.

View Source

var SHARD_COUNT = 32

This section is empty.

type ConcurrentMap []*ConcurrentMapShared

A "thread" safe map of type string:*mgo.Session. To avoid lock bottlenecks this map is dived to several (SHARD_COUNT) map shards.

func New() ConcurrentMap

Creates a new concurrent map.

func (m ConcurrentMap) Count() int

Returns the number of elements within the map.

func (m ConcurrentMap) Get(key string) (*mgo.Session, bool)

Retrieves an element from map under given key.

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

Returns shard under given key

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

Looks up an item under specified key

func (m *ConcurrentMap) IsEmpty() bool

Checks if map is empty.

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

Returns an iterator which could be used in a for range loop.

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

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

func (m ConcurrentMap) MarshalJSON() ([]byte, error)

Reviles ConcurrentMap "private" variables to json marshal.

func (m *ConcurrentMap) Remove(key string)

Removes an element from the map.

func (m *ConcurrentMap) Set(key string, value *mgo.Session)

Sets the given value under the specified key.

func (m *ConcurrentMap) UnmarshalJSON(b []byte) (err error)

type ConcurrentMapShared struct {
	sync.RWMutex // Read Write mutex, guards access to internal map.
	// contains filtered or unexported fields
}

type Tuple struct {
	Key string
	Val *mgo.Session
}

Used by the Iter & IterBuffered functions to wrap two variables together over a channel,