Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

batchsqlc

package

Go to main page

Versions in this module

v0

v0.17.0

Nov 7, 2024

v0.16.0

Oct 31, 2024

v0.15.0

Oct 29, 2024

v0.14.0

Oct 28, 2024

v0.13.0

Oct 1, 2024

Changes in this version

type Batch

+ CreatedAt pgtype.Timestamp

type BatchFile

+ CreatedAt pgtype.Timestamp

type Batchrow

+ CreatedAt pgtype.Timestamp

+ type GetBatchStatusAndOutputFilesRow struct

+ Outputfiles []byte

+ Res []byte

+ Status StatusEnum

type Querier

+ GetBatchStatusAndOutputFiles func(ctx context.Context, id uuid.UUID) (GetBatchStatusAndOutputFilesRow, error)

+ UpdateBatchResult func(ctx context.Context, arg UpdateBatchResultParams) error

type Queries

+ func (q *Queries) GetBatchStatusAndOutputFiles(ctx context.Context, id uuid.UUID) (GetBatchStatusAndOutputFilesRow, error)

+ func (q *Queries) UpdateBatchResult(ctx context.Context, arg UpdateBatchResultParams) error

+ type UpdateBatchResultParams struct

+ Doneat pgtype.Timestamp

+ ID uuid.UUID

+ Outputfiles []byte

+ Status StatusEnum

v0.12.0

Sep 24, 2024

Changes in this version

+ type BatchFile struct

+ BatchID uuid.UUID

+ Checksum string

+ ContentType string

+ ErrorMessage pgtype.Text

+ Filename string

+ ID int32

+ Metadata []byte

+ ObjectID string

+ ProcessedAt pgtype.Timestamptz

+ ReceivedAt pgtype.Timestamptz

+ Size int64

+ Status bool

+ type InsertBatchFileParams struct

+ BatchID uuid.UUID

+ Checksum string

+ ContentType string

+ Filename string

+ Metadata []byte

+ ObjectID string

+ ReceivedAt pgtype.Timestamptz

+ Size int64

+ Status bool

type Querier

+ InsertBatchFile func(ctx context.Context, arg InsertBatchFileParams) error

type Queries

+ func (q *Queries) InsertBatchFile(ctx context.Context, arg InsertBatchFileParams) error

v0.11.0

May 22, 2024

Changes in this version

+ type Batch struct

+ App string

+ Context []byte

+ Doneat pgtype.Timestamp

+ ID uuid.UUID

+ Inputfile pgtype.Text

+ Naborted pgtype.Int4

+ Nfailed pgtype.Int4

+ Nsuccess pgtype.Int4

+ Op string

+ Outputfiles []byte

+ Reqat pgtype.Timestamp

+ Status StatusEnum

+ type Batchrow struct

+ Batch uuid.UUID

+ Blobrows []byte

+ Doneat pgtype.Timestamp

+ Doneby pgtype.Text

+ Input []byte

+ Line int32

+ Messages []byte

+ Reqat pgtype.Timestamp

+ Res []byte

+ Rowid int32

+ Status StatusEnum

+ type BulkInsertIntoBatchRowsParams struct

+ Batch []uuid.UUID

+ Input [][]byte

+ Line []int32

+ Reqat []pgtype.Timestamp

+ type CountBatchRowsByBatchIDAndStatusParams struct

+ Batch uuid.UUID

+ Status StatusEnum

+ Status_2 StatusEnum

+ type DBTX interface

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Query func(context.Context, string, ...interface{}) (pgx.Rows, error)

+ QueryRow func(context.Context, string, ...interface{}) pgx.Row

+ type FetchBatchRowsForBatchDoneRow struct

+ Line int32

+ Messages []byte

+ Res []byte

+ Status StatusEnum

+ type FetchBlockOfRowsParams struct

+ Limit int32

+ Status StatusEnum

+ type FetchBlockOfRowsRow struct

+ App string

+ Batch uuid.UUID

+ Context []byte

+ Input []byte

+ Line int32

+ Op string

+ Rowid int32

+ Status StatusEnum

+ type GetBatchRowsByBatchIDSortedRow struct

+ Blobrows []byte

+ Doneat pgtype.Timestamp

+ Doneby pgtype.Text

+ Input []byte

+ Line int32

+ Messages []byte

+ Reqat pgtype.Timestamp

+ Res []byte

+ Rowid int32

+ Status StatusEnum

+ type GetPendingBatchRowsRow struct

+ Blobrows []byte

+ Doneat pgtype.Timestamp

+ Doneby pgtype.Text

+ Input []byte

+ Line int32

+ Messages []byte

