type github.com/jackc/pgx/v5/pgconn.Pipeline
30 uses
github.com/jackc/pgx/v5/pgconn (current package)
pgconn.go#L105: pipeline Pipeline
pgconn.go#L1712: pipeline *Pipeline
pgconn.go#L2261: type Pipeline struct {
pgconn.go#L2426: func (pgConn *PgConn) StartPipeline(ctx context.Context) *Pipeline {
pgconn.go#L2428: pipeline := &Pipeline{
pgconn.go#L2439: pgConn.pipeline = Pipeline{
pgconn.go#L2463: func (p *Pipeline) SendPrepare(name, sql string, paramOIDs []uint32) {
pgconn.go#L2474: func (p *Pipeline) SendDeallocate(name string) {
pgconn.go#L2484: func (p *Pipeline) SendQueryParams(sql string, paramValues [][]byte, paramOIDs []uint32, paramFormats, resultFormats []int16) {
pgconn.go#L2497: func (p *Pipeline) SendQueryPrepared(stmtName string, paramValues [][]byte, paramFormats, resultFormats []int16) {
pgconn.go#L2509: func (p *Pipeline) SendQueryStatement(statementDescription *StatementDescription, paramValues [][]byte, paramFormats, resultFormats []int16) {
pgconn.go#L2527: func (p *Pipeline) SendFlushRequest() {
pgconn.go#L2542: func (p *Pipeline) SendPipelineSync() {
pgconn.go#L2552: func (p *Pipeline) Flush() error {
pgconn.go#L2578: func (p *Pipeline) Sync() error {
pgconn.go#L2586: func (p *Pipeline) GetResults() (results any, err error) {
pgconn.go#L2597: func (p *Pipeline) getResults() (results any, err error) {
pgconn.go#L2628: func (p *Pipeline) getResultsPrepare() (*StatementDescription, error) {
pgconn.go#L2678: func (p *Pipeline) getResultsQueryParams() (*ResultReader, error) {
pgconn.go#L2692: func (p *Pipeline) getResultsQueryPrepared() (*ResultReader, error) {
pgconn.go#L2701: func (p *Pipeline) getResultsQueryStatement() (*ResultReader, error) {
pgconn.go#L2752: func (p *Pipeline) getResultsDeallocate() (*CloseComplete, error) {
pgconn.go#L2771: func (p *Pipeline) getResultsSync() (*PipelineSync, error) {
pgconn.go#L2794: func (p *Pipeline) receiveParseComplete(errStr string) error {
pgconn.go#L2812: func (p *Pipeline) receiveBindComplete(errStr string) error {
pgconn.go#L2830: func (p *Pipeline) receiveDescribedResultReader(errStr string) (*ResultReader, error) {
pgconn.go#L2879: func (p *Pipeline) receiveMessage() (pgproto3.BackendMessage, error) {
pgconn.go#L2897: func (p *Pipeline) handleUnexpectedMessage(errStr string, msg pgproto3.BackendMessage) error {
pgconn.go#L2904: func (p *Pipeline) Close() error {
github.com/jackc/pgx/v5
batch.go#L282: pipeline *pgconn.Pipeline