server

Documentation

Overview

Package server implements the query server for making database queries to otterdb.

Index

• type Server
  • func New(conf config.ServerConfig) (s *Server, err error)
  • func (s *Server) Run(errc chan<- error, sock net.Listener)
  • func (s *Server) Serve(errc chan<- error) (err error)
  • func (s *Server) Shutdown() (err error)

Types

type Server

type Server struct {
	health.ProbeServer
	api.UnimplementedOtterServer
	// contains filtered or unexported fields
}

func New

func New(conf config.ServerConfig) (s *Server, err error)

func (*Server) Run

func (s *Server) Run(errc chan<- error, sock net.Listener)

Run the gRPC server on the specified socket. This method can be used to serve TCP requests or to connect to a bufconn for testing purposes. This method blocks while the server is running so it should be run in a go routine.

func (*Server) Serve

func (s *Server) Serve(errc chan<- error) (err error)

func (*Server) Shutdown

func (s *Server) Shutdown() (err error)