+ Reqat pgtype.Timestamp

+ Res []byte

+ Rowid int32

+ Status StatusEnum

+ type GetProcessedBatchRowsByBatchIDSortedRow struct

+ Blobrows []byte

+ Doneat pgtype.Timestamp

+ Doneby pgtype.Text

+ Input []byte

+ Line int32

+ Messages []byte

+ Reqat pgtype.Timestamp

+ Res []byte

+ Rowid int32

+ Status StatusEnum

+ type InsertIntoBatchRowsParams struct

+ Batch uuid.UUID

+ Input []byte

+ Line int32

+ Reqat pgtype.Timestamp

+ type InsertIntoBatchesParams struct

+ App string

+ Context []byte

+ ID uuid.UUID

+ Op string

+ Reqat pgtype.Timestamp

+ Status StatusEnum

+ type NullStatusEnum struct

+ StatusEnum StatusEnum

+ Valid bool

+ func (ns *NullStatusEnum) Scan(value interface{}) error

+ func (ns NullStatusEnum) Value() (driver.Value, error)

+ type Querier interface

+ BulkInsertIntoBatchRows func(ctx context.Context, arg BulkInsertIntoBatchRowsParams) (int64, error)

+ CountBatchRowsByBatchIDAndStatus func(ctx context.Context, arg CountBatchRowsByBatchIDAndStatusParams) (int64, error)

+ FetchBatchRowsForBatchDone func(ctx context.Context, batch uuid.UUID) ([]FetchBatchRowsForBatchDoneRow, error)

+ FetchBlockOfRows func(ctx context.Context, arg FetchBlockOfRowsParams) ([]FetchBlockOfRowsRow, error)

+ GetBatchByID func(ctx context.Context, id uuid.UUID) (Batch, error)

+ GetBatchRowsByBatchID func(ctx context.Context, batch uuid.UUID) ([]Batchrow, error)

+ GetBatchRowsByBatchIDSorted func(ctx context.Context, batch uuid.UUID) ([]GetBatchRowsByBatchIDSortedRow, error)

+ GetBatchRowsCount func(ctx context.Context, batch uuid.UUID) (int64, error)

+ GetBatchStatus func(ctx context.Context, id uuid.UUID) (StatusEnum, error)

+ GetCompletedBatches func(ctx context.Context) ([]uuid.UUID, error)

+ GetPendingBatchRows func(ctx context.Context, batch uuid.UUID) ([]GetPendingBatchRowsRow, error)

+ GetProcessedBatchRowsByBatchIDSorted func(ctx context.Context, batch uuid.UUID) ([]GetProcessedBatchRowsByBatchIDSortedRow, error)

+ InsertIntoBatchRows func(ctx context.Context, arg InsertIntoBatchRowsParams) error

+ InsertIntoBatches func(ctx context.Context, arg InsertIntoBatchesParams) (uuid.UUID, error)

+ UpdateBatchCounters func(ctx context.Context, arg UpdateBatchCountersParams) error

+ UpdateBatchOutputFiles func(ctx context.Context, arg UpdateBatchOutputFilesParams) error

+ UpdateBatchRowStatus func(ctx context.Context, arg UpdateBatchRowStatusParams) error

+ UpdateBatchRowsBatchJob func(ctx context.Context, arg UpdateBatchRowsBatchJobParams) error

+ UpdateBatchRowsSlowQuery func(ctx context.Context, arg UpdateBatchRowsSlowQueryParams) error

+ UpdateBatchRowsStatus func(ctx context.Context, arg UpdateBatchRowsStatusParams) error

+ UpdateBatchStatus func(ctx context.Context, arg UpdateBatchStatusParams) error

+ UpdateBatchSummary func(ctx context.Context, arg UpdateBatchSummaryParams) error

+ UpdateBatchSummaryOnAbort func(ctx context.Context, arg UpdateBatchSummaryOnAbortParams) error

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) BulkInsertIntoBatchRows(ctx context.Context, arg BulkInsertIntoBatchRowsParams) (int64, error)

+ func (q *Queries) CountBatchRowsByBatchIDAndStatus(ctx context.Context, arg CountBatchRowsByBatchIDAndStatusParams) (int64, error)

+ func (q *Queries) FetchBatchRowsForBatchDone(ctx context.Context, batch uuid.UUID) ([]FetchBatchRowsForBatchDoneRow, error)

+ func (q *Queries) FetchBlockOfRows(ctx context.Context, arg FetchBlockOfRowsParams) ([]FetchBlockOfRowsRow, error)

+ func (q *Queries) GetBatchByID(ctx context.Context, id uuid.UUID) (Batch, error)

