Versions in this module Expand all Collapse all v0 v0.0.2 Jul 28, 2026 Changes in this version + type Analyses interface + type AnalysesReader interface + GetAnalysis func(ctx context.Context, arg *GetAnalysisParams, storeOptions ...QueryOption) (*Analysis, error) + type AnalysesWriter interface type Querier + UpdateUserName func(ctx context.Context, arg *UpdateUserNameParams) (*User, error) type Queries + func (q *Queries) UpdateUserName(ctx context.Context, arg *UpdateUserNameParams) (*User, error) + type QueryOption func(*queryOptions) + type ShardedOption func(*shardedOptions) + func WithReplicaSet(name string, primary DBTX, replicas ...DBTX) ShardedOption + func WithVShardMapping(mainReplicaSet string, vshards []uint64, mirrorReplicaSets ...string) ShardedOption + type SingletonOption func(*singletonConfig) + func WithDatabaseName(name string) SingletonOption + func WithReadReplicas(databases ...DBTX) SingletonOption + func WithWriteMirrors(databases ...DBTX) SingletonOption + type Store interface + Analyses func() Analyses + Users func() Users + func NewStore(ctx context.Context, topology Topology, options ...StoreOption) (Store, error) + type StoreOption func(*storeOptions) + func WithLogger(logger *slog.Logger) StoreOption + func WithMeterProvider(provider metric.MeterProvider) StoreOption + func WithTracerProvider(provider trace.TracerProvider) StoreOption + type Topology interface + func Sharded[SK any](numVShards uint64, shardHasher pgmesh.ShardHasher[SK], ...) Topology + func Singleton(primary DBTX, options ...SingletonOption) Topology + type UpdateUserNameParams struct + ID int64 + Name string + TenantID int64 + type Users interface + type UsersReader interface + GetUser func(ctx context.Context, arg *GetUserParams, storeOptions ...QueryOption) (*User, error) + type UsersWriter interface + CreateUser func(ctx context.Context, arg *CreateUserParams, storeOptions ...QueryOption) (*User, error) + UpdateUserName func(ctx context.Context, arg *UpdateUserNameParams, storeOptions ...QueryOption) (*User, error) v0.0.1 Jul 20, 2026 Changes in this version + func NewStoreNode(database DBTX) pgmesh.Node[*ReadQueries, *StoreQueries] + type Analysis struct + ActiveWindow pgtype.Range[pgtype.Timestamptz] + Description *string + ID int64 + Source netip.Addr + State NullAnalysisState + TenantID int64 + type AnalysisState string + const AnalysisStateComplete + const AnalysisStatePending + func (e *AnalysisState) Scan(src interface{}) error + type CopyUsersParams struct + ID int64 + Name string + TenantID int64 + type CreateUserParams struct + ID int64 + Name string + TenantID int64 + 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 GetAnalysisParams struct + ID int64 + TenantID int64 + type GetUserParams struct + ID int64 + TenantID int64 + type NullAnalysisState struct + AnalysisState AnalysisState + Valid bool + func (ns *NullAnalysisState) Scan(value interface{}) error + func (ns NullAnalysisState) Value() (driver.Value, error) + type Querier interface + CopyUsers func(ctx context.Context, arg []*CopyUsersParams) (int64, error) + CreateUser func(ctx context.Context, arg *CreateUserParams) (*User, error) + GetAnalysis func(ctx context.Context, arg *GetAnalysisParams) (*Analysis, error) + GetUser func(ctx context.Context, arg *GetUserParams) (*User, error) + ListUsers func(ctx context.Context) ([]*User, error) + type Queries struct + func New(db DBTX) *Queries + func (q *Queries) CopyUsers(ctx context.Context, arg []*CopyUsersParams) (int64, error) + func (q *Queries) CreateUser(ctx context.Context, arg *CreateUserParams) (*User, error) + func (q *Queries) GetAnalysis(ctx context.Context, arg *GetAnalysisParams) (*Analysis, error) + func (q *Queries) GetUser(ctx context.Context, arg *GetUserParams) (*User, error) + func (q *Queries) ListUsers(ctx context.Context) ([]*User, error) + func (q *Queries) WithTx(tx pgx.Tx) *Queries + type ReadQuerier interface + GetAnalysis func(ctx context.Context, arg *GetAnalysisParams) (*Analysis, error) + GetUser func(ctx context.Context, arg *GetUserParams) (*User, error) + ListUsers func(ctx context.Context) ([]*User, error) + type ReadQueries struct + func NewReadQueries(database DBTX) *ReadQueries + func (q *ReadQueries) GetAnalysis(ctx context.Context, arg *GetAnalysisParams) (*Analysis, error) + func (q *ReadQueries) GetUser(ctx context.Context, arg *GetUserParams) (*User, error) + func (q *ReadQueries) ListUsers(ctx context.Context) ([]*User, error) + func (q *ReadQueries) WithTx(tx pgx.Tx) *ReadQueries + type RouteOption func(*routeOptions) + func ReadFromPrimary() RouteOption + func WithTx(tx pgx.Tx) RouteOption + type ShardResolver interface + Tenant func(tenantID int64) SK + type ShardedQueries struct + func NewShardedQueries[SK any](mesh *pgmesh.Mesh[*ReadQueries, *StoreQueries, SK], resolver ShardResolver[SK]) *ShardedQueries[SK] + func (q *ShardedQueries[SK]) CreateUser(ctx context.Context, arg *CreateUserParams, routeOptions ...RouteOption) (*User, error) + func (q *ShardedQueries[SK]) GetAnalysis(ctx context.Context, arg *GetAnalysisParams, routeOptions ...RouteOption) (*Analysis, error) + func (q *ShardedQueries[SK]) GetUser(ctx context.Context, arg *GetUserParams, routeOptions ...RouteOption) (*User, error) + type StoreQuerier interface + type StoreQueries struct + func NewStoreQueries(database DBTX) *StoreQueries + func (q *StoreQueries) WithMirrors(qs ...*StoreQueries) *StoreQueries + func (q *StoreQueries) WithTx(tx pgx.Tx) *StoreQueries + type User struct + ID int64 + Name string + TenantID int64 + type WriteQuerier interface + CopyUsers func(ctx context.Context, arg []*CopyUsersParams) (int64, error) + CreateUser func(ctx context.Context, arg *CreateUserParams) (*User, error) + type WriteQueries struct + func NewWriteQueries(database DBTX) *WriteQueries + func (q *WriteQueries) CopyUsers(ctx context.Context, arg []*CopyUsersParams) (int64, error) + func (q *WriteQueries) CreateUser(ctx context.Context, arg *CreateUserParams) (*User, error) + func (q *WriteQueries) WithMirrors(qs ...*WriteQueries) *WriteQueries + func (q *WriteQueries) WithTx(tx pgx.Tx) *WriteQueries
Go to main page