MCPcopy Create free account

hub / github.com/PacktPublishing/Effective-Concurrency-in-Go / functions

Functions119 in github.com/PacktPublishing/Effective-Concurrency-in-Go

⨍ Functions 119◇ Types & classes 36
↓ 35 callersMethodDone
()
chapter2/waitgroup/waitgroup.go:28
↓ 21 callersMethodAdd
(delta int)
chapter2/waitgroup/waitgroup.go:13
↓ 18 callersMethodWait
()
chapter2/waitgroup/waitgroup.go:40
↓ 8 callersMethodClose
()
chapter10/unresponsive_service/main.go:75
↓ 6 callersFunctioncancelablePipelineStage
(input <-chan IN, done <-chan struct{}, process func(IN) OUT)
chapter5/pipeline/fanin.go:10
↓ 5 callersFunctionphilosopher
(index int, leftFork, rightFork *sync.Mutex)
chapter4/dining-philosophers/mutex/main.go:10
↓ 5 callersFunctionphilosopher
(index int, leftFork, rightFork chan bool)
chapter4/dining-philosophers/chan/main.go:9
↓ 5 callersFunctionphilosopher
(index int, firstFork, secondFork *sync.Mutex)
chapter4/dining-philosophers/ordered/main.go:10
↓ 3 callersFunctionGetRequestID
(ctx context.Context)
chapter8/context/requestid/main.go:18
↓ 3 callersMethodStream
(ctx context.Context, req Request)
chapter8/streams/store/store.go:23
↓ 3 callersFunctionencode
(input Record)
chapter5/pipeline/main.go:43
↓ 3 callersFunctioninitDB
(dbName string)
chapter8/streams/main.go:22
↓ 3 callersFunctionpipelineStage
(input <-chan IN, output chan<- OUT, process func(IN) OUT)
chapter5/pipeline/asynchpipeline.go:9
↓ 3 callersFunctionworkerPoolPipelineStage
(input <-chan IN, output chan<- OUT, process func(IN) OUT, numWorkers int)
chapter5/pipeline/asynchworkerpipeline.go:10
↓ 2 callersFunctionEncodeFromChan
(input <-chan T, encode func(T) ([]byte, error), out io.Writer)
chapter8/streams/main.go:133
↓ 2 callersMethodGet
(ID string)
chapter2/cache/main.go:35
↓ 2 callersMethodGetStats
(context.Context, string)
chapter8/server/dashboard/main.go:19
↓ 2 callersMethodGetTransactions
(context.Context, string)
chapter8/server/dashboard/main.go:23
↓ 2 callersMethodListen
()
chapter8/server/tcp/main.go:23
↓ 2 callersMethodWait
()
chapter4/rate-limiter/simple/main.go:22
↓ 2 callersMethodWait
()
chapter4/rate-limiter/channel/main.go:15
↓ 2 callersMethodWaitForConnections
(timeout time.Duration)
chapter8/server/tcp/main.go:46
↓ 2 callersFunctionWithRequestID
(ctx context.Context)
chapter8/context/requestid/main.go:14
↓ 2 callersFunctionconsumer
(index int, wg *sync.WaitGroup, input <-chan int)
chapter4/producer-consumer/main.go:27
↓ 2 callersMethodgetSequence
()
chapter5/pipeline/orderedfanin.go:11
↓ 2 callersFunctionphilosopher
(firstFork, secondFork *sync.Mutex)
chapter10/stacktrace/deadlock/main.go:7
↓ 2 callersFunctionproducer
(index int, wg *sync.WaitGroup, done chan struct{}, output chan<- int)
chapter4/producer-consumer/main.go:10
↓ 1 callersMethodCall
(ctx context.Context, req Req)
chapter10/unresponsive_service/main.go:92
↓ 1 callersFunctionCancelSupport
()
chapter9/cancel/main.go:10
↓ 1 callersFunctionConcurrencyLimiter
(sem chan struct{}, next http.HandlerFunc)
chapter8/server/dashboard/main.go:164
↓ 1 callersMethodDequeue
Dequeue removes a value from the queue. Returns 0,false if queue is empty
chapter2/condition/main.go:40
↓ 1 callersMethodEnqueue
Enqueue adds a value to the queue. Returns false if queue is full
chapter2/condition/main.go:27
↓ 1 callersMethodGet
()
chapter9/progress/main.go:20
↓ 1 callersMethodGetDashboardData
(ctx context.Context, userID string)
chapter8/server/dashboard/main.go:54
↓ 1 callersFunctionGetUserID
(ctx context.Context)
chapter8/server/dashboard/main.go:148
↓ 1 callersFunctionNewChannelRate
(rate float64, limit int)
chapter4/rate-limiter/channel/main.go:24
↓ 1 callersFunctionNewDashboardService
()
chapter8/server/dashboard/main.go:39
↓ 1 callersFunctionNewLimiter
(rate int, limit int)
chapter4/rate-limiter/simple/main.go:53
↓ 1 callersFunctionNewMonitor
(callTimeout time.Duration, alertTimeout time.Duration, maxActive int, call func(Req) (Rsp, error))
chapter10/unresponsive_service/main.go:31
↓ 1 callersFunctionNewQueue
NewQueue initializes an empty circular queue with the given capacity
chapter2/condition/main.go:17
↓ 1 callersMethodProgress
()
chapter9/progress/main.go:16
↓ 1 callersMethodSetDashboardConfig
(ctx context.Context, userID string, params DashboardParams)
chapter8/server/dashboard/main.go:113
↓ 1 callersMethodStopListener
()
chapter8/server/tcp/main.go:42
↓ 1 callersFunctionWithUserID
(ctx context.Context, userID string)
chapter8/server/dashboard/main.go:144
↓ 1 callersFunctioncomputeNewCopy
(in SomeStruct)
chapter9/cas/main.go:15
↓ 1 callersFunctionconvert
(input Record)
chapter5/pipeline/main.go:37
↓ 1 callersFunctionfanIn
(done <-chan struct{}, channels ...<-chan T)
chapter5/pipeline/fanin.go:29
↓ 1 callersFunctionhttpMain
()
chapter8/streams/main.go:238
↓ 1 callersFunctionlongGoroutine
(ctx context.Context, pm *ProgressMeter)
chapter9/progress/main.go:24
↓ 1 callersFunctionlongRunningProcess
(heartbeat, done chan struct{})
chapter7/heartbeat2/main.go:9
↓ 1 callersFunctionlongRunningProcess
(heartbeat, done chan struct{})
chapter7/heartbeat/main.go:9
↓ 1 callersFunctionmonitor
(heartbeat, done chan struct{}, tick <-chan time.Time)
chapter7/heartbeat2/main.go:23
↓ 1 callersFunctionmonitor
Monitor a long-running function that sends information to heartbeat channel every so often. At least one notification must arrive between every tick.
chapter7/heartbeat/main.go:26
↓ 1 callersFunctionnewRecord
(in []string)
chapter5/pipeline/main.go:16
↓ 1 callersFunctionobserver
(ctx context.Context, cancel func(), progress *ProgressMeter)
chapter9/progress/main.go:37
↓ 1 callersFunctionorderedFanIn
(done <-chan struct{}, channels ...<-chan T)
chapter5/pipeline/orderedfanin.go:20
↓ 1 callersFunctionparse
(input []string)
chapter5/pipeline/main.go:29
↓ 1 callersFunctionrestart
(done chan struct{}, f func(done, heartBeat chan struct{}), timeout time.Duration)
chapter10/heal/main.go:26
↓ 1 callersFunctionretrieveData
(ID string)
chapter2/cache/main.go:25
↓ 1 callersFunctionupdateSharedValue
(index int)
chapter9/cas/main.go:19
↓ 1 callersFunctionworker
(jobs chan Work)
chapter5/workerpool/wp2/main.go:25
↓ 1 callersFunctionworker
(jobs chan Work)
chapter5/workerpool/wp1/main.go:18
FunctionAuthenticate
(authenticator func(*http.Request) (string, error), next http.HandlerFunc)
chapter8/server/dashboard/main.go:153
MethodClose
()
chapter4/rate-limiter/channel/main.go:19
MethodDashboardHandler
(w http.ResponseWriter, req *http.Request)
chapter8/server/dashboard/main.go:116
FunctionDecodeToChan
(decode func(*T) error)
chapter8/websocket-chat/chat.go:36
FunctionDecodeToChan
(decode func(*T) error)
chapter8/streams/main.go:113
FunctionEncodeFromChan
(input <-chan T, encode func(T) ([]byte, error), out io.Writer)
chapter8/websocket-chat/chat.go:15
FunctionErrFilter
(in <-chan store.Entry)
chapter8/streams/filters/err.go:7
MethodGetStats
(context.Context, string)
chapter8/server/dashboard/main.go:29
MethodGetTransactions
(context.Context, string)
chapter8/server/dashboard/main.go:33
FunctionLimit
(maxSize int64, next http.HandlerFunc)
chapter8/server/dashboard/main.go:133
FunctionMinFilter
(min float64, in <-chan store.Entry)
chapter8/streams/filters/min.go:7
FunctionMovingAvg
(threshold float64, windowSize int, in <-chan store.Entry)
chapter8/streams/filters/movingavg.go:12
FunctionSlowFunc
(req *Request)
chapter10/unresponsive_service/main.go:79
FunctionasynchronousPipeline
(input *csv.Reader)
chapter5/pipeline/asynchpipeline.go:16
FunctionasynchronousPipeline2Workers
(input *csv.Reader)
chapter5/pipeline/asynchworkerpipeline.go:28
FunctionfanOutFanIn
(input *csv.Reader)
chapter5/pipeline/fanin.go:56
MethodgetSequence
()
chapter5/pipeline/main.go:51
FunctionlongRunning
(done, heartBeat chan struct{})
chapter10/heal/main.go:9
Functionmain
()
chapter7/heartbeat2/main.go:47
Functionmain
()
chapter7/simple-ticker/main.go:8
Functionmain
()
chapter7/heartbeat/main.go:50
Functionmain
()
chapter7/ticker-slow-receiver/main.go:8
Functionmain
()
chapter7/timer-cancel/main.go:8
Functionmain
()
chapter5/pipeline/main.go:53
Functionmain
()
chapter5/workerpool/wp2/main.go:50
Functionmain
()
chapter5/workerpool/wp1/main.go:38
Functionmain
()
chapter8/websocket-chat/client/main.go:14
Functionmain
()
chapter8/websocket-chat/server/main.go:13
Functionmain
()
chapter8/context/timeouts/main.go:10
Functionmain
()
chapter8/context/cancellation/main.go:9
Functionmain
()
chapter8/context/requestid/main.go:23
Functionmain
()
chapter8/streams/main.go:320
Functionmain
()
chapter8/server/dashboard/main.go:172
Functionmain
()
chapter8/server/tcp/main.go:59
Functionmain
()
chapter2/cache/main.go:60
Functionmain
()
chapter2/signal/main.go:14
Functionmain
()
chapter2/workers/main.go:16
Functionmain
()
chapter2/condition/main.go:52
next →1–100 of 119, ranked by callers