postgres

package

Go to main page

Versions in this module

v1

v1.3.2-pre3

Apr 30, 2026

v1.3.2-pre2

Apr 30, 2026

v1.3.2-pre1

Apr 30, 2026

v1.3.1

Apr 29, 2026

v1.3.0

Apr 13, 2026

v1.2.6

Mar 6, 2026

v1.2.6-pre2

Mar 3, 2026

v1.2.6-pre1

Feb 20, 2026

v1.2.5

Nov 25, 2025

v1.2.5-pre1

Nov 25, 2025

v1.2.4

Nov 24, 2025

v1.2.3

Nov 24, 2025

v1.2.2

Nov 24, 2025

v1.2.1

Nov 14, 2025

v1.2.0

Nov 11, 2025

v1.1.3

Oct 1, 2025

v1.1.2

Sep 30, 2025

v1.1.1

Sep 22, 2025

v1.1.0

Sep 16, 2025

Changes in this version

type CheckForPercolatorParams

+ Language string

type CreatePercolatorParams

+ Language string

type Percolator

+ Language string

v1.1.0-pre2

Sep 15, 2025

v1.1.0-pre1

Sep 12, 2025

v1.0.10

Jun 18, 2025

v1.0.9

Jun 3, 2025

v1.0.8

May 20, 2025

Changes in this version

type PercolatorDocument

+ EventID int64

v1.0.7

May 19, 2025

v1.0.6

May 18, 2025

Changes in this version

type CheckForPercolatorParams

+ DocType string

v1.0.5

May 18, 2025

v1.0.4

May 15, 2025

v1.0.3

May 15, 2025

v1.0.2

May 15, 2025

v1.0.1

May 10, 2025

v1.0.0

May 10, 2025

v0

v0.10.4

Mar 6, 2025

v0.10.3

Mar 4, 2025

v0.10.2

Mar 4, 2025

v0.10.1

Mar 3, 2025

v0.10.0

Mar 3, 2025

Changes in this version

+ type AppState struct

+ Data AppStateData

+ Name string

+ type AppStateData struct

+ Percolator *PercolatorState

+ type CheckForPercolatorParams struct

+ Hash []byte

+ Owner pgtype.Text

+ type CreatePercolatorParams struct

+ Created pgtype.Timestamptz

+ DocType string

+ Hash []byte

+ Owner pgtype.Text

+ Query map[string]any

+ type CreateSubscriptionParams struct

+ Client string

+ Hash []byte

+ Percolator int64

+ Spec SubscriptionSpec

+ Touched pgtype.Timestamptz

+ type DropSubscriptionParams struct

+ Client string

+ Percolator int64

+ type FetchPercolatorEventsParams struct

+ Ids []int64

+ Limit int64

+ Percolators []int64

+ type FetchPercolatorEventsRow struct

+ ID int64

+ Matched bool

+ Percolator int64

+ type GetActiveSubscriptionCountParams struct

+ Cutoff pgtype.Timestamptz

+ Percolator int64

+ type GetCurrentActiveForUpdateRow struct

+ Active bool

+ Cluster pgtype.Text

+ Deleted bool

+ Enabled bool

+ Modified pgtype.Timestamptz

+ Name string

+ Position int64

+ type GetIndexSetForDeleteRow struct

+ Active bool

+ Cluster pgtype.Text

+ Deleted bool

+ Enabled bool

+ Modified pgtype.Timestamptz

+ Name string

+ Position int64

+ type GetIndexSetPositionRow struct

+ CaughtUp bool

+ Position int64

+ type GetPercolatorsMarkedForDeletionRow struct

+ DocType string

+ ID int64

+ type GetSubscriptionsParams struct

+ Client string

+ Subscriptions []int64

+ type GetSubscriptionsRow struct

+ ID int64

+ Percolator int64

+ Spec SubscriptionSpec

type IndexSet

+ CaughtUp bool

+ type IndexSetQueryRow struct

+ Active bool

+ Cluster pgtype.Text

+ Deleted bool

+ Enabled bool

+ Modified pgtype.Timestamptz

+ Name string

