pgsearch

Documentation

Index

• Variables
• func MapUnicodeSegmentation(original map[string]string) map[string]string
• func StringUnicodeSegmentation(original string) string
• type Service
  • func (s *Service) DeleteUser(ctx context.Context, userID string) error
  • func (s *Service) QueryUser(ctx context.Context, searchKeyword string, filters user.FilterOptions, ...) ([]apimodel.PageItemRef, error)
  • func (s *Service) ReindexUser(ctx context.Context, user *apimodel.SearchUserSource) error
• type Store
  • func NewStore(appID config.AppID, sqlBuilder *searchdb.SQLBuilder, ...) *Store
  • func (s *Store) CleanupUsers(ctx context.Context, appID string, keepUserIDs []string) (int64, error)
  • func (s *Store) DeleteUser(ctx context.Context, appID string, userID string) error
  • func (s *Store) QueryUser(ctx context.Context, searchKeyword string, filters user.FilterOptions, ...) ([]apimodel.PageItemRef, error)
  • func (s *Store) UpsertUsers(ctx context.Context, users []*model.SearchUserSource) error

Variables

var DependencySet = wire.NewSet(
	NewStore,
	wire.Struct(new(Service), "*"),
)

var ErrMissingCredential = apierrors.InternalError.WithReason("SearchDisabled").New("search database credential is not provided")

Functions

func MapUnicodeSegmentation

func MapUnicodeSegmentation(original map[string]string) map[string]string

func StringUnicodeSegmentation

func StringUnicodeSegmentation(original string) string

Types

type Service

type Service struct {
	AppID    *config.AppID
	Store    *Store
	Database *searchdb.Handle
}

func (*Service) DeleteUser

func (s *Service) DeleteUser(
	ctx context.Context, userID string) error

func (*Service) QueryUser

func (s *Service) QueryUser(
	ctx context.Context,
	searchKeyword string,
	filters user.FilterOptions,
	sortOption user.SortOption,
	pageArgs graphqlutil.PageArgs) ([]apimodel.PageItemRef, error)

func (*Service) ReindexUser

func (s *Service) ReindexUser(
	ctx context.Context, user *apimodel.SearchUserSource) error

type Store

type Store struct {
	AppID       config.AppID
	SQLBuilder  *searchdb.SQLBuilder
	SQLExecutor *searchdb.SQLExecutor
}

func NewStore

func NewStore(
	appID config.AppID,
	sqlBuilder *searchdb.SQLBuilder,
	sqlExecutor *searchdb.SQLExecutor,
) *Store

func (*Store) CleanupUsers

func (s *Store) CleanupUsers(ctx context.Context, appID string, keepUserIDs []string) (int64, error)

func (*Store) DeleteUser

func (s *Store) DeleteUser(ctx context.Context, appID string, userID string) error

func (*Store) QueryUser

func (s *Store) QueryUser(
	ctx context.Context,
	searchKeyword string,
	filters user.FilterOptions,
	sortOption user.SortOption,
	pageArgs graphqlutil.PageArgs) ([]apimodel.PageItemRef, error)

func (*Store) UpsertUsers

func (s *Store) UpsertUsers(ctx context.Context, users []*model.SearchUserSource) error