postgres

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)

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)

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

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