MCPcopy Create free account

hub / github.com/Balun-courses/concurrency_go / functions

Functions875 in github.com/Balun-courses/concurrency_go

⨍ Functions 875◇ Types & classes 175
↓ 109 callersMethodDone
()
lessons/7_lesson_contexts_and_memory_barriers/context_with_timeout_implementation/main.go:45
↓ 81 callersMethodUnlock
()
lessons/4_lesson_sync_primitives_2/spinlock/main.go:26
↓ 79 callersMethodLock
()
lessons/4_lesson_sync_primitives_2/spinlock/main.go:20
↓ 76 callersMethodAdd
(key, value interface{})
lessons/3_lesson_sync_primitives_1/lazy_initialization/main.go:14
↓ 76 callersMethodWait
()
lessons/6_lesson_channel_patterns/errgroup_implementation/main.go:48
↓ 46 callersMethodGet
(string)
lessons/9_lesson_concurrency_patterns/2pl/scheduler.go:10
↓ 44 callersMethodSet
(string, string)
lessons/9_lesson_concurrency_patterns/2pl/scheduler.go:9
↓ 34 callersMethodStore
(key string, value int)
lessons/4_lesson_sync_primitives_2/sync_map/main.go:14
↓ 27 callersMethodRun
Run start worker for periodic flushing
lessons/10_lesson_live_coding_practise/batcher/main.go:65
↓ 25 callersMethodLoad
(key string)
lessons/4_lesson_sync_primitives_2/sync_map/main.go:9
↓ 24 callersMethodWrite
([]WriteRequest)
database/internal/database/storage/wal/wal.go:15
↓ 23 callersMethodLock
()
additional/open_lessons/mutex_internals/spinlock/main.go:18
↓ 22 callersMethodStop
()
lessons/6_lesson_channel_patterns/ticker_implementation/main.go:32
↓ 21 callersMethodStartTransaction
()
lessons/9_lesson_concurrency_patterns/mvcc/scheduler.go:34
↓ 20 callersMethodUnlock
()
additional/open_lessons/mutex_internals/spinlock/main.go:24
↓ 18 callersMethodCommit
()
lessons/9_lesson_concurrency_patterns/mvcc/transaction.go:57
↓ 17 callersMethodGet
(context.Context, string)
database/internal/database/storage/storage.go:22
↓ 16 callersMethodErr
()
lessons/7_lesson_contexts_and_memory_barriers/context_with_timeout_implementation/main.go:49
↓ 16 callersFunctionNewMockEngine
NewMockEngine creates a new mock instance.
database/internal/database/storage/storage_mock.go:28
↓ 16 callersMethodStartTransaction
()
lessons/9_lesson_concurrency_patterns/2pl/scheduler.go:34
↓ 15 callersFunctionParseSize
(text string)
database/internal/common/size_parser.go:5
↓ 15 callersMethodRead
()
database/internal/database/storage/wal/wal.go:19
↓ 13 callersMethodCommit
()
lessons/9_lesson_concurrency_patterns/2pl/transaction.go:55
↓ 13 callersMethodSet
(context.Context, string, string)
database/internal/database/storage/storage.go:28
↓ 12 callersMethodDel
(context.Context, string)
database/internal/database/storage/storage.go:29
↓ 11 callersMethodClose
()
database/internal/database/storage/replication/slave.go:19
↓ 11 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
database/internal/database/storage/storage_mock.go:97
↓ 11 callersFunctionNewMockcomputeLayer
NewMockcomputeLayer creates a new mock instance.
database/internal/database/database_mock.go:27
↓ 11 callersMethodRLock
()
lessons/4_lesson_sync_primitives_2/rw_mutex_implementation/main.go:44
↓ 11 callersMethodValue
(any)
lessons/7_lesson_contexts_and_memory_barriers/context_with_timeout_implementation/main.go:63
↓ 10 callersFunctionNewInMemoryStorage
()
lessons/9_lesson_concurrency_patterns/mvcc/storage.go:27
↓ 10 callersFunctionNewMockstorageLayer
NewMockstorageLayer creates a new mock instance.
database/internal/database/database_mock.go:65
↓ 10 callersFunctionNewWriteRequest
(lsn int64, commandID int, args []string)
database/internal/database/storage/wal/write_request.go:10
↓ 10 callersMethodParse
(string)
database/internal/database/database.go:15
↓ 10 callersMethodRUnlock
()
lessons/4_lesson_sync_primitives_2/rw_mutex_implementation/main.go:55
↓ 9 callersFunctionNewScheduler
(storage storage)
lessons/9_lesson_concurrency_patterns/mvcc/scheduler.go:27
↓ 9 callersMethodloadLocalReadOnly
()
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:193
↓ 8 callersMethodContains
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/without_sync/main.go:20
↓ 8 callersMethodContains
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:46
↓ 8 callersMethodContains
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:47
↓ 8 callersMethodContains
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/rough_sync/main.go:24
↓ 8 callersMethodContains
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/fine_sync/main.go:24
↓ 8 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
database/internal/database/database_mock.go:34
↓ 8 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
database/internal/database/storage/storage_mock.go:35
↓ 8 callersMethodLock
()
lessons/4_lesson_sync_primitives_2/rw_mutex_implementation/main.go:22
↓ 8 callersFunctionNewInMemoryStorage
()
lessons/9_lesson_concurrency_patterns/2pl/storage.go:10
↓ 8 callersFunctionNewMockWAL
NewMockWAL creates a new mock instance.
database/internal/database/storage/storage_mock.go:90
↓ 8 callersFunctionNewScheduler
(storage storage)
lessons/9_lesson_concurrency_patterns/2pl/scheduler.go:27
↓ 8 callersMethodRecover
()
database/internal/database/storage/storage.go:27
↓ 8 callersMethodStart
(ctx context.Context)
database/internal/database/storage/wal/wal.go:51
↓ 7 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
database/internal/database/database_mock.go:72
↓ 7 callersMethodGo
(task func() error)
lessons/6_lesson_channel_patterns/errgroup_implementation/main.go:23
↓ 7 callersFunctionNewEngine
(logger *zap.Logger, options ...EngineOption)
database/internal/database/storage/engine/in_memory/engine.go:18
↓ 7 callersMethodUnlock
()
lessons/4_lesson_sync_primitives_2/rw_mutex_implementation/main.go:36
↓ 7 callersFunctiontrace
go test -v
additional/lesson_testing_and_profiling/testing_in_one_package_parallel_with_subtests/order_test.go:10
↓ 6 callersMethodDo
(action func())
lessons/4_lesson_sync_primitives_2/once_implementation/once.go:17
↓ 6 callersMethodEncode
(buffer *bytes.Buffer)
database/internal/database/storage/wal/log.go:14
↓ 6 callersMethodGenerate
()
database/internal/database/storage/id_generator.go:18
↓ 6 callersMethodLoad
(key string)
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:95
↓ 6 callersFunctioncommandNameToCommandID
(command string)
database/internal/database/compute/command.go:23
↓ 5 callersMethodAdd
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:65
↓ 5 callersMethodArguments
()
database/internal/database/compute/query.go:19
↓ 5 callersMethodDecode
(buffer *bytes.Buffer)
database/internal/database/storage/wal/log.go:19
↓ 5 callersMethodFutureResponse
()
database/internal/database/storage/wal/write_request.go:29
↓ 5 callersMethodGet
(txID int32, key string)
lessons/9_lesson_concurrency_patterns/mvcc/storage.go:70
↓ 5 callersFunctionNewIDGenerator
(previousID int64)
database/internal/database/storage/id_generator.go:12
↓ 5 callersFunctionNewQuery
(commandID int, arguments []string)
database/internal/database/compute/query.go:8
↓ 5 callersFunctionNewStorage
(engine Engine, logger *zap.Logger, options ...StorageOption)
database/internal/database/storage/storage.go:45
↓ 5 callersMethodPop
()
lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/michael_scott_queue/main.go:53
↓ 5 callersMethodSetResponse
(err error)
database/internal/database/storage/wal/write_request.go:25
↓ 5 callersFunctionWithPartitions
(partitionsNumber uint)
database/internal/database/storage/engine/in_memory/engine_options.go:5
↓ 5 callersMethodgetNext
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:28
↓ 5 callersFunctiontrace
go test -v
additional/lesson_testing_and_profiling/testing_in_one_package_parallel/order_test.go:10
↓ 4 callersMethodAdd
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/without_sync/main.go:25
↓ 4 callersMethodAdd
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:64
↓ 4 callersMethodAdd
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/rough_sync/main.go:32
↓ 4 callersMethodAdd
(value uint)
lessons/8_lesson_sync_algorithms_and_lock_free/set/fine_sync/main.go:31
↓ 4 callersMethodAfter
()
lessons/6_lesson_channel_patterns/barrier/main.go:38
↓ 4 callersFunctionDecode
(object *ProtocolObject, data []byte)
database/internal/database/storage/replication/protocol.go:43
↓ 4 callersFunctionEncode
(object *ProtocolObject)
database/internal/database/storage/replication/protocol.go:33
↓ 4 callersMethodGet
(context.Context, string)
database/internal/database/database.go:20
↓ 4 callersMethodIsMaster
()
database/internal/database/storage/storage.go:33
↓ 4 callersFunctionNewMockReplica
NewMockReplica creates a new mock instance.
database/internal/database/storage/storage_mock.go:156
↓ 4 callersFunctionNewMocklogsWriter
NewMocklogsWriter creates a new mock instance.
database/internal/database/storage/wal/wal_mock.go:25
↓ 4 callersFunctionNewMockwalSegment
NewMockwalSegment creates a new mock instance.
database/internal/database/storage/wal/logs_writer_mock.go:25
↓ 4 callersFunctionNewTCPClient
(address string, options ...TCPClientOption)
database/internal/network/tcp_client.go:17
↓ 4 callersFunctionSegmentNext
(directory string, segmentName string)
database/internal/database/filesystem/utils.go:8
↓ 4 callersMethodSet
(ctx context.Context, key, value string)
database/internal/database/storage/wal/wal.go:83
↓ 4 callersMethodSet
(txID int32, modified map[string]string)
lessons/9_lesson_concurrency_patterns/mvcc/storage.go:33
↓ 4 callersFunctionWithReplication
(replica Replica)
database/internal/database/storage/storage_options.go:19
↓ 4 callersFunctionWithWAL
(wal WAL)
database/internal/database/storage/storage_options.go:13
↓ 4 callersFunctioncommandArgumentsNumber
(commandID int)
database/internal/database/compute/command.go:44
↓ 4 callersMethodgetNext
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:29
↓ 4 callersFunctiontask
()
lessons/2_lesson_gorutines_and_scheduler/never_exit/main.go:8
↓ 3 callersMethodCommandID
()
database/internal/database/compute/query.go:15
↓ 3 callersMethodDo
(key string, action func() (interface{}, error))
lessons/6_lesson_channel_patterns/single_flight/main.go:27
↓ 3 callersMethodExistsBetween
(readTxID, writeTxID int32, modified map[string]string)
lessons/9_lesson_concurrency_patterns/mvcc/storage.go:47
↓ 3 callersMethodForEach
(func([]byte) error)
database/internal/database/storage/wal/logs_reader.go:11
↓ 3 callersMethodGet
(key string)
database/internal/database/storage/engine/in_memory/hash_table.go:25
↓ 3 callersMethodLoad
(key string)
lessons/4_lesson_sync_primitives_2/rw_mutex_with_map/main.go:10
next →1–100 of 875, ranked by callers