Documentation
¶
Overview ¶
Package iopipe simplifies the process of pumping data from one end to another while allowing us to measure throughput.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Float64Metric ¶
type Float64Metric func(i float64)
Int64Metric defines what we will use to produce/inform int64 metrics.
type Pipe ¶
type Pipe struct {
AMetric Float64Metric
BMetric Float64Metric
// contains filtered or unexported fields
}
Pipe will ensure that data flows from A to B and vice-versa - being A and B instances of io.ReadWriteCloser.
func New ¶
func New(a io.ReadWriteCloser, b io.ReadWriteCloser) *Pipe
New will create a new Pipe, copying data from A to B and vice-versa.
Source Files
Click to show internal directories.
Click to hide internal directories.