muxer

Documentation

Index

• type GRPCServer
  • func NewGRPCServer(cfg *config.Config, tenantMgr *metadata.TenantManager, ...) *GRPCServer
  • func (s *GRPCServer) Start(mux cmux.CMux) error
• type HTTPServer
  • func NewHTTPServer(cfg *config.Config, tenantMgr *metadata.TenantManager, ...) *HTTPServer
  • func (s *HTTPServer) Start(mux cmux.CMux) error
• type Muxer
  • func NewMuxer(cfg *config.Config, tenantMgr *metadata.TenantManager, ...) *Muxer
  • func (m *Muxer) RegisterServices(kvStore kv.KeyValueStore, searchStore search.Store, ...)
  • func (m *Muxer) Start(host string, port int16) error
• type Server

Types

type GRPCServer

type GRPCServer struct {
	*grpc.Server
}

func NewGRPCServer

func NewGRPCServer(cfg *config.Config, tenantMgr *metadata.TenantManager, txMgr *transaction.Manager) *GRPCServer

func (*GRPCServer) Start

func (s *GRPCServer) Start(mux cmux.CMux) error

type HTTPServer

type HTTPServer struct {
	Router chi.Router
	Inproc *inprocgrpc.Channel
}

func NewHTTPServer

func NewHTTPServer(cfg *config.Config, tenantMgr *metadata.TenantManager, txMgr *transaction.Manager) *HTTPServer

func (*HTTPServer) Start

func (s *HTTPServer) Start(mux cmux.CMux) error

type Muxer

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

func NewMuxer

func NewMuxer(cfg *config.Config, tenantMgr *metadata.TenantManager, txMgr *transaction.Manager) *Muxer

func (*Muxer) RegisterServices

func (m *Muxer) RegisterServices(kvStore kv.KeyValueStore, searchStore search.Store, tenantMgr *metadata.TenantManager, txMgr *transaction.Manager)

func (*Muxer) Start

func (m *Muxer) Start(host string, port int16) error

type Server

type Server interface {
	Start(mux cmux.CMux) error
}