Versions in this module Expand all Collapse all v1 v1.0.0 May 22, 2022 Changes in this version + func NewStore(dsn string) (s rocketride.Datastore, err error) + type AuditRecord struct + Action string + CreatedAt time.Time + Data json.RawMessage + ID int64 + OriginIp string + ResourceID int64 + ResourceType string + UserID int64 + type CreateAuditRecordParams struct + Action string + CreatedAt time.Time + Data json.RawMessage + OriginIp string + ResourceID int64 + ResourceType string + UserID int64 + type CreateIdempotencyKeyParams struct + CreatedAt time.Time + IdempotencyKey string + LastRunAt time.Time + LockedAt sql.NullTime + RecoveryPoint string + RequestMethod string + RequestParams json.RawMessage + RequestPath string + ResponseBody pqtype.NullRawMessage + ResponseCode sql.NullInt32 + UserID int64 + type CreateRideParams struct + CreatedAt time.Time + IdempotencyKeyID sql.NullInt64 + OriginLat float64 + OriginLon float64 + StripeChargeID sql.NullString + TargetLat float64 + TargetLon float64 + UserID int64 + type CreateStagedJobParams struct + JobArgs json.RawMessage + JobName string + type DBTX interface + ExecContext func(context.Context, string, ...interface{}) (sql.Result, error) + PrepareContext func(context.Context, string) (*sql.Stmt, error) + QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error) + QueryRowContext func(context.Context, string, ...interface{}) *sql.Row + type GetIdempotencyKeyParams struct + IdempotencyKey string + UserID int64 + type IdempotencyKey struct + CreatedAt time.Time + ID int64 + IdempotencyKey string + LastRunAt time.Time + LockedAt sql.NullTime + RecoveryPoint string + RequestMethod string + RequestParams json.RawMessage + RequestPath string + ResponseBody pqtype.NullRawMessage + ResponseCode sql.NullInt32 + UserID int64 + type Queries struct + func New(db DBTX) *Queries + func (q *Queries) CreateAuditRecord(ctx context.Context, arg CreateAuditRecordParams) (AuditRecord, error) + func (q *Queries) CreateIdempotencyKey(ctx context.Context, arg CreateIdempotencyKeyParams) (IdempotencyKey, error) + func (q *Queries) CreateRide(ctx context.Context, arg CreateRideParams) (Ride, error) + func (q *Queries) CreateStagedJob(ctx context.Context, arg CreateStagedJobParams) (StagedJob, error) + func (q *Queries) GetIdempotencyKey(ctx context.Context, arg GetIdempotencyKeyParams) (IdempotencyKey, error) + func (q *Queries) GetRideByID(ctx context.Context, id int64) (Ride, error) + func (q *Queries) GetRideByIdempotencyKeyID(ctx context.Context, idempotencyKeyID sql.NullInt64) (Ride, error) + func (q *Queries) GetUserByEmail(ctx context.Context, email string) (User, error) + func (q *Queries) GetUserByID(ctx context.Context, id int64) (User, error) + func (q *Queries) UpdateIdempotencyKey(ctx context.Context, arg UpdateIdempotencyKeyParams) (IdempotencyKey, error) + func (q *Queries) UpdateRide(ctx context.Context, arg UpdateRideParams) (Ride, error) + func (q *Queries) WithTx(tx *sql.Tx) *Queries + type Ride struct + CreatedAt time.Time + ID int64 + IdempotencyKeyID sql.NullInt64 + OriginLat float64 + OriginLon float64 + StripeChargeID sql.NullString + TargetLat float64 + TargetLon float64 + UserID int64 + type StagedJob struct + ID int64 + JobArgs json.RawMessage + JobName string + type UpdateIdempotencyKeyParams struct + ID int64 + LastRunAt time.Time + LockedAt sql.NullTime + RecoveryPoint string + ResponseBody pqtype.NullRawMessage + ResponseCode sql.NullInt32 + type UpdateRideParams struct + ID int64 + StripeChargeID sql.NullString + type User struct + Email string + ID int64 + StripeCustomerID string