fixture

type Analyses interface {
	AnalysesReader
	AnalysesWriter
}

type AnalysesReader interface {
	// GetAnalysis executes the generated GetAnalysis query.
	GetAnalysis(ctx context.Context, arg *GetAnalysisParams, storeOptions ...QueryOption) (*Analysis, error)
}

type AnalysesWriter interface {
}

type Analysis struct {
	ID           int64
	TenantID     int64
	Description  *string
	State        NullAnalysisState
	Source       netip.Addr
	ActiveWindow pgtype.Range[pgtype.Timestamptz]
}

type AnalysisState string

type CreateUserParams struct {
	ID       int64
	TenantID int64
	Name     string
}

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 GetAnalysisParams struct {
	TenantID int64
	ID       int64
}

type GetUserParams struct {
	TenantID int64
	ID       int64
}

type NullAnalysisState struct {
	AnalysisState AnalysisState
	Valid         bool // Valid is true if AnalysisState is not NULL
}

type Querier interface {
	// kind: write
	// shard: tenant(tenant_id)
	// store: Users
	CreateUser(ctx context.Context, arg *CreateUserParams) (*User, error)
	// kind: read
	// shard: tenant(tenant_id)
	// store: Analyses
	GetAnalysis(ctx context.Context, arg *GetAnalysisParams) (*Analysis, error)
	// kind: read
	// shard: tenant(tenant_id)
	// store: Users
	GetUser(ctx context.Context, arg *GetUserParams) (*User, error)
	// kind: write
	// shard: tenant(tenant_id)
	// store: Users
	UpdateUserName(ctx context.Context, arg *UpdateUserNameParams) (*User, error)
}

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

type QueryOption func(*queryOptions)

type ShardResolver[SK any] interface {
	// Tenant resolves the "tenant" shard route.
	Tenant(tenantID int64) SK
}

type ShardedOption func(*shardedOptions)

type SingletonOption func(*singletonConfig)

type Store interface {
	// Analyses returns the Analyses query group.
	Analyses() Analyses
	// Users returns the Users query group.
	Users() Users
}

type StoreOption func(*storeOptions)

type Topology interface {
	// contains filtered or unexported methods
}

type UpdateUserNameParams struct {
	TenantID int64
	ID       int64
	Name     string
}

type User struct {
	ID       int64
	TenantID int64
	Name     string
}

type Users interface {
	UsersReader
	UsersWriter
}

type UsersReader interface {
	// GetUser executes the generated GetUser query.
	GetUser(ctx context.Context, arg *GetUserParams, storeOptions ...QueryOption) (*User, error)
}

type UsersWriter interface {
	// CreateUser executes the generated CreateUser query.
	CreateUser(ctx context.Context, arg *CreateUserParams, storeOptions ...QueryOption) (*User, error)
	// UpdateUserName executes the generated UpdateUserName query.
	UpdateUserName(ctx context.Context, arg *UpdateUserNameParams, storeOptions ...QueryOption) (*User, error)
}