cmd

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
• func SetupWS(app *fiber.App, routes ...string) websocket.Config
• type GrpcServer
  • func (s *GrpcServer) BuildIndex(ctx context.Context, req *protosearch.BuildRequest) (res *protosearch.BuildResponse, err error)
  • func (s *GrpcServer) Init(ctx 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)

Functions

func CreateApp

func CreateApp(conf *cfg.Config) *fiber.App

func RunGrpcServer

func RunGrpcServer(s *GrpcServer)

RunGrpcServer is the entry point for the GRPC server.

func SetupLogger

func SetupLogger(conf *cfg.Config, logger *zerolog.Logger) fiber.Handler

func SetupMiddlewares

func SetupMiddlewares(conf *cfg.Config,
	logger *zerolog.Logger,
) []fiber.Handler

func SetupWS

func SetupWS(app *fiber.App, routes ...string) websocket.Config

SetupWS MUST be called before SetupRoutes Otherwise the websocket handler will not be 'shadowed' by the static file handler

Types

type GrpcServer

type GrpcServer struct {
	shutdown.UnimplementedShutdownServiceServer
	protodb.UnimplementedDBServer
	protosearch.UnimplementedSearchServer
	Cache  *redis.Storage
	App    *fiber.App
	Log    *zerolog.Logger
	Config *cfg.GrpcConfig
}

func (*GrpcServer) BuildIndex

func (s *GrpcServer) BuildIndex(
	ctx context.Context,
	req *protosearch.BuildRequest,
) (res *protosearch.BuildResponse, err error)

func (*GrpcServer) Init

func (s *GrpcServer) Init(ctx context.Context, req *protodb.InitRequest) (*protodb.InitResponse, error)

func (*GrpcServer) Migrate

func (s *GrpcServer) Migrate(ctx context.Context, req *protodb.MigrateRequest) (*protodb.MigrateResponse, error)

func (*GrpcServer) SendShutdown

func (s *GrpcServer) SendShutdown(ctx context.Context, req *shutdown.ShutdownRequest) (*shutdown.ShutdownResponse, error)