sqlc

package

Go to main page

Versions in this module

v0

v0.4.0

Jul 29, 2026

v0.3.0

Jul 6, 2026

Changes in this version

+ type ClaimMaintenanceLeasesParams struct

+ HolderID uuid.UUID

+ StaleCutoff pgtype.Timestamptz

+ Topics []string

+ type ConsumerSession struct

+ ConsumerID uuid.UUID

+ ExpiresAt pgtype.Timestamptz

+ MaintainsDefaultExpiration bool

+ type CountLiveConsumerSessionsRow struct

+ DefaultMaintainers int64

+ Live int64

+ type GetMaintenanceCandidateTopicsParams struct

+ DefaultExpirationNanos pgtype.Int8

+ HolderID uuid.UUID

+ IncludeTopics []string

+ SlackSeconds float64

+ StaleCutoff pgtype.Timestamptz

+ type GetMaintenanceCandidateTopicsRow struct

+ ExpirationNanos pgtype.Int8

+ HeldByMe bool

+ LeaseExpired bool

+ Topic string

+ Unleased bool

+ type GetTopicsWithExpirationRow struct

+ ExclusiveConsumerExpiresAt pgtype.Timestamptz

+ ExclusiveConsumerID *uuid.UUID

+ ExpirationNanos pgtype.Int8

+ Topic string

+ type InsertMaintenanceLeasesParams struct

+ HolderID uuid.UUID

+ Topics []string

type Queries

+ func (q *Queries) BumpTopicActivityIfStale(ctx context.Context, db DBTX, topic string) error

+ func (q *Queries) ClaimMaintenanceLeases(ctx context.Context, db DBTX, arg ClaimMaintenanceLeasesParams) ([]string, error)

+ func (q *Queries) CountLiveConsumerSessions(ctx context.Context, db DBTX) (*CountLiveConsumerSessionsRow, error)

+ func (q *Queries) DeleteExpiredConsumerSessions(ctx context.Context, db DBTX, cutoff pgtype.Timestamptz) error

+ func (q *Queries) GetMaintenanceCandidateTopics(ctx context.Context, db DBTX, arg GetMaintenanceCandidateTopicsParams) ([]*GetMaintenanceCandidateTopicsRow, error)

+ func (q *Queries) GetTopicsWithMessages(ctx context.Context, db DBTX) ([]string, error)

+ func (q *Queries) InsertMaintenanceLeases(ctx context.Context, db DBTX, arg InsertMaintenanceLeasesParams) ([]string, error)

+ func (q *Queries) ReleaseMaintenanceLease(ctx context.Context, db DBTX, arg ReleaseMaintenanceLeaseParams) error

+ func (q *Queries) UpsertConsumerSession(ctx context.Context, db DBTX, arg UpsertConsumerSessionParams) error

+ type ReleaseMaintenanceLeaseParams struct

+ HolderID uuid.UUID

+ Topic string

+ type SelectMaintenanceLeaseForUpdateParams struct

+ StaleCutoff pgtype.Timestamptz

+ Topic string

type SelectMaintenanceLeaseForUpdateRow

+ LeaseExpired bool

type Topic

+ LastInsertedAt pgtype.Timestamptz

+ type UpsertConsumerSessionParams struct

+ ConsumerID uuid.UUID

+ ExpiresAt pgtype.Timestamptz

+ MaintainsDefaultExpiration bool

v0.2.0

Jun 25, 2026

Changes in this version

+ type DeleteExpiredMessagesParams struct

+ Cutoff pgtype.Timestamptz

+ Topic string

+ type GetTopicExclusiveStatusRow struct

+ ExclusiveConsumerExpiresAt pgtype.Timestamptz

+ ExclusiveConsumerID *uuid.UUID

+ type GetTopicForUpdateRow struct

+ ExclusiveConsumerExpiresAt pgtype.Timestamptz

+ ExclusiveConsumerID *uuid.UUID

+ type InsertMaintenanceLeaseIfAbsentParams struct

