server

Documentation

Index

• func RunHttpServer(ctx context.Context, config cfg.Config) job.WithGracefulShutdown
• func RunServer(ctx context.Context, config cfg.Config) job.WithGracefulShutdown
• type SearchServiceServer
  • func NewSearchServiceServer(i2v img2vec.Img2Vec, searchHandler search.Handler, fetcher productmeta.Fetcher, ...) *SearchServiceServer
  • func (s *SearchServiceServer) AsyncSearch(req *pb.SearchRequest, stream pb.SearchService_AsyncSearchServer) error
  • func (s *SearchServiceServer) Crop(ctx context.Context, req *pb.CropRequest) (*pb.CropResponse, error)
  • func (s *SearchServiceServer) Search(ctx context.Context, req *pb.SearchRequest) (*pb.SearchResponse, error)

Functions

func RunHttpServer

func RunHttpServer(ctx context.Context, config cfg.Config) job.WithGracefulShutdown

func RunServer

func RunServer(ctx context.Context, config cfg.Config) job.WithGracefulShutdown

Types

type SearchServiceServer

type SearchServiceServer struct {
	pb.UnimplementedSearchServiceServer
	// contains filtered or unexported fields
}

func NewSearchServiceServer

func NewSearchServiceServer(
	i2v img2vec.Img2Vec,
	searchHandler search.Handler,
	fetcher productmeta.Fetcher,
	rankers map[pb.Ranker]rank.Ranker,
	objectDetector od.ObjectDetector,
	logSearchImage bool,
) *SearchServiceServer

func (*SearchServiceServer) AsyncSearch

func (s *SearchServiceServer) AsyncSearch(req *pb.SearchRequest, stream pb.SearchService_AsyncSearchServer) error

func (*SearchServiceServer) Crop

func (s *SearchServiceServer) Crop(ctx context.Context, req *pb.CropRequest) (*pb.CropResponse, error)

func (*SearchServiceServer) Search

func (s *SearchServiceServer) Search(ctx context.Context, req *pb.SearchRequest) (*pb.SearchResponse, error)