Functions — github.com/Balun-courses/concurrency

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

Functions875 in github.com/Balun-courses/concurrency_go

⨍ Functions 875◇ Types & classes 175

↓ 3 callersMethodLock

()

additional/open_lessons/mutex_internals/rw_mutex_implementation/main.go:22

↓ 3 callersFunctionNewHashTable

()

database/internal/database/storage/engine/in_memory/hash_table.go:12

↓ 3 callersFunctionNewLogsReader

(segmentsDirectory segmentsDirectory)

database/internal/database/storage/wal/logs_reader.go:18

↓ 3 callersFunctionNewLogsWriter

(segment segment, logger *zap.Logger)

database/internal/database/storage/wal/logs_writer.go:19

↓ 3 callersFunctionNewMocklogsReader

NewMocklogsReader creates a new mock instance.

database/internal/database/storage/wal/wal_mock.go:60

↓ 3 callersFunctionNewMocksegmentsDirectory

NewMocksegmentsDirectory creates a new mock instance.

database/internal/database/storage/wal/logs_reader_mock.go:25

↓ 3 callersFunctionNewWAL

(writer logsWriter, reader logsReader, flushTimeout time.Duration, maxBatchSize int)

database/internal/database/storage/wal/wal.go:34

↓ 3 callersMethodPop

()

lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/stack/main.go:22

↓ 3 callersMethodPop

()

lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/queue/main.go:28

↓ 3 callersMethodPop

()

lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/treiber_stack/main.go:36

↓ 3 callersMethodPush

(value int)

lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/michael_scott_queue/main.go:27

↓ 3 callersMethodPush

(value int)

lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/stack/main.go:18

↓ 3 callersMethodPush

(value int)

lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/queue/main.go:23

↓ 3 callersMethodPush

(value int)

lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/treiber_stack/main.go:23

↓ 3 callersMethodRemove

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/without_sync/main.go:36

↓ 3 callersMethodRemove

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:86

↓ 3 callersMethodRemove

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:87

↓ 3 callersMethodRemove

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/rough_sync/main.go:46

↓ 3 callersMethodRemove

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/fine_sync/main.go:44

↓ 3 callersMethodReset

(interval time.Duration)

lessons/6_lesson_channel_patterns/ticker_implementation/main.go:36

↓ 3 callersMethodRollback

()

lessons/9_lesson_concurrency_patterns/mvcc/transaction.go:74

↓ 3 callersMethodRollback

()

lessons/9_lesson_concurrency_patterns/2pl/transaction.go:64

↓ 3 callersMethodSize

()

lessons/3_lesson_sync_primitives_1/recursive_lock/main.go:38

↓ 3 callersMethodStore

(key string, value int)

lessons/4_lesson_sync_primitives_2/rw_mutex_with_map/main.go:18

↓ 3 callersMethodStore

(key, value string)

lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:163

↓ 3 callersMethodTryLock

()

lessons/4_lesson_sync_primitives_2/timed_mutex_implementation/main.go:20

↓ 3 callersMethodUnlock

()

additional/open_lessons/mutex_internals/rw_mutex_implementation/main.go:36

↓ 3 callersFunctionWithReplicationStream

(stream <-chan []wal.Log)

database/internal/database/storage/storage_options.go:7

↓ 3 callersMethodWrite

(data []byte)

database/internal/database/filesystem/segment.go:26

↓ 3 callersMethodfind

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/without_sync/main.go:50

↓ 3 callersMethodfind

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:111

↓ 3 callersMethodfind

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:113

↓ 3 callersMethodfind

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/rough_sync/main.go:63

↓ 3 callersMethodfind

(value uint)

lessons/8_lesson_sync_algorithms_and_lock_free/set/fine_sync/main.go:60

↓ 3 callersMethodflush

()

lessons/10_lesson_live_coding_practise/batcher/main.go:94

↓ 3 callersMethodflushBatch

()

database/internal/database/storage/wal/wal.go:106

