// PreparePipeline prepares a new pipeline statement for a query.
344013
func (c *boltConn) PreparePipeline(queries ...string) (PipelineStmt, error) {
	if c.statement != nil {
		return nil, errors.New("An open statement already exists")
	}
	if c.closed {
		return nil, errors.New("Connection already closed")
	}
	c.statement = newPipelineStmt(queries, c)
	return c.statement, nil
}
871146
func (pool *ObjectPool) PreparePool(ctx context.Context) {
	if pool.getMinIdle() < 1 {
		return
	}
	pool.ensureMinIdle(ctx)
}
684716
func (s *CreateJobInput) SetPipelineId(v string) *CreateJobInput {
	s.PipelineId = &v
	return s
}
1186121
func newPipeline(db *Database) (*Pipeline, error) {
	ppl := &Pipeline{
		database: db,
	}
	err := ppl.ensureProtocol()
	if err != nil {
		return nil, err
	}
	// Perform authentication and database selection.
	if err != nil {
		return nil, err
	}
	err = ppl.resp.authenticate()
	if err != nil {
		ppl.database.pool.kill(ppl.resp)
		return nil, err
	}
	err = ppl.resp.selectDatabase()
	if err != nil {
		ppl.database.pool.kill(ppl.resp)
		return nil, err
	}
	return ppl, nil
}
1245543
func (t *Transaction) Prepare(query string) (*sql.Stmt, error) {
	if t.dbmap.logger != nil {
		now := time.Now()
		defer t.dbmap.trace(now, query, nil)
	}
	return prepare(t, query)
}
566209
func (s *JobData) SetPipelineContext(v *PipelineContext) *JobData {
	s.PipelineContext = v
	return s
}
217283
func (pg *PipelineGroups) GetGroupByPipeline(pipeline *Pipeline) *PipelineGroup {
	return pg.GetGroupByPipelineName(pipeline.Name)
}
241792
func (s *GetPipelineExecutionOutput) SetPipelineExecution(v *PipelineExecution) *GetPipelineExecutionOutput {
	s.PipelineExecution = v
	return s
}
1221500
func (s *UpdatePipelineStatusOutput) SetPipeline(v *Pipeline) *UpdatePipelineStatusOutput {
	s.Pipeline = v
	return s
}
907066
func (r *Redis) Pipelining() (*Pipelined, error) {
	c, err := r.pool.Get()
	if err != nil {
		return nil, err
	}
	return &Pipelined{r, c, 0}, nil
}
102683
func (t *RedconTransport) AppendEntriesPipeline(target string) (
	raft.AppendPipeline, error,
) {
	return nil, raft.ErrPipelineReplicationNotSupported
}
942432
func Pipeline(fns ...func() error) error {
	for _, fn := range fns {
		if err := fn(); err != nil {
			return err
		}
	}
	return nil
}
1289367
func (d DotSql) Prepare(db Preparer, name string) (*sql.Stmt, error) {
	query, err := d.lookupQuery(name)
	if err != nil {
		return nil, err
	}

	return db.Prepare(query)
}
934917
func (s *DescribePipelinesOutput) SetPipelineDescriptionList(v []*PipelineDescription) *DescribePipelinesOutput {
	s.PipelineDescriptionList = v
	return s
}
57987
func (tx *Tx) Preparex(query string) (*Stmt, error) {
	return Preparex(tx, query)
}
1213394
func (c *Tx) Pipeline() Pipeliner {
	pipe := Pipeline{
		exec: c.processTxPipeline,
	}
	pipe.statefulCmdable.setProcessor(pipe.Process)
	return &pipe
}
379176
func (c AccountClient) EnterResetPipeline(ctx context.Context, __arg EnterResetPipelineArg) (err error) {
	err = c.Cli.Call(ctx, "keybase.1.account.enterResetPipeline", []interface{}{__arg}, nil)
	return
}