grpcapp

Documentation

Index

• func InterceptorLogger(l *slog.Logger) logging.Logger
• type App
  • func New(opts *GRPCOpts, storage *services.StorageService, dht *services.DHTService) *App
  • func (a *App) MustRun(notifyReady chan<- bool)
  • func (a *App) Run(notifyReady chan<- bool) error
  • func (a *App) Stop()
• type GRPCOpts

Functions

func InterceptorLogger

func InterceptorLogger(l *slog.Logger) logging.Logger

InterceptorLogger adapts slog logger to interceptor logger.

Types

type App

type App struct {
	// contains filtered or unexported fields
}

func New

func New(opts *GRPCOpts, storage *services.StorageService, dht *services.DHTService) *App

New creates new gRPC server app

func (*App) MustRun

func (a *App) MustRun(notifyReady chan<- bool)

MustRun runs gRPC server and panics if any error occurs

func (*App) Run

func (a *App) Run(notifyReady chan<- bool) error

Run runs gRPC server

func (*App) Stop

func (a *App) Stop()

Stop stops gRPC server

type GRPCOpts

type GRPCOpts struct {
	Port   int
	Logger *slog.Logger

	NotifyRebase    chan<- bool
	ReplicationChan chan<- *cas.KeyHashPair
}