Lines Matching defs:streamReader
276 type streamReader struct { struct
277 peerID types.ID
278 typ streamType
280 tr *Transport
281 picker *urlPicker
282 status *peerStatus
283 recvc chan<- raftpb.Message
284 propc chan<- raftpb.Message
286 rl *rate.Limiter // alters the frequency of dial retrial attempts
288 errorc chan<- error
290 mu sync.Mutex
291 paused bool
292 closer io.Closer
294 ctx context.Context
295 cancel context.CancelFunc
296 done chan struct{}
299 func (cr *streamReader) start() {
310 func (cr *streamReader) run() {
346 func (cr *streamReader) decodeLoop(rc io.ReadCloser, t streamType) error {
412 func (cr *streamReader) stop() {
420 func (cr *streamReader) dial(t streamType) (io.ReadCloser, error) {
502 func (cr *streamReader) close() {
511 func (cr *streamReader) pause() {
517 func (cr *streamReader) resume() {