searchservices

Documentation

Index

• func CreateIndexing(log *zap.Logger, db *sql.DB, elasticOpt *common.ElasticOptions) (*elasticsearch.Client, error)
• func StartSearchServer(log *zap.Logger, isTest bool, pwd string, dbOpt *common.DBOptions, ...)
• type SearchService
  • func NewSearchService(log *zap.Logger, dbOpt *common.DBService, es *elasticsearch.Client, ...) *SearchService
  • func (s *SearchService) Search(ctx context.Context, in *searchproto.CreateSearchRequest) (*searchproto.SearchResults, error)

Functions

func CreateIndexing

func CreateIndexing(log *zap.Logger, db *sql.DB, elasticOpt *common.ElasticOptions) (*elasticsearch.Client, error)

CreateIndexing - Create Index

func StartSearchServer

func StartSearchServer(log *zap.Logger, isTest bool, pwd string, dbOpt *common.DBOptions, redisOpt *common.RedisOptions, mailerOpt *common.MailerOptions, grpcServerOpt *common.GrpcServerOptions, jwtOpt *common.JWTOptions, oauthOpt *common.OauthOptions, userOpt *common.UserOptions, jaegerTracerOpt *common.JaegerTracerOptions, promOpt *common.PromOptions, elasticOpt *common.ElasticOptions, roleOpt *common.RoleOptions, dbService *common.DBService, redisService *common.RedisService, mailerService common.MailerIntf)

StartSearchServer - start search server

Types

type SearchService

type SearchService struct {
	DBService           *common.DBService
	ElasticSearchClient *elasticsearch.Client
	IndexName           string
	searchproto.UnimplementedSearchServiceServer
	// contains filtered or unexported fields
}

SearchService - For accessing search service

func NewSearchService

func NewSearchService(log *zap.Logger, dbOpt *common.DBService, es *elasticsearch.Client, indexName string) *SearchService

NewSearchService - Create search service

func (*SearchService) Search

func (s *SearchService) Search(ctx context.Context, in *searchproto.CreateSearchRequest) (*searchproto.SearchResults, error)

Search - search query string