postgres

package
v0.5.4 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2024 License: MIT Imports: 4 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 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 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 GetIndexConfigurationRow added in v0.5.1 

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

type IndexSet 

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

type IndexSetQueryParams added in v0.3.0 

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

type IndexingOverride 

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

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 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) 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) 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) GetActiveIndexSet added in v0.3.0 

func (q *Queries) GetActiveIndexSet(ctx context.Context) (IndexSet, 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) (IndexSet, 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) (IndexSet, 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) (int64, error)

func (*Queries) GetIndexSets added in v0.3.0 

func (q *Queries) GetIndexSets(ctx context.Context) ([]IndexSet, 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) ([]IndexSet, 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) Notify added in v0.3.0 

func (q *Queries) Notify(ctx context.Context, arg NotifyParams) 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) 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 SchemaVersion 

type SchemaVersion struct {
	Version int32
}

type SetIndexSetStatusParams added in v0.3.0 

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

type UpdateIndexMappingsParams 

type UpdateIndexMappingsParams struct {
	Mappings []byte
	Name     string
}

type UpdateSetPositionParams 

type UpdateSetPositionParams struct {
	Position int64
	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.