+ Position int64

+ type InsertPercolatorEventPayloadParams struct

+ Created pgtype.Timestamptz

+ Data PercolatorDocument

+ ID int64

+ type InsertPercolatorEventsParams struct

+ Created pgtype.Timestamptz

+ Document uuid.UUID

+ ID int64

+ Matched []bool

+ Percolators []int64

+ type Percolator struct

+ Created pgtype.Timestamptz

+ Deleted bool

+ DocType string

+ Hash []byte

+ ID int64

+ Owner pgtype.Text

+ Query map[string]any

+ type PercolatorDocument struct

+ Document *newsdoc.Document

+ Fields map[string][]string

+ ID int64

+ type PercolatorDocumentIndex struct

+ Index string

+ Percolator int64

+ type PercolatorEvent struct

+ Created pgtype.Timestamptz

+ Document uuid.UUID

+ ID int64

+ Matched bool

+ Percolator int64

+ type PercolatorEventPayload struct

+ Created pgtype.Timestamptz

+ Data PercolatorDocument

+ ID int64

+ type PercolatorState struct

+ CurrentPosition int64

type Queries

+ func (q *Queries) CheckForPercolator(ctx context.Context, arg CheckForPercolatorParams) (int64, error)

+ func (q *Queries) CreatePercolator(ctx context.Context, arg CreatePercolatorParams) (int64, error)

+ func (q *Queries) CreateSubscription(ctx context.Context, arg CreateSubscriptionParams) (int64, error)

+ func (q *Queries) DeletePercolator(ctx context.Context, id int64) error

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

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

+ func (q *Queries) DeleteSubscriptions(ctx context.Context, ids []int64) error

+ func (q *Queries) DeleteSubscriptionsForPercolators(ctx context.Context, percolators []int64) error

+ func (q *Queries) DropSubscription(ctx context.Context, arg DropSubscriptionParams) error

+ func (q *Queries) FetchPercolatorEvents(ctx context.Context, arg FetchPercolatorEventsParams) ([]FetchPercolatorEventsRow, error)

+ func (q *Queries) GetActiveSubscriptionCount(ctx context.Context, arg GetActiveSubscriptionCountParams) (int64, error)

+ func (q *Queries) GetAppState(ctx context.Context, name string) (AppStateData, error)

+ func (q *Queries) GetLastPercolatorEventID(ctx context.Context) (int64, error)

+ func (q *Queries) GetPercolator(ctx context.Context, id int64) (Percolator, error)

+ func (q *Queries) GetPercolatorDocumentIndices(ctx context.Context, percolator int64) ([]string, error)

+ func (q *Queries) GetPercolatorEventPayload(ctx context.Context, id int64) (PercolatorEventPayload, error)

+ func (q *Queries) GetPercolators(ctx context.Context) ([]Percolator, error)

+ func (q *Queries) GetPercolatorsMarkedForDeletion(ctx context.Context) ([]GetPercolatorsMarkedForDeletionRow, error)

+ func (q *Queries) GetSubscriptions(ctx context.Context, arg GetSubscriptionsParams) ([]GetSubscriptionsRow, error)

+ func (q *Queries) InsertPercolatorEventPayload(ctx context.Context, arg InsertPercolatorEventPayloadParams) error

+ func (q *Queries) InsertPercolatorEvents(ctx context.Context, arg InsertPercolatorEventsParams) error

+ func (q *Queries) MarkPercolatorsForDeletion(ctx context.Context, ids []int64) error

+ func (q *Queries) PercolatorsToDelete(ctx context.Context) ([]int64, error)

+ func (q *Queries) RegisterPercolatorDocumentIndex(ctx context.Context, arg RegisterPercolatorDocumentIndexParams) error

+ func (q *Queries) SetAppState(ctx context.Context, arg SetAppStateParams) error

+ func (q *Queries) SubscriptionsToDelete(ctx context.Context, cutoff pgtype.Timestamptz) ([]int64, error)

+ func (q *Queries) TouchSubscriptions(ctx context.Context, arg TouchSubscriptionsParams) error

+ type RegisterPercolatorDocumentIndexParams struct

+ Index string

+ Percolator int64

+ type SetAppStateParams struct

+ Data AppStateData

+ Name string

+ type Subscription struct

+ Client string

+ Hash []byte

+ ID int64

+ Percolator int64

+ Spec SubscriptionSpec

+ Touched pgtype.Timestamptz

+ type SubscriptionSpec struct

+ Fields []string

+ LoadDocuments bool

+ Source bool

+ type TouchSubscriptionsParams struct

+ Ids []int64

+ Touched pgtype.Timestamptz

type UpdateSetPositionParams

+ CaughtUp bool

v0.9.3

Feb 21, 2025

v0.9.2

Feb 20, 2025

v0.9.1

Feb 14, 2025

v0.9.0

Feb 13, 2025

v0.8.6

Nov 7, 2024

Changes in this version

+ type GetMappingsForTypeParams struct

+ ContentType string

+ SetName string

+ type GetMappingsForTypeRow struct

+ Mappings []byte

+ Name string

type Queries

+ func (q *Queries) GetMappingsForType(ctx context.Context, arg GetMappingsForTypeParams) ([]GetMappingsForTypeRow, error)

v0.8.5

Oct 16, 2024

v0.8.4

Oct 7, 2024

v0.8.3

Oct 1, 2024

v0.8.2

Sep 30, 2024

v0.8.1

Sep 25, 2024

v0.8.0

Sep 24, 2024

v0.7.1

Sep 18, 2024

v0.7.0

Sep 18, 2024

v0.6.0

Sep 13, 2024

v0.6.0-pre3

Sep 13, 2024

v0.6.0-pre2

Sep 13, 2024

v0.6.0-pre1

Sep 13, 2024

v0.5.4

Sep 5, 2024

v0.5.4-pre2

Aug 26, 2024

v0.5.4-pre1

Aug 26, 2024

v0.5.3

Jul 1, 2024

v0.5.2

Jul 1, 2024

v0.5.1

Jun 28, 2024

Changes in this version

type CreateDocumentIndexParams

+ FeatureFlags []string

type DocumentIndex

+ FeatureFlags []string

+ type GetIndexConfigurationRow struct

+ FeatureFlags []string

+ Mappings []byte

type Queries

+ func (q *Queries) GetIndexConfiguration(ctx context.Context, name string) (GetIndexConfigurationRow, error)

v0.5.0

Jun 19, 2024

v0.5.0-pre1

Jun 19, 2024

v0.4.4

Jun 12, 2024

v0.4.3

Jun 11, 2024

v0.4.2

Jun 10, 2024

v0.4.1

Jun 10, 2024

v0.4.0

Jun 10, 2024

v0.3.2

Feb 2, 2024

v0.3.1

Feb 1, 2024

v0.3.0

Feb 1, 2024

Changes in this version

+ type AddClusterParams struct

+ Auth []byte

+ Name string

+ Url string

+ type Cluster struct

+ Auth []byte

+ Created pgtype.Timestamptz

+ Name string

+ Url string

+ type ClusterIndexCountRow struct

+ PendingDelete int64

+ Total int64

+ type CreateDocumentIndexParams struct

+ ContentType string

+ Mappings []byte

+ Name string

+ SetName string

type CreateIndexSetParams

+ Active bool

+ Cluster string

+ Enabled bool

type IndexSet

+ Active bool

+ Cluster pgtype.Text

+ Deleted bool

+ Enabled bool

+ Modified pgtype.Timestamptz

+ type IndexSetQueryParams struct

+ Active pgtype.Bool

+ Cluster pgtype.Text

+ Enabled pgtype.Bool

+ RowOffset int32

+ type ListClustersWithCountsRow struct

+ Auth []byte

+ IndexSetCount int64

+ Name string

+ Url string

+ type NotifyParams struct

+ Channel string

+ Message string

type Queries

+ func (q *Queries) AddCluster(ctx context.Context, arg AddClusterParams) error

+ func (q *Queries) ClusterIndexCount(ctx context.Context, cluster string) (ClusterIndexCountRow, error)

+ func (q *Queries) CreateDocumentIndex(ctx context.Context, arg CreateDocumentIndexParams) error

+ func (q *Queries) DeleteCluster(ctx context.Context, name string) error

+ func (q *Queries) DeleteIndexSet(ctx context.Context, name string) error

+ func (q *Queries) GetActiveIndexSet(ctx context.Context) (IndexSet, error)

+ func (q *Queries) GetCluster(ctx context.Context, name string) (Cluster, error)

+ func (q *Queries) GetClusterForUpdate(ctx context.Context, name string) (Cluster, error)

+ func (q *Queries) GetClusters(ctx context.Context) ([]Cluster, error)

+ func (q *Queries) GetCurrentActiveForUpdate(ctx context.Context) (IndexSet, error)

+ func (q *Queries) GetIndexSet(ctx context.Context, name string) (IndexSet, error)

+ func (q *Queries) GetIndexSetForDelete(ctx context.Context, name string) (IndexSet, error)

+ func (q *Queries) GetIndexSetForUpdate(ctx context.Context, name string) (IndexSet, error)

+ func (q *Queries) GetIndexSets(ctx context.Context) ([]IndexSet, error)

+ func (q *Queries) IndexSetExists(ctx context.Context, name string) (bool, error)

+ func (q *Queries) IndexSetQuery(ctx context.Context, arg IndexSetQueryParams) ([]IndexSet, error)

+ func (q *Queries) ListClustersWithCounts(ctx context.Context) ([]ListClustersWithCountsRow, error)

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

+ func (q *Queries) LockClusters(ctx context.Context) error

+ func (q *Queries) Notify(ctx context.Context, arg NotifyParams) error

+ func (q *Queries) SetClusterWhereMissing(ctx context.Context, cluster string) error

+ func (q *Queries) SetIndexSetStatus(ctx context.Context, arg SetIndexSetStatusParams) error

+ type SetIndexSetStatusParams struct

+ Active bool

+ Deleted bool

+ Enabled bool

+ Name string

v0.2.0

Jan 9, 2024

v0.1.7

Dec 1, 2023

v0.1.6

Dec 1, 2023

v0.1.5

Nov 30, 2023

v0.1.4

Nov 10, 2023

Changes in this version

+ type CreateIndexParams struct

+ ContentType string

+ Mappings []byte

+ Name string

+ SetName string

+ type CreateIndexSetParams struct

+ Name string

+ Position int64

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

+ ContentType string

+ Mappings []byte

+ Name string

+ SetName string

+ type IndexSet struct

+ Name string

+ Position int64

+ type IndexingOverride struct

+ ContentType string

+ Field string

+ Mapping []byte

+ type JobLock struct

+ Holder string

+ Iteration int64

+ Name string

+ Touched pgtype.Timestamptz

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) CreateIndex(ctx context.Context, arg CreateIndexParams) error

+ func (q *Queries) CreateIndexSet(ctx context.Context, arg CreateIndexSetParams) error

+ func (q *Queries) GetIndexMappings(ctx context.Context, name string) ([]byte, error)

+ func (q *Queries) GetIndexSetPosition(ctx context.Context, name string) (int64, error)

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

+ func (q *Queries) UpdateIndexMappings(ctx context.Context, arg UpdateIndexMappingsParams) error

+ func (q *Queries) UpdateSetPosition(ctx context.Context, arg UpdateSetPositionParams) error

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

+ type SchemaVersion struct

+ Version int32

+ type UpdateIndexMappingsParams struct

+ Mappings []byte

+ Name string

+ type UpdateSetPositionParams struct

+ Name string

+ Position int64

v0.1.4-pre2

Nov 11, 2025

v0.1.4-pre1

Nov 9, 2023

v0.1.3

Sep 22, 2023

v0.1.2

Jul 18, 2023

v0.1.1

Jul 18, 2023

v0.1.0

Jul 18, 2023

v0.1.0-alpha4

May 29, 2023

v0.1.0-alpha3

May 5, 2023

v0.1.0-alpha2

May 5, 2023

v0.1.0-alpha1

May 5, 2023

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