store

type Analyses interface {
	AnalysesReader
	AnalysesWriter
}

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

type AnalysesWriter interface {
}

type Analysis = db.Analysis

type AnalysisState = db.AnalysisState

type CopyUsersParams = db.CopyUsersParams

type CreateUserParams = db.CreateUserParams

type GetAnalysisParams = db.GetAnalysisParams

type GetTenantUserAnalysisParams = db.GetTenantUserAnalysisParams

type GetTenantUserAnalysisRow = db.GetTenantUserAnalysisRow

type GetTenantUserAnalysisShardParams struct {
	UserID     int64
	AnalysisID int64
	TenantID   int64
}

type GetUserParams = db.GetUserParams

type ListP2PMessageIDsByChatParams = db.ListP2PMessageIDsByChatParams

type ListP2PMessageIDsByChatShardParams struct {
	Limit           int32
	UserID          int64
	PeerID          int64
	CreatedSince    pgtype.Timestamptz
	LastID          interface{}
	ToUserOrGroupID int64
	InGroup         bool
}

type ListP2PMessagesByChatParams = db.ListP2PMessagesByChatParams

type ListP2PMessagesByChatShardParams struct {
	Limit           int32
	UserID          int64
	PeerID          int64
	CreatedSince    pgtype.Timestamptz
	LastID          interface{}
	ToUserOrGroupID int64
	InGroup         bool
}

type Message = db.Message

type NullAnalysisState = db.NullAnalysisState

type QueryMessage interface {
	QueryMessageReader
	QueryMessageWriter
}

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

type QueryMessageWriter interface {
}

type QueryOption func(*queryOptions)

type ShardResolver[SK any] interface {
	// Messagekey resolves the "messageKey" shard route.
	Messagekey(userID int64, toUserOrGroupID int64, inGroup bool) SK
	// 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
	// QueryMessage returns the QueryMessage query group.
	QueryMessage() QueryMessage
	// Users returns the Users query group.
	Users() Users
}

type StoreOption func(*storeOptions)

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

type UpdateUserNameParams = db.UpdateUserNameParams

type User = db.User

type Users interface {
	UsersReader
	UsersWriter
}

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

type UsersWriter interface {
	// CopyUsers executes the generated CopyUsers query.
	CopyUsers(ctx context.Context, arg []*CopyUsersParams, storeOptions ...QueryOption) (int64, error)
	// CreateUser executes the generated CreateUser query.
	CreateUser(ctx context.Context, arg *CreateUserParams, 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 *UpdateUserNameParams, storeOptions ...QueryOption) (*User, error)
}