+ HolderID uuid.UUID

+ Topic string

+ type InsertTopicIfAbsentParams struct

+ ExpirationNanos pgtype.Int8

+ Topic string

+ type MaintenanceLease struct

+ AcquiredAt pgtype.Timestamptz

+ HolderID uuid.UUID

+ Topic string

type Queries

+ func (q *Queries) DeleteExpiredMessages(ctx context.Context, db DBTX, arg DeleteExpiredMessagesParams) error

+ func (q *Queries) GetAllTopics(ctx context.Context, db DBTX) ([]*Topic, error)

+ func (q *Queries) GetOldestMessageInsertedAt(ctx context.Context, db DBTX, topic string) (pgtype.Timestamptz, error)

+ func (q *Queries) GetTopicExclusiveStatus(ctx context.Context, db DBTX, topic string) (*GetTopicExclusiveStatusRow, error)

+ func (q *Queries) GetTopicForUpdate(ctx context.Context, db DBTX, topic string) (*GetTopicForUpdateRow, error)

+ func (q *Queries) GetTopicsWithExpiration(ctx context.Context, db DBTX) ([]*Topic, error)

+ func (q *Queries) InsertMaintenanceLeaseIfAbsent(ctx context.Context, db DBTX, arg InsertMaintenanceLeaseIfAbsentParams) error

+ func (q *Queries) InsertTopicIfAbsent(ctx context.Context, db DBTX, arg InsertTopicIfAbsentParams) error

+ func (q *Queries) RenewTopicExclusiveConsumer(ctx context.Context, db DBTX, arg RenewTopicExclusiveConsumerParams) error

+ func (q *Queries) SelectMaintenanceLeaseForUpdate(ctx context.Context, db DBTX, topic string) (*SelectMaintenanceLeaseForUpdateRow, error)

+ func (q *Queries) SetTopicExclusiveConsumer(ctx context.Context, db DBTX, arg SetTopicExclusiveConsumerParams) error

+ func (q *Queries) UpdateMaintenanceLease(ctx context.Context, db DBTX, arg UpdateMaintenanceLeaseParams) error

+ type RenewTopicExclusiveConsumerParams struct

+ ExclusiveConsumerExpiresAt pgtype.Timestamptz

+ ExclusiveConsumerID *uuid.UUID

+ Topic string

+ type SelectMaintenanceLeaseForUpdateRow struct

+ AcquiredAt pgtype.Timestamptz

+ HolderID uuid.UUID

+ type SetTopicExclusiveConsumerParams struct

+ ExclusiveConsumerExpiresAt pgtype.Timestamptz

+ ExclusiveConsumerID *uuid.UUID

+ Topic string

+ type Topic struct

+ ExclusiveConsumerExpiresAt pgtype.Timestamptz

+ ExclusiveConsumerID *uuid.UUID

+ ExpirationNanos pgtype.Int8

+ Topic string

+ type UpdateMaintenanceLeaseParams struct

+ HolderID uuid.UUID

+ Topic string

v0.1.2

Jun 23, 2026

v0.1.1

Jun 22, 2026

v0.1.0

Jun 19, 2026

Changes in this version

+ type AcquireMessagesByTopicParams struct

+ Limit pgtype.Int4

+ Topic string

+ type DBTX interface

+ CopyFrom func(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)

+ 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 DeleteMessagesByIdsParams struct

+ Ids []int64

+ Topic string

+ type InsertMessageParams struct

+ Payload []byte

+ Topic string

+ type Message struct

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ Payload []byte

+ Topic string

+ type Queries struct

+ func New() *Queries

+ func (q *Queries) AcquireMessagesByTopic(ctx context.Context, db DBTX, arg AcquireMessagesByTopicParams) ([]*Message, error)

+ func (q *Queries) DeleteMessagesByIds(ctx context.Context, db DBTX, arg DeleteMessagesByIdsParams) error

+ func (q *Queries) InsertMessage(ctx context.Context, db DBTX, arg []InsertMessageParams) (int64, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL