postgres

package
v0.10.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 6, 2025 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddClusterParams added in v0.3.0 

type AddClusterParams struct {
	Name string
	Url  string
	Auth []byte
}

type AppState added in v0.10.0 

type AppState struct {
	Name string
	Data AppStateData
}

type AppStateData added in v0.10.0 

type AppStateData struct {
	Percolator *PercolatorState `json:",omitempty"`
}

type CheckForPercolatorParams added in v0.10.0 

type CheckForPercolatorParams struct {
	Hash  []byte
	Owner pgtype.Text
}

type Cluster added in v0.3.0 

type Cluster struct {
	Name    string
	Url     string
	Auth    []byte
	Created pgtype.Timestamptz
}

type ClusterIndexCountRow added in v0.3.0 

type ClusterIndexCountRow struct {
	Total         int64
	PendingDelete int64
}

type CreateDocumentIndexParams added in v0.3.0 

type CreateDocumentIndexParams struct {
	Name         string
	SetName      string
	ContentType  string
	Mappings     []byte
	FeatureFlags []string
}

type CreateIndexSetParams 

type CreateIndexSetParams struct {
	Name     string
	Position int64
	Cluster  string
	Active   bool
	Enabled  bool
}

type CreatePercolatorParams added in v0.10.0 

type CreatePercolatorParams struct {
	Hash    []byte
	Owner   pgtype.Text
	Created pgtype.Timestamptz
	DocType string
	Query   map[string]any
}

type CreateSubscriptionParams added in v0.10.0 

type CreateSubscriptionParams struct {
	Percolator int64
	Client     string
	Hash       []byte
	Touched    pgtype.Timestamptz
	Spec       SubscriptionSpec
}

type DBTX 

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DocumentIndex 

type DocumentIndex struct {
	Name         string
	SetName      string
	ContentType  string
	Mappings     []byte
	FeatureFlags []string
}

type DropSubscriptionParams added in v0.10.0 

type DropSubscriptionParams struct {
	Percolator int64
	Client     string
}

type FetchPercolatorEventsParams added in v0.10.0 

type FetchPercolatorEventsParams struct {
	Limit       int64
	Ids         []int64
	Percolators []int64
}

type FetchPercolatorEventsRow added in v0.10.0 

type FetchPercolatorEventsRow struct {
	ID         int64
	Percolator int64
	Matched    bool
}

type GetActiveSubscriptionCountParams added in v0.10.0 

type GetActiveSubscriptionCountParams struct {
	Percolator int64
	Cutoff     pgtype.Timestamptz
}

type GetCurrentActiveForUpdateRow added in v0.10.0 

type GetCurrentActiveForUpdateRow struct {
	Name     string
	Position int64
	Cluster  pgtype.Text
	Active   bool
	Enabled  bool
	Deleted  bool
	Modified pgtype.Timestamptz
}

type GetIndexConfigurationRow added in v0.5.1 

type GetIndexConfigurationRow struct {
	Mappings     []byte
	FeatureFlags []string
}

type GetIndexSetForDeleteRow added in v0.10.0 

type GetIndexSetForDeleteRow struct {
	Name     string
	Position int64
	Cluster  pgtype.Text
	Active   bool
	Enabled  bool
	Deleted  bool
	Modified pgtype.Timestamptz
}

type GetIndexSetPositionRow added in v0.10.0 

type GetIndexSetPositionRow struct {
	Position int64
	CaughtUp bool
}

type GetMappingsForTypeParams added in v0.8.6 

type GetMappingsForTypeParams struct {
	SetName     string
	ContentType string
}

type GetMappingsForTypeRow added in v0.8.6 

type GetMappingsForTypeRow struct {
	Name     string
	Mappings []byte
}

type GetPercolatorsMarkedForDeletionRow added in v0.10.0 

type GetPercolatorsMarkedForDeletionRow struct {
	ID      int64
	DocType string
}

type GetSubscriptionsParams added in v0.10.0 

type GetSubscriptionsParams struct {
	Subscriptions []int64
	Client        string
}

type GetSubscriptionsRow added in v0.10.0 

type GetSubscriptionsRow struct {
	ID         int64
	Percolator int64
	Spec       SubscriptionSpec
}

type IndexSet 

type IndexSet struct {
	Name     string
	Position int64
	Cluster  pgtype.Text
	Active   bool
	Enabled  bool
	Deleted  bool
	Modified pgtype.Timestamptz
	CaughtUp bool
}

type IndexSetQueryParams added in v0.3.0 

type IndexSetQueryParams struct {
	Cluster   pgtype.Text
	Active    pgtype.Bool
	Enabled   pgtype.Bool
	RowOffset int32
}

type IndexSetQueryRow added in v0.10.0 

type IndexSetQueryRow struct {
	Name     string
	Position int64
	Cluster  pgtype.Text
	Active   bool
	Enabled  bool
	Deleted  bool
	Modified pgtype.Timestamptz
}

type IndexingOverride 

type IndexingOverride struct {
	ContentType string
	Field       string
	Mapping     []byte
}

type InsertPercolatorEventPayloadParams added in v0.10.0 

type InsertPercolatorEventPayloadParams struct {
	ID      int64
	Created pgtype.Timestamptz
	Data    PercolatorDocument
}

type InsertPercolatorEventsParams added in v0.10.0 

type InsertPercolatorEventsParams struct {
	ID          int64
	Document    uuid.UUID
	Percolators []int64
	Matched     []bool
	Created     pgtype.Timestamptz
}

type JobLock 

type JobLock struct {
	Name      string
	Holder    string
	Touched   pgtype.Timestamptz
	Iteration int64
}

type ListClustersWithCountsRow added in v0.3.0 

type ListClustersWithCountsRow struct {
	Name          string
	Url           string
	Auth          []byte
	IndexSetCount int64
}

type NotifyParams added in v0.3.0 

type NotifyParams struct {
	Channel string
	Message string
}

type Percolator added in v0.10.0 

type Percolator struct {
	ID      int64
	Hash    []byte
	Owner   pgtype.Text
	Created pgtype.Timestamptz
	DocType string
	Query   map[string]any
	Deleted bool
}

type PercolatorDocument added in v0.10.0 

type PercolatorDocument struct {
	ID       int64
	Fields   map[string][]string
	Document *newsdoc.Document
}

type PercolatorDocumentIndex added in v0.10.0 

type PercolatorDocumentIndex struct {
	Percolator int64
	Index      string
}

type PercolatorEvent added in v0.10.0 

type PercolatorEvent struct {
	ID         int64
	Document   uuid.UUID
	Percolator int64
	Matched    bool
	Created    pgtype.Timestamptz
}

type PercolatorEventPayload added in v0.10.0 

type PercolatorEventPayload struct {
	ID      int64
	Created pgtype.Timestamptz
	Data    PercolatorDocument
}

type PercolatorState added in v0.10.0 

type PercolatorState struct {
	CurrentPosition int64
}

type Queries 

type Queries struct {
	// contains filtered or unexported fields
}

func New 

func New(db DBTX) *Queries

func (*Queries) AddCluster added in v0.3.0 

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

func (*Queries) CheckForPercolator added in v0.10.0 

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

func (*Queries) ClusterIndexCount added in v0.3.0 

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

func (*Queries) CreateDocumentIndex added in v0.3.0 

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

func (*Queries) CreateIndexSet 

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

func (*Queries) CreatePercolator added in v0.10.0 

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

func (*Queries) CreateSubscription added in v0.10.0 

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

func (*Queries) DeleteCluster added in v0.3.0 

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

func (*Queries) DeleteIndexSet added in v0.3.0 

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

func (*Queries) DeletePercolator added in v0.10.0 

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

func (*Queries) DeletePercolatorEventPayloads added in v0.10.0 

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

func (*Queries) DeletePercolatorEvents added in v0.10.0 

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

func (*Queries) DeleteSubscriptions added in v0.10.0 

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

func (*Queries) DeleteSubscriptionsForPercolators added in v0.10.0 

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

func (*Queries) DropSubscription added in v0.10.0 

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

func (*Queries) FetchPercolatorEvents added in v0.10.0 

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

func (*Queries) GetActiveIndexSet added in v0.3.0 

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