+ func (q *Queries) GetBatchRowsByBatchID(ctx context.Context, batch uuid.UUID) ([]Batchrow, error)

+ func (q *Queries) GetBatchRowsByBatchIDSorted(ctx context.Context, batch uuid.UUID) ([]GetBatchRowsByBatchIDSortedRow, error)

+ func (q *Queries) GetBatchRowsCount(ctx context.Context, batch uuid.UUID) (int64, error)

+ func (q *Queries) GetBatchStatus(ctx context.Context, id uuid.UUID) (StatusEnum, error)

+ func (q *Queries) GetCompletedBatches(ctx context.Context) ([]uuid.UUID, error)

+ func (q *Queries) GetPendingBatchRows(ctx context.Context, batch uuid.UUID) ([]GetPendingBatchRowsRow, error)

+ func (q *Queries) GetProcessedBatchRowsByBatchIDSorted(ctx context.Context, batch uuid.UUID) ([]GetProcessedBatchRowsByBatchIDSortedRow, error)

+ func (q *Queries) InsertIntoBatchRows(ctx context.Context, arg InsertIntoBatchRowsParams) error

+ func (q *Queries) InsertIntoBatches(ctx context.Context, arg InsertIntoBatchesParams) (uuid.UUID, error)

+ func (q *Queries) UpdateBatchCounters(ctx context.Context, arg UpdateBatchCountersParams) error

+ func (q *Queries) UpdateBatchOutputFiles(ctx context.Context, arg UpdateBatchOutputFilesParams) error

+ func (q *Queries) UpdateBatchRowStatus(ctx context.Context, arg UpdateBatchRowStatusParams) error

+ func (q *Queries) UpdateBatchRowsBatchJob(ctx context.Context, arg UpdateBatchRowsBatchJobParams) error

+ func (q *Queries) UpdateBatchRowsSlowQuery(ctx context.Context, arg UpdateBatchRowsSlowQueryParams) error

+ func (q *Queries) UpdateBatchRowsStatus(ctx context.Context, arg UpdateBatchRowsStatusParams) error

+ func (q *Queries) UpdateBatchStatus(ctx context.Context, arg UpdateBatchStatusParams) error

+ func (q *Queries) UpdateBatchSummary(ctx context.Context, arg UpdateBatchSummaryParams) error

+ func (q *Queries) UpdateBatchSummaryOnAbort(ctx context.Context, arg UpdateBatchSummaryOnAbortParams) error

+ func (q *Queries) WithTx(tx pgx.Tx) *Queries

+ type StatusEnum string

+ const StatusEnumAborted

+ const StatusEnumFailed

+ const StatusEnumInprog

+ const StatusEnumQueued

+ const StatusEnumSuccess

+ const StatusEnumWait

+ func (e *StatusEnum) Scan(src interface{}) error

+ type UpdateBatchCountersParams struct

+ ID uuid.UUID

+ Naborted pgtype.Int4

+ Nfailed pgtype.Int4

+ Nsuccess pgtype.Int4

+ type UpdateBatchOutputFilesParams struct

+ ID uuid.UUID

+ Outputfiles []byte

+ type UpdateBatchRowStatusParams struct

+ Rowid int32

+ Status StatusEnum

+ type UpdateBatchRowsBatchJobParams struct

+ Blobrows []byte

+ Doneat pgtype.Timestamp

+ Doneby pgtype.Text

+ Messages []byte

+ Res []byte

+ Rowid int32

+ Status StatusEnum

+ type UpdateBatchRowsSlowQueryParams struct

+ Doneat pgtype.Timestamp

+ Doneby pgtype.Text

+ Messages []byte

+ Res []byte

+ Rowid int32

+ Status StatusEnum

+ type UpdateBatchRowsStatusParams struct

+ Column2 []int32

+ Status StatusEnum

+ type UpdateBatchStatusParams struct

+ Doneat pgtype.Timestamp

+ ID uuid.UUID

+ Naborted pgtype.Int4

+ Nfailed pgtype.Int4

+ Nsuccess pgtype.Int4

+ Outputfiles []byte

+ Status StatusEnum

+ type UpdateBatchSummaryOnAbortParams struct

+ Doneat pgtype.Timestamp

+ ID uuid.UUID

+ Naborted pgtype.Int4

+ Status StatusEnum

+ type UpdateBatchSummaryParams struct

+ Doneat pgtype.Timestamp

+ ID uuid.UUID

+ Naborted pgtype.Int4

+ Nfailed pgtype.Int4

+ Nsuccess pgtype.Int4

+ Outputfiles []byte

+ Status StatusEnum