MCPcopy Create free account

hub / github.com/cloudfoundry/go-diodes / functions

Functions38 in github.com/cloudfoundry/go-diodes

⨍ Functions 38◇ Types & classes 13
↓ 32 callersMethodTryNext
()
poller.go:11
↓ 23 callersMethodSet
(GenericDataType)
poller.go:10
↓ 14 callersMethodNext
Next polls the diode until data is available or until the context is done. If the context is done, then nil will be returned.
poller.go:58
↓ 4 callersMethodNext
Next returns the next data point on the wrapped diode. If there is no new data, it will wait for Set to be called or the context to be done. If the co
waiter.go:59
↓ 4 callersMethodSet
Set invokes the wrapped diode's Set with the given data and uses broadcast to wake up any readers.
waiter.go:43
↓ 4 callersFunctionnewSpyAlerter
()
one_to_one_test.go:167
↓ 2 callersMethodAlert
(missed int)
one_to_one.go:14
↓ 2 callersFunctiondrainChannel
(c chan []byte)
benchmarks_test.go:269
↓ 1 callersMethodbroadcast
broadcast sends to the channel if it can.
waiter.go:49
↓ 1 callersMethodisDone
()
poller.go:73
↓ 1 callersFunctionrandDataGen
()
benchmarks_test.go:279
MethodAlert
(missed int)
one_to_one_test.go:173
MethodAlert
Alert calls f(missed)
one_to_one.go:22
FunctionBenchmarkChannel
(b *testing.B)
benchmarks_test.go:119
FunctionBenchmarkChannelDrain
(b *testing.B)
benchmarks_test.go:188
FunctionBenchmarkManyToOnePoller
(b *testing.B)
benchmarks_test.go:71
FunctionBenchmarkManyToOneWaiter
(b *testing.B)
benchmarks_test.go:95
FunctionBenchmarkManyWritersChannel
(b *testing.B)
benchmarks_test.go:240
FunctionBenchmarkManyWritersDiode
(b *testing.B)
benchmarks_test.go:212
FunctionBenchmarkOneToOnePoller
(b *testing.B)
benchmarks_test.go:23
FunctionBenchmarkOneToOnePollerDrain
(b *testing.B)
benchmarks_test.go:141
FunctionBenchmarkOneToOneWaiter
(b *testing.B)
benchmarks_test.go:47
FunctionBenchmarkOneToOneWaiterDrain
(b *testing.B)
benchmarks_test.go:165
FunctionNewManyToOne
NewManyToOne creates a new diode (ring buffer). The ManyToOne diode is optimzed for many writers (on go-routines B-n) and a single reader (on go-routi
many_to_one.go:23
FunctionNewOneToOne
NewOneToOne creates a new diode is meant to be used by a single reader and a single writer. The alerter is invoked on the read's go-routine. It is cal
one_to_one.go:44
FunctionNewPoller
NewPoller returns a new Poller that wraps the given diode.
poller.go:42
FunctionNewWaiter
NewWaiter returns a new Waiter that wraps the given diode.
waiter.go:28
MethodSet
Set sets the data in the next slot of the ring buffer.
one_to_one.go:56
MethodSet
Set sets the data in the next slot of the ring buffer.
many_to_one.go:41
MethodSet
(data diodes.GenericDataType)
poller_test.go:64
FunctionTestDiodes
(t *testing.T)
diodes_suite_test.go:10
FunctionTestMain
(m *testing.M)
benchmarks_test.go:17
MethodTryNext
TryNext will attempt to read from the next slot of the ring buffer. If there is no data available, it will return (nil, false).
one_to_one.go:70
MethodTryNext
TryNext will attempt to read from the next slot of the ring buffer. If there is not data available, it will return (nil, false).
many_to_one.go:70
MethodTryNext
()
poller_test.go:70
FunctionWithPollingContext
WithPollingContext sets the context to cancel any retrieval (Next()). It will not change any results for adding data (Set()). Default is context.Backg
poller.go:35
FunctionWithPollingInterval
WithPollingInterval sets the interval at which the diode is queried for new data. The default is 10ms.
poller.go:26
FunctionWithWaiterContext
WithWaiterContext sets the context to cancel any retrieval (Next()). It will not change any results for adding data (Set()). Default is context.Backgr
waiter.go:21