↓ 3 callersMethodpartitionIdx

(key string)

database/internal/database/storage/engine/in_memory/engine.go:79

↓ 3 callersMethodrelease

(previous, current *node)

lessons/8_lesson_sync_algorithms_and_lock_free/set/fine_sync/main.go:80

↓ 3 callersMethodshardIdx

(key string)

lessons/8_lesson_sync_algorithms_and_lock_free/sharded_map/main.go:68

↓ 3 callersMethodvalidate

(previous, current *node)

lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:122

↓ 3 callersMethodvalidate

(previous, current *node)

lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:124

↓ 3 callersFunctionwithRetries

(ctx context.Context, action func() error)

lessons/10_lesson_live_coding_practise/cache/main.go:142

↓ 3 callersMethodwithSynchronization

(previous, current *node, action func())

lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:135

↓ 3 callersMethodwithSynchronization

(previous, current *node, action func())

lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:130

↓ 2 callersMethodAcquire

()

database/internal/concurrency/semaphore.go:13

↓ 2 callersMethodAcquire

()

lessons/6_lesson_channel_patterns/semaphore/main.go:19

↓ 2 callersMethodAdd

(value int)

lessons/3_lesson_sync_primitives_1/incorrect_struct_design/main.go:10

↓ 2 callersMethodCreateActor

(address string, executor Executor)

lessons/9_lesson_concurrency_patterns/actors/actor_manager.go:26

↓ 2 callersFunctionCreateEngine

(cfg *configuration.EngineConfig, logger *zap.Logger)

database/internal/initialization/engine_initializer.go:12

↓ 2 callersFunctionCreateLogger

(cfg *configuration.LoggingConfig)

database/internal/initialization/logger_initializer.go:25

↓ 2 callersFunctionCreateNetwork

(cfg *configuration.NetworkConfig, logger *zap.Logger)

database/internal/initialization/network_initializer.go:15

↓ 2 callersFunctionCreateReplica

( replicationCfg *configuration.ReplicationConfig, walCfg *configuration.WALConfig, logger *zap.Logger, )

database/internal/initialization/replication_initializer.go:25

↓ 2 callersFunctionCreateWAL

(cfg *configuration.WALConfig, logger *zap.Logger)

database/internal/initialization/wal_initializer.go:22

↓ 2 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

database/internal/database/storage/storage_mock.go:163

↓ 2 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

database/internal/database/storage/wal/logs_reader_mock.go:32

↓ 2 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

database/internal/database/storage/wal/logs_writer_mock.go:32

↓ 2 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

database/internal/database/storage/wal/wal_mock.go:32

↓ 2 callersMethodForEach

(action func([]byte) error)

database/internal/database/filesystem/segments_directory.go:18

↓ 2 callersFunctionGetActorManager

()

lessons/9_lesson_concurrency_patterns/actors/actor_manager.go:16

↓ 2 callersMethodHandleQueries

(context.Context, func(context.Context, []byte) []byte)

database/internal/database/storage/replication/master.go:15

↓ 2 callersMethodHandleQuery

(ctx context.Context, queryStr string)

database/internal/database/database.go:50

↓ 2 callersFunctionIsClosed

(ch chan int)

lessons/5_lesson_channels/is_closed_1/main.go:5

↓ 2 callersFunctionIsClosed

Need to show solution

lessons/5_lesson_channels/is_closed_2/main.go:7

↓ 2 callersMethodLock

Здесь нет гарантии прогресса (liveness), так как могут несколько горутин могут помешать друг другу и попасть в livelock

additional/open_lessons/mutex_internals/broken_mutex_3/main.go:22

↓ 2 callersMethodLock

(index int)

additional/open_lessons/mutex_internals/peterson_mutex/main.go:20

↓ 2 callersMethodLock

(index int)

lessons/4_lesson_sync_primitives_2/peterson_mutex/main.go:19

↓ 2 callersFunctionNeverExit

(name string, action func())

