Versions in this module Expand all Collapse all v0 v0.9.1 May 3, 2024 v0.9.0 Mar 4, 2024 Changes in this version + var DDLPostgres = []string + var DDLSqlite3 = []string + var MigrationRunWebhookLimit = runWebhookLimit + var Sequences = []sqlg.Sequence + type DB struct + func NewDB(log zerolog.Logger, sdb *sql.DB) (*DB, error) + func (d *DB) CommitStatusArray() []any + func (d *DB) CommitStatusDeliveryArray() []any + func (d *DB) CommitStatusDeliveryFromArray(a []any, txID string) (*types.CommitStatusDelivery, string, error) + func (d *DB) CommitStatusFromArray(a []any, txID string) (*types.CommitStatus, string, error) + func (d *DB) DB() *sql.DB + func (d *DB) DBType() sql.Type + func (d *DB) DDL() []string + func (d *DB) DeleteCommitStatus(tx *sql.Tx, id string) error + func (d *DB) DeleteCommitStatusDeliveriesByCommitStatusID(tx *sql.Tx, commitStatusID string) error + func (d *DB) DeleteCommitStatusDelivery(tx *sql.Tx, id string) error + func (d *DB) DeleteLastRunEventSequence(tx *sql.Tx, id string) error + func (d *DB) DeleteRunWebhook(tx *sql.Tx, id string) error + func (d *DB) DeleteRunWebhookDeliveriesByRunWebhookID(tx *sql.Tx, runWebhookID string) error + func (d *DB) DeleteRunWebhookDelivery(tx *sql.Tx, id string) error + func (d *DB) Do(ctx context.Context, f func(tx *sql.Tx) error) error + func (d *DB) FetchObjects(tx *sql.Tx, kind string, q sq.Builder) ([]sqlg.Object, error) + func (d *DB) Flavor() sq.Flavor + func (d *DB) GetCommitStatusByID(tx *sql.Tx, commitStatusID string) (*types.CommitStatus, error) + func (d *DB) GetCommitStatusDeliveriesAfterSequence(tx *sql.Tx, afterSequence uint64, limit int) ([]*types.CommitStatusDelivery, error) + func (d *DB) GetCommitStatusDeliveriesByCommitStatusID(tx *sql.Tx, commitStatusID string, deliveryStatusFilter []types.DeliveryStatus, ...) ([]*types.CommitStatusDelivery, error) + func (d *DB) GetCommitStatusDeliveryByID(tx *sql.Tx, commitStatusDeliveryID string) (*types.CommitStatusDelivery, error) + func (d *DB) GetCommitStatuses(tx *sql.Tx, limit int) ([]*types.CommitStatus, error) + func (d *DB) GetCommitStatusesAfterCommitStatusID(tx *sql.Tx, afterCommitStatusID string, limit int) ([]*types.CommitStatus, error) + func (d *DB) GetLastRunEventSequence(tx *sql.Tx) (*types.LastRunEventSequence, error) + func (d *DB) GetProjectCommitStatusDeliveriesAfterSequenceByProjectID(tx *sql.Tx, afterSequence uint64, projectID string, ...) ([]*types.CommitStatusDelivery, error) + func (d *DB) GetProjectRunWebhookDeliveriesAfterSequenceByProjectID(tx *sql.Tx, afterSequence uint64, projectID string, ...) ([]*types.RunWebhookDelivery, error) + func (d *DB) GetRunWebhookByID(tx *sql.Tx, runWebhookID string) (*types.RunWebhook, error) + func (d *DB) GetRunWebhookDeliveriesAfterSequence(tx *sql.Tx, afterSequence uint64, limit int) ([]*types.RunWebhookDelivery, error) + func (d *DB) GetRunWebhookDeliveriesByRunWebhookID(tx *sql.Tx, runWebhookID string, deliveryStatusFilter []types.DeliveryStatus, ...) ([]*types.RunWebhookDelivery, error) + func (d *DB) GetRunWebhookDeliveryByID(tx *sql.Tx, runWebhookDeliveryID string) (*types.RunWebhookDelivery, error) + func (d *DB) GetRunWebhooks(tx *sql.Tx, limit int) ([]*types.RunWebhook, error) + func (d *DB) GetRunWebhooksAfterRunWebhookID(tx *sql.Tx, afterRunWebhookID string, limit int) ([]*types.RunWebhook, error) + func (d *DB) GetSequence(tx *sql.Tx, sequenceName string) (uint64, error) + func (d *DB) InsertCommitStatus(tx *sql.Tx, v *types.CommitStatus) error + func (d *DB) InsertCommitStatusDelivery(tx *sql.Tx, v *types.CommitStatusDelivery) error + func (d *DB) InsertLastRunEventSequence(tx *sql.Tx, v *types.LastRunEventSequence) error + func (d *DB) InsertOrUpdateCommitStatus(tx *sql.Tx, v *types.CommitStatus) error + func (d *DB) InsertOrUpdateCommitStatusDelivery(tx *sql.Tx, v *types.CommitStatusDelivery) error + func (d *DB) InsertOrUpdateLastRunEventSequence(tx *sql.Tx, v *types.LastRunEventSequence) error + func (d *DB) InsertOrUpdateRunWebhook(tx *sql.Tx, v *types.RunWebhook) error + func (d *DB) InsertOrUpdateRunWebhookDelivery(tx *sql.Tx, v *types.RunWebhookDelivery) error + func (d *DB) InsertRawObject(tx *sql.Tx, obj sqlg.Object) error + func (d *DB) InsertRunWebhook(tx *sql.Tx, v *types.RunWebhook) error + func (d *DB) InsertRunWebhookDelivery(tx *sql.Tx, v *types.RunWebhookDelivery) error + func (d *DB) LastRunEventSequenceArray() []any + func (d *DB) LastRunEventSequenceFromArray(a []any, txID string) (*types.LastRunEventSequence, string, error) + func (d *DB) MigrateFuncs() map[uint]sqlg.MigrateFunc + func (d *DB) ObjectToExportJSON(obj sqlg.Object, e *json.Encoder) error + func (d *DB) ObjectsInfo() []sqlg.ObjectInfo + func (d *DB) PopulateSequences(tx *sql.Tx) error + func (d *DB) RunWebhookArray() []any + func (d *DB) RunWebhookDeliveryArray() []any + func (d *DB) RunWebhookDeliveryFromArray(a []any, txID string) (*types.RunWebhookDelivery, string, error) + func (d *DB) RunWebhookFromArray(a []any, txID string) (*types.RunWebhook, string, error) + func (d *DB) SelectObject(kind string) *sq.SelectBuilder + func (d *DB) Sequences() []sqlg.Sequence + func (d *DB) UnmarshalExportObject(data []byte) (sqlg.Object, error) + func (d *DB) UpdateCommitStatus(tx *sql.Tx, v *types.CommitStatus) error + func (d *DB) UpdateCommitStatusDelivery(tx *sql.Tx, v *types.CommitStatusDelivery) error + func (d *DB) UpdateLastRunEventSequence(tx *sql.Tx, v *types.LastRunEventSequence) error + func (d *DB) UpdateRunWebhook(tx *sql.Tx, v *types.RunWebhook) error + func (d *DB) UpdateRunWebhookDelivery(tx *sql.Tx, v *types.RunWebhookDelivery) error + func (d *DB) Version() uint