fuzzy/transport.go
func (t *transport) AppendEntriesPipeline(id raft.ServerID, target raft.ServerAddress) (raft.AppendPipeline, error) {
	p := &pipeline{
		t:        t,
		id:       id,
		target:   target,
		work:     make(chan *appendEntry, 100),
		consumer: make(chan raft.AppendFuture, 100),
	}
	go p.run()
	return p, nil
}
func (t *transport) AppendEntriesPipeline(id raft.ServerID, target raft.ServerAddress) (raft.AppendPipeline, error) {
	p := &pipeline{
		t:        t,
		id:       id,
		target:   target,
		work:     make(chan *appendEntry, 100),
		consumer: make(chan raft.AppendFuture, 100),
	}
	go p.run()
	return p, nil
}
func ( t * transport ) AppendEntriesPipeline ( id raft . ServerID , target raft . ServerAddress ) ( raft . AppendPipeline , error ) { p := & pipeline { t : t , id : id , target : target , work : make ( chan * appendEntry , 100 ) , consumer : make ( chan raft . AppendFuture , 100 ) , } go p . run ( ) return p , nil }
// AppendEntriesPipeline returns an interface that can be used to pipeline
// AppendEntries requests.
AppendEntriesPipeline returns an interface that can be used to pipeline AppendEntries requests .