func (*Queries) GetActiveSubscriptionCount added in v0.10.0 

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

func (*Queries) GetAppState added in v0.10.0 

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

func (*Queries) GetCluster added in v0.3.0 

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

func (*Queries) GetClusterForUpdate added in v0.3.0 

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

func (*Queries) GetClusters added in v0.3.0 

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

func (*Queries) GetCurrentActiveForUpdate added in v0.3.0 

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

func (*Queries) GetIndexConfiguration added in v0.5.1 

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

func (*Queries) GetIndexSet added in v0.3.0 

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

func (*Queries) GetIndexSetForDelete added in v0.3.0 

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

func (*Queries) GetIndexSetForUpdate added in v0.3.0 

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

func (*Queries) GetIndexSetPosition 

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

func (*Queries) GetIndexSets added in v0.3.0 

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

func (*Queries) GetLastPercolatorEventID added in v0.10.0 

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

func (*Queries) GetMappingsForType added in v0.8.6 

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

func (*Queries) GetPercolator added in v0.10.0 

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

func (*Queries) GetPercolatorDocumentIndices added in v0.10.0 

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

func (*Queries) GetPercolatorEventPayload added in v0.10.0 

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

func (*Queries) GetPercolators added in v0.10.0 

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

TODO: add pagination

func (*Queries) GetPercolatorsMarkedForDeletion added in v0.10.0 

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

func (*Queries) GetSubscriptions added in v0.10.0 

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

func (*Queries) IndexSetExists added in v0.3.0 

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

func (*Queries) IndexSetQuery added in v0.3.0 

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

func (*Queries) InsertPercolatorEventPayload added in v0.10.0 

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

func (*Queries) InsertPercolatorEvents added in v0.10.0 

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

func (*Queries) ListClustersWithCounts added in v0.3.0 

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

func (*Queries) ListDeletedIndexSets added in v0.3.0 

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

func (*Queries) ListIndexSets 

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

func (*Queries) LockClusters added in v0.3.0 

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

func (*Queries) MarkPercolatorsForDeletion added in v0.10.0 

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

func (*Queries) Notify added in v0.3.0 

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

func (*Queries) PercolatorsToDelete added in v0.10.0 

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

func (*Queries) RegisterPercolatorDocumentIndex added in v0.10.0 

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

func (*Queries) SetAppState added in v0.10.0 

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

func (*Queries) SetClusterWhereMissing added in v0.3.0 

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

func (*Queries) SetIndexSetStatus added in v0.3.0 

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

func (*Queries) SubscriptionsToDelete added in v0.10.0 

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

func (*Queries) TouchSubscriptions added in v0.10.0 

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

func (*Queries) UpdateIndexMappings 

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

func (*Queries) UpdateSetPosition 

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

func (*Queries) WithTx 

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

type RegisterPercolatorDocumentIndexParams added in v0.10.0 

type RegisterPercolatorDocumentIndexParams struct {
	Percolator int64
	Index      string
}

type SchemaVersion 

type SchemaVersion struct {
	Version int32
}

type SetAppStateParams added in v0.10.0 

type SetAppStateParams struct {
	Name string
	Data AppStateData
}

type SetIndexSetStatusParams added in v0.3.0 

type SetIndexSetStatusParams struct {
	Active  bool
	Enabled bool
	Deleted bool
	Name    string
}

type Subscription added in v0.10.0 

type Subscription struct {
	ID         int64
	Percolator int64
	Client     string
	Hash       []byte
	Touched    pgtype.Timestamptz
	Spec       SubscriptionSpec
}

type SubscriptionSpec added in v0.10.0 

type SubscriptionSpec struct {
	Source        bool
	Fields        []string
	LoadDocuments bool
}

type TouchSubscriptionsParams added in v0.10.0 

type TouchSubscriptionsParams struct {
	Touched pgtype.Timestamptz
	Ids     []int64
}

type UpdateIndexMappingsParams 

type UpdateIndexMappingsParams struct {
	Mappings []byte
	Name     string
}

type UpdateSetPositionParams 

type UpdateSetPositionParams struct {
	Position int64
	CaughtUp bool
	Name     string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.