lessons/2_lesson_gorutines_and_scheduler/never_exit/main.go:15

↓ 2 callersFunctionNewCompute

(logger *zap.Logger)

database/internal/database/compute/compute.go:20

↓ 2 callersFunctionNewDatabase

(computeLayer computeLayer, storageLayer storageLayer, logger *zap.Logger)

database/internal/database/database.go:30

↓ 2 callersFunctionNewRequest

(lastSegmentName string)

database/internal/database/storage/replication/protocol.go:13

↓ 2 callersFunctionNewSegmentsDirectory

(directory string)

database/internal/database/filesystem/segments_directory.go:12

↓ 2 callersMethodRange

(action func(key, value string))

lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:117

↓ 2 callersMethodRead

()

database/internal/database/storage/wal/logs_reader.go:28

↓ 2 callersMethodRelease

()

database/internal/concurrency/semaphore.go:21

↓ 2 callersMethodRelease

()

lessons/6_lesson_channel_patterns/semaphore/main.go:23

↓ 2 callersMethodSend

(request []byte)

database/internal/network/tcp_client.go:41

↓ 2 callersMethodSendMessage

(message Message)

lessons/9_lesson_concurrency_patterns/actors/actor_manager.go:38

↓ 2 callersMethodShutdown

()

lessons/6_lesson_channel_patterns/done_channel_with_struct/main.go:48

↓ 2 callersMethodStartDatabase

(ctx context.Context)

database/internal/initialization/initializer.go:77

↓ 2 callersMethodUnlock

()

additional/open_lessons/mutex_internals/broken_mutex_3/main.go:32

↓ 2 callersMethodUnlock

()

additional/open_lessons/mutex_internals/peterson_mutex/main.go:32

↓ 2 callersMethodUnlock

(index int)

lessons/4_lesson_sync_primitives_2/peterson_mutex/main.go:30

↓ 2 callersFunctionWithClientBufferSize

(size uint)

database/internal/network/network_options.go:15

↓ 2 callersFunctionWithClientIdleTimeout

(timeout time.Duration)

database/internal/network/network_options.go:9

↓ 2 callersMethodWrite

(requests []WriteRequest)

database/internal/database/storage/wal/logs_writer.go:33

↓ 2 callersMethodacknowledgeWrite

(requests []WriteRequest, err error)

database/internal/database/storage/wal/logs_writer.go:52

↓ 2 callersMethodapply

(operations []txOperation, rollback bool)

lessons/9_lesson_concurrency_patterns/2pl/scheduler.go:109

↓ 2 callersMethodapplyData

(logs []wal.Log)

database/internal/database/storage/storage.go:143

↓ 2 callersMethodcommit

([]txOperation)

lessons/9_lesson_concurrency_patterns/2pl/transaction.go:12

↓ 2 callersFunctiondoSomething

()

lessons/5_lesson_channels/select_with_main_goroutine/main.go:5

↓ 2 callersFunctiondoWork

(closeCh chan struct{})

lessons/6_lesson_channel_patterns/done_channel/main.go:7

↓ 2 callersMethodflushLocked

()

lessons/10_lesson_live_coding_practise/batcher/main.go:101

↓ 2 callersFunctionfunctionWithPanic

()

lessons/3_lesson_sync_primitives_1/defer_with_panic/main.go:10

↓ 2 callersMethodget

(int32, string)

lessons/9_lesson_concurrency_patterns/2pl/transaction.go:10

↓ 2 callersFunctiongoid

This is terrible, slow, and should never be used.

lessons/4_lesson_sync_primitives_2/recursive_mutex_implementation/main.go:13

↓ 2 callersMethodload

()

lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:22

↓ 2 callersFunctionloadConfig

()

lessons/4_lesson_sync_primitives_2/atomic_value/main.go:8

↓ 2 callersMethodlock

()

lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:16

↓ 2 callersMethodlock

()

lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:17

↓ 2 callersMethodmissLocked

()

lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:216

← previous next →101–200 of 875, ranked by callers