Documentation
¶
Index ¶
- func CreateApp(conf *cfg.Config) *fiber.App
- func RunGrpcServer(s *GrpcServer)
- func SetupLogger(conf *cfg.Config, logger *zerolog.Logger) fiber.Handler
- func SetupMiddlewares(conf *cfg.Config, logger *zerolog.Logger) []fiber.Handler
- type GrpcServer
- func (s *GrpcServer) BuildIndex(ctx context.Context, req *protosearch.BuildRequest) (res *protosearch.BuildResponse, err error)
- func (s *GrpcServer) Init(_ context.Context, req *protodb.InitRequest) (*protodb.InitResponse, error)
- func (s *GrpcServer) Migrate(ctx context.Context, req *protodb.MigrateRequest) (*protodb.MigrateResponse, error)
- func (s *GrpcServer) SendShutdown(ctx context.Context, req *shutdown.ShutdownRequest) (*shutdown.ShutdownResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunGrpcServer ¶ added in v0.8.3
func RunGrpcServer(s *GrpcServer)
RunGrpcServer is the entry point for the GRPC server.
Types ¶
type GrpcServer ¶ added in v0.8.3
type GrpcServer struct { shutdown.UnimplementedShutdownServiceServer protodb.UnimplementedDBServer protosearch.UnimplementedSearchServer Cache *redis.Storage App *fiber.App Log *zerolog.Logger Config *cfg.GrpcConfig }
func (*GrpcServer) BuildIndex ¶ added in v0.9.14
func (s *GrpcServer) BuildIndex( ctx context.Context, req *protosearch.BuildRequest, ) (res *protosearch.BuildResponse, err error)
func (*GrpcServer) Init ¶ added in v0.8.5
func (s *GrpcServer) Init(_ context.Context, req *protodb.InitRequest) (*protodb.InitResponse, error)
func (*GrpcServer) Migrate ¶ added in v0.8.5
func (s *GrpcServer) Migrate(ctx context.Context, req *protodb.MigrateRequest) (*protodb.MigrateResponse, error)
func (*GrpcServer) SendShutdown ¶ added in v0.8.3
func (s *GrpcServer) SendShutdown(ctx context.Context, req *shutdown.ShutdownRequest) (*shutdown.ShutdownResponse, error)
Click to show internal directories.
Click to hide internal directories.