samepackage

type Analyses interface {
	AnalysesReader
	AnalysesWriter
}

type AnalysesReader interface {
	// GetAnalysis executes the generated GetAnalysis query.
	GetAnalysis(ctx context.Context, arg *GetAnalysisT, storeOptions ...QueryOption) (*Analysis, error)
	// GetTenantUserAnalysis executes the generated GetTenantUserAnalysis query.
	GetTenantUserAnalysis(ctx context.Context, arg *GetTenantUserAnalysisT, storeOptions ...QueryOption) (*GetTenantUserAnalysisRow, 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 CopyUsersParams struct {
	ID       int64
	TenantID int64
	Name     string
}

type CopyUsersT struct {
	TenantKey
	ID   int64
	Name string
}

type CreateUserParams struct {
	ID       int64
	TenantID int64
	Name     string
}

type CreateUserT struct {
	TenantKey
	ID   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
	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
}

type GetAnalysisParams struct {
	TenantID int64
	ID       int64
}

type GetAnalysisT struct {
	TenantKey
	ID int64
}

type GetTenantUserAnalysisParams struct {
	UserID     int64
	AnalysisID int64
}

type GetTenantUserAnalysisRow struct {
	UserID     int64
	AnalysisID int64
}

type GetTenantUserAnalysisT struct {
	TenantKey
	UserID     int64
	AnalysisID int64
}

type GetUserParams struct {
	TenantID int64
	ID       int64
}

type GetUserT struct {
	TenantKey
	ID int64
}

type ListP2PMessageIDsByChatParams struct {
	Limit        int32
	UserID       int64
	PeerID       int64
	CreatedSince pgtype.Timestamptz
	LastID       interface{}
}

type ListP2PMessageIDsByChatT struct {
	MessageKey
	Limit        int32
	PeerID       int64
	CreatedSince pgtype.Timestamptz
	LastID       interface{}
}

type ListP2PMessagesByChatParams struct {
	Limit        int32
	UserID       int64
	PeerID       int64
	CreatedSince pgtype.Timestamptz
	LastID       interface{}
}

type ListP2PMessagesByChatT struct {
	MessageKey
	Limit        int32
	PeerID       int64
	CreatedSince pgtype.Timestamptz
	LastID       interface{}
}

type ListUsersByIDsT struct {
	TenantKey
	ID int64
}

type Message struct {
	ID              interface{}
	UserID          int64
	ToUserOrGroupID int64
	InGroup         bool
	CreatedAt       pgtype.Timestamptz
	DeletedAt       pgtype.Timestamptz
}

type MessageInbox struct {
	ID              int64
	ToUserOrGroupID *int64
}

type MessageKey struct {
	UserID          int64
	ToUserOrGroupID int64
	InGroup         bool
}

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

type Querier interface {
	// kind: write
	// shard: tenantKey(tenant_id)
	// store: Users
	CopyUsers(ctx context.Context, arg []*CopyUsersParams) (int64, error)
	// kind: write
	// shard: tenantKey(tenant_id)
	// store: Users
	CreateUser(ctx context.Context, arg *CreateUserParams) (*User, error)
	// kind: write
	// shard: all()
	// store: Users
	DeleteAllUsers(ctx context.Context) error
	// kind: write
	// shard: all()
	// store: Users
	DeleteAllUsersByName(ctx context.Context, name string) (int64, error)
	// kind: read
	// shard: tenantKey(tenant_id)
	// store: Analyses
	GetAnalysis(ctx context.Context, arg *GetAnalysisParams) (*Analysis, error)
	// kind: read
	// shard: tenantKey(tenant_id)
	// store: Analyses
	GetTenantUserAnalysis(ctx context.Context, arg *GetTenantUserAnalysisParams) (*GetTenantUserAnalysisRow, error)
	// kind: read
	// shard: tenantKey(tenant_id)
	// store: Users
	GetUser(ctx context.Context, arg *GetUserParams) (*User, error)
	// kind: read
	// shard: all()
	// store: Users
	ListAllUsers(ctx context.Context) ([]*User, error)
	// kind: read
	// shard: messageKey(user_id, to_user_or_group_id, in_group)
	// store: QueryMessage
	ListP2PMessageIDsByChat(ctx context.Context, arg *ListP2PMessageIDsByChatParams) ([]interface{}, error)
	// kind: read
	// shard: messageKey(user_id, to_user_or_group_id, in_group)
	// store: QueryMessage
	ListP2PMessagesByChat(ctx context.Context, arg *ListP2PMessagesByChatParams) ([]*Message, error)
	// kind: read
	// shard: tenantKey(tenant_id)
	// store: Users
	ListUsersByIDs(ctx context.Context, ids []int64) ([]*User, error)
	// kind: write
	// shard: tenantKey(tenant_id)
	// store: Users
	UpdateUserName(ctx context.Context, arg *UpdateUserNameParams) (*User, error)
}

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

type QueryMessage interface {
	QueryMessageReader
	QueryMessageWriter
}

type QueryMessageReader interface {
	// ListP2PMessageIDsByChat executes the generated ListP2PMessageIDsByChat query.
	ListP2PMessageIDsByChat(ctx context.Context, arg *ListP2PMessageIDsByChatT, storeOptions ...QueryOption) ([]interface{}, error)
	// ListP2PMessagesByChat executes the generated ListP2PMessagesByChat query.
	ListP2PMessagesByChat(ctx context.Context, arg *ListP2PMessagesByChatT, storeOptions ...QueryOption) ([]*Message, error)
}

type QueryMessageWriter interface {
}

type QueryOption func(*queryOptions)

type ShardResolver[SK any] interface {
	// MessageKey resolves the "messageKey" shard route.
	MessageKey(key MessageKey) SK
	// TenantKey resolves the "tenantKey" shard route.
	TenantKey(key TenantKey) SK
}

type ShardedOption func(*shardedOptions)

type SingletonOption func(*singletonConfig)

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

type StoreOption func(*storeOptions)

type TenantKey struct {
	TenantID int64
}

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

type UpdateUserNameParams struct {
	TenantID int64
	ID       int64
	Name     string
}

type UpdateUserNameT struct {
	TenantKey
	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 *GetUserT, storeOptions ...QueryOption) (*User, error)
	// ListAllUsers executes the generated ListAllUsers query.
	ListAllUsers(ctx context.Context, storeOptions ...QueryOption) ([]*User, error)
	// ListUsersByIDs executes the generated ListUsersByIDs query.
	ListUsersByIDs(ctx context.Context, arg []*ListUsersByIDsT, storeOptions ...QueryOption) ([]*User, error)
}

type UsersWriter interface {
	// CopyUsers executes the generated CopyUsers query.
	CopyUsers(ctx context.Context, arg []*CopyUsersT, storeOptions ...QueryOption) (int64, error)
	// CopyUsersAsync accepts rows for asynchronous COPY.
	CopyUsersAsync(ctx context.Context, arg []*CopyUsersT) *pgmesh.Future[int64]
	// FlushCopyUsers drains asynchronous submissions accepted before its barrier.
	FlushCopyUsers(ctx context.Context) error
	// CreateUser executes the generated CreateUser query.
	CreateUser(ctx context.Context, arg *CreateUserT, storeOptions ...QueryOption) (*User, error)
	// DeleteAllUsers executes the generated DeleteAllUsers query.
	DeleteAllUsers(ctx context.Context, storeOptions ...QueryOption) error
	// DeleteAllUsersByName executes the generated DeleteAllUsersByName query.
	DeleteAllUsersByName(ctx context.Context, name string, storeOptions ...QueryOption) (int64, error)
	// UpdateUserName executes the generated UpdateUserName query.
	UpdateUserName(ctx context.Context, arg *UpdateUserNameT, storeOptions ...QueryOption) (*User, error)
}