Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/olric-data/olric
/ functions
Functions
1,316 in github.com/olric-data/olric
⨍
Functions
1,316
◇
Types & classes
192
Method
Check
(hkey uint64)
internal/kvstore/table/table.go:400
Method
Close
Close stops the iteration and releases allocated resources.
embedded_iterator.go:95
Method
Close
Close closes the pipeline and frees the allocated resources. You shouldn't try to reuse a closed pipeline.
pipeline.go:596
Method
Close
Close stops background routines and frees allocated resources.
embedded_client.go:284
Method
Close
Close stops the iteration and releases allocated resources.
cluster_iterator.go:298
Method
Close
Close stops the iteration and releases allocated resources.
client.go:54
Method
Close
Close stops background routines and frees allocated resources.
cluster_client.go:399
Method
Close
Close stops an online storage engine instance. It may free some of allocated resources. A storage engine implementation should be started again, but i
pkg/storage/engine.go:134
Method
Close
Close gracefully terminates all operations and releases resources associated with the service discovery instance.
pkg/service_discovery/service_discovery.go:42
Method
Close
()
internal/dmap/fragment.go:67
Method
Close
()
internal/testutil/mockfragment/mockfragment.go:124
Method
Close
()
internal/kvstore/kvstore.go:525
Method
Close
()
internal/discovery/discovery_test.go:223
Method
Close
()
internal/cluster/partitions/partition_test.go:42
Method
Compaction
Compaction reorganizes storage tables and reclaims wasted resources.
pkg/storage/engine.go:129
Method
Compaction
()
internal/dmap/fragment.go:48
Method
Compaction
()
internal/testutil/mockfragment/mockfragment.go:113
Method
Compaction
()
internal/kvstore/compaction.go:84
Method
Compaction
()
internal/cluster/partitions/partition_test.go:50
Function
Count
Count is the user specified the amount of work that should be done at every call in order to retrieve elements from the distributed map. This is just
client.go:138
Method
Decr
Decr queues a Decr command. The parameters are identical to the DMap.Decr, but it returns FutureDecr to read the batched response.
pipeline.go:362
Method
Decr
Decr atomically decrements the key by delta. The return value is the new value after being decremented or an error.
embedded_client.go:232
Method
Decr
Decr atomically decrements the key by delta. The return value is the new value after being decremented or an error.
cluster_client.go:240
Method
Delete
Delete queues a Delete command. The parameters are identical to the DMap.Delete, but it returns FutureDelete to read the batched response.
pipeline.go:230
Method
Delete
Delete deletes values for the given keys. Delete will not return error if key doesn't exist. It's thread-safe. It is safe to modify the contents of th
embedded_client.go:250
Method
Delete
Delete deletes values for the given keys. Delete will not return an error if the key doesn't exist. It's thread-safe. It is safe to modify the content
cluster_client.go:199
Method
Delete
Delete deletes an entry from the storage engine.
pkg/storage/engine.go:95
Method
Delete
(key string)
internal/testutil/mockfragment/mockfragment.go:70
Method
Delete
Delete deletes the value for the given key. Delete will not returns error if key doesn't exist.
internal/kvstore/kvstore.go:359
Method
Delete
Delete deletes an item from the Round-Robin scheduler.
internal/roundrobin/round_robin.go:76
Method
Delete
(id uint64)
internal/cluster/routingtable/members.go:47
Method
Deregister
()
internal/discovery/discovery_test.go:207
Method
Destroy
Destroy flushes the given DMap on the cluster. You should know that there is no global lock on DMaps. So if you call Put/PutEx and Destroy methods con
embedded_client.go:203
Method
Destroy
Destroy flushes the given DMap on the cluster. You should know that there is no global lock on DMaps. So if you call Put/PutEx and Destroy methods con
cluster_client.go:476
Method
Destroy
Destroy stops an online storage engine instance and frees allocated resources. It should not be possible to reuse a destroyed storage engine.
pkg/storage/engine.go:138
Method
Destroy
()
internal/dmap/fragment.go:58
Method
Destroy
()
internal/testutil/mockfragment/mockfragment.go:117
Method
Destroy
()
internal/kvstore/kvstore.go:529
Method
Destroy
()
internal/cluster/partitions/partition_test.go:46
Method
DiscoverPeers
()
internal/discovery/discovery_test.go:215
Method
Drop
(index int)
internal/kvstore/transport.go:33
Method
Encode
(v interface{})
internal/resp/encoder.go:61
Method
Encode
()
internal/kvstore/entry/entry.go:82
Method
Encode
()
events/cluster_events.go:37
Method
Expire
Expire queues an Expire command. The parameters are identical to the DMap.Expire, but it returns FutureExpire to read the batched response.
pipeline.go:272
Method
Expire
Expire updates the expiry for the given key. It returns ErrKeyNotFound if the DB does not contain the key. It's thread-safe.
embedded_client.go:209
Method
Expire
Expire updates the expiry for the given key. It returns ErrKeyNotFound if the DB does not contain the key. It's thread-safe.
cluster_client.go:320
Method
Export
()
internal/kvstore/transport.go:45
Method
Fork
Fork creates a new KVStore instance.
internal/kvstore/kvstore.go:157
Method
Get
Get queues a Get command. The parameters are identical to the DMap.Get, but it returns FutureGet to read the batched response.
pipeline.go:185
Method
Get
Get gets the value for the given key. It returns ErrKeyNotFound if the DB does not contain the key. It's thread-safe. It is safe to modify the content
embedded_client.go:257
Method
Get
Get gets the value for the given key. It returns ErrKeyNotFound if the DB does not contain the key. It's thread-safe. It is safe to modify the content
cluster_client.go:184
Method
Get
Get reads an entry from the storage engine.
pkg/storage/engine.go:83
Method
Get
Get returns an empty buffer from the pool. It creates a new buffer, if there is no bytes.Buffer available in the pool.
internal/bufpool/bufpool.go:46
Method
Get
(key string)
internal/testutil/mockfragment/mockfragment.go:64
Method
Get
Get gets the value for the given key. It returns storage.ErrKeyNotFound if the DB does not contain the key. The returned Entry is its own copy, it is
internal/kvstore/kvstore.go:275
Method
Get
Get returns an item.
internal/roundrobin/round_robin.go:45
Method
Get
(id uint64)
internal/cluster/routingtable/members.go:39
Method
GetBroadcasts
GetBroadcasts is called when user data messages can be broadcast.
internal/discovery/delegate.go:44
Method
GetKey
GetKey gets the key for the given hkey. It returns storage.ErrKeyNotFound if the DB does not contain the key.
internal/kvstore/kvstore.go:338
Method
GetKey
(hkey uint64)
internal/kvstore/table/table.go:221
Method
GetLastAccess
(hkey uint64)
internal/kvstore/kvstore.go:316
Method
GetLastAccess
(hkey uint64)
internal/kvstore/table/table.go:242
Method
GetPut
GetPut queues a GetPut command. The parameters are identical to the DMap.GetPut, but it returns FutureGetPut to read the batched response.
pipeline.go:420
Method
GetPut
GetPut atomically sets the key to value and returns the old value stored at key. It returns nil if there is no previous value.
embedded_client.go:220
Method
GetPut
GetPut atomically sets the key to value and returns the old value stored at a key. It returns nil if there is no previous value.
cluster_client.go:260
Method
GetRaw
GetRaw extracts encoded value for the given hkey. This is useful for merging tables.
internal/kvstore/kvstore.go:252
Method
GetRaw
(hkey uint64)
internal/kvstore/table/table.go:179
Method
GetTTL
GetTTL gets the timeout for the given key. It returns storage.ErrKeyNotFound if the DB does not contain the key.
internal/kvstore/kvstore.go:296
Method
GetTTL
(hkey uint64)
internal/kvstore/table/table.go:229
Method
HandleFunc
HandleFunc registers the handler function for the given command.
internal/server/handler.go:75
Method
Import
(data []byte, f func(uint64, storage.Entry) error)
internal/kvstore/transport.go:60
Method
Incr
Incr queues an Incr command. The parameters are identical to the DMap.Incr, but it returns FutureIncr to read the batched response.
pipeline.go:317
Method
Incr
Incr atomically increments the key by delta. The return value is the new value after being incremented or an error.
embedded_client.go:238
Method
Incr
Incr atomically increments the key by delta. The return value is the new value after being incremented or an error.
cluster_client.go:220
Method
IncrByFloat
IncrByFloat queues an IncrByFloat command. The parameters are identical to the DMap.IncrByFloat, but it returns FutureIncrByFloat to read the batched
pipeline.go:474
Method
IncrByFloat
IncrByFloat atomically increments the key by delta. The return value is the new value after being incremented or an error.
embedded_client.go:243
Method
IncrByFloat
IncrByFloat atomically increments the key by delta. The return value is the new value after being incremented or an error.
cluster_client.go:300
Method
Initialize
()
internal/discovery/discovery_test.go:175
Method
Key
Key returns a key name from the distributed map.
embedded_iterator.go:90
Method
Key
Key returns a key name from the distributed map.
cluster_iterator.go:256
Method
Key
Key returns the key as string
pkg/storage/entry.go:24
Method
Lease
Lease takes the duration to update the expiry for the given Lock.
embedded_client.go:45
Method
Lease
Lease extends the lease of the distributed lock associated with the context for the specified duration.
cluster_client.go:418
Method
LocalState
LocalState is used for a TCP Push/Pull.
internal/discovery/delegate.go:47
Method
Lock
Lock sets a lock for the given key. Acquired lock is only for the key in this dmap. It returns immediately if it acquires the lock for the given key.
embedded_client.go:166
Method
Lock
Lock sets a lock for the given key. Acquired lock is only for the key in this dmap. It returns immediately if it acquires the lock for the given key.
cluster_client.go:342
Method
Lock
Lock locks the mutex
internal/locker/locker.go:55
Method
Lock
Lock locks a mutex with the given name. If it doesn't exist, one is created
internal/locker/locker.go:72
Method
LockWithTimeout
LockWithTimeout sets a lock for the given key. If the lock is still unreleased the end of given period of time, it automatically releases the lock. Ac
embedded_client.go:188
Method
LockWithTimeout
LockWithTimeout sets a lock for the given key. If the lock is still unreleased the end of a given period of time, it automatically releases the lock.
cluster_client.go:374
Method
MarshalBinary
()
get_response_test.go:377
Method
MergeRemoteState
MergeRemoteState is invoked after a TCP Push/Pull.
internal/discovery/delegate.go:50
Method
Move
(part *partitions.Partition, name string, owners []discovery.Member)
internal/dmap/fragment.go:76
Method
Move
(part *partitions.Partition, name string, owners []discovery.Member)
internal/testutil/mockfragment/mockfragment.go:95
Method
Move
(_ *Partition, _ string, _ []discovery.Member)
internal/cluster/partitions/partition_test.go:38
Method
Name
Name exposes name of the DMap.
embedded_client.go:214
Method
Name
Name exposes name of the DMap.
cluster_client.go:67
Method
Name
Name returns name of the current storage engine implementation.
pkg/storage/engine.go:67
Method
Name
()
internal/dmap/fragment.go:72
← previous
next →
701–800 of 1,316, ranked by callers