transport

Documentation

Index

• type GRPCServer
  • func NewGRPCServer(ctx context.Context, logger *log.Logger, services ...GRPCService) *GRPCServer
  • func (s *GRPCServer) AddGRPCServices(services ...GRPCService)
  • func (s *GRPCServer) GetServer() *grpc.Server
  • func (s GRPCServer) MapRoutes()
• type GRPCService
• type HTTPServer
  • func NewHTTPServer(k domain.KernelStore, l *log.Logger, handlers ...Handler) *HTTPServer
  • func (s *HTTPServer) AddHandlers(hs ...Handler)
  • func (s *HTTPServer) GetRouter() *mux.Router
  • func (s *HTTPServer) GetServer() *http.Server
  • func (s *HTTPServer) MapRoutes()
• type Handler
• type TransportFacade
  • func NewTransportFacade(ctx context.Context, kernel domain.KernelStore, logger *log.Logger, ...) (*TransportFacade, func(), error)
  • func (f TransportFacade) GetKernel() domain.KernelStore

Types

type GRPCServer

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

GRPCServer gRPC Server proxy

func NewGRPCServer

func NewGRPCServer(ctx context.Context, logger *log.Logger, services ...GRPCService) *GRPCServer

NewGRPCServer GRCPServer factory method - Create a new preconfigured gRPC Server instance

func (*GRPCServer) AddGRPCServices

func (s *GRPCServer) AddGRPCServices(services ...GRPCService)

AddGRPCServices Runtime GRPCServer service injection using an strategy-like pattern

func (*GRPCServer) GetServer

func (s *GRPCServer) GetServer() *grpc.Server

GetServer Obtain GRPCServer's root grpc.Server reference

func (GRPCServer) MapRoutes

func (s GRPCServer) MapRoutes()

MapRoutes Runtime GRPCServer service mapping to internal server

type GRPCService

type GRPCService interface {
	SetRoutes(s *grpc.Server)
	GetName() string
}

GRPCService gRPC service mediator

type HTTPServer

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

HTTPServer HTTP Server proxy

func NewHTTPServer

func NewHTTPServer(k domain.KernelStore, l *log.Logger, handlers ...Handler) *HTTPServer

NewHTTPServer HTTPServer factory method - Create a new preconfigured HTTP Server instance

func (*HTTPServer) AddHandlers

func (s *HTTPServer) AddHandlers(hs ...Handler)

AddHandlers Runtime HTTPServer handler injection using an strategy-like pattern

func (*HTTPServer) GetRouter

func (s *HTTPServer) GetRouter() *mux.Router

GetRouter Obtain HTTPServer's root mux.Router reference

func (*HTTPServer) GetServer

func (s *HTTPServer) GetServer() *http.Server

GetServer Obtain HTTPServer's root http.Server reference

func (*HTTPServer) MapRoutes

func (s *HTTPServer) MapRoutes()

MapRoutes Runtime HTTPServer handler mapping to internal mux

type Handler

type Handler interface {
	SetRoutes(r *mux.Router)
	GetName() string
}

Handler HTTP handler container/mediator

type TransportFacade

type TransportFacade struct {
	HTTP *HTTPServer
	GRPC *GRPCServer
	// contains filtered or unexported fields
}

TransportFacade Encapsulates transport-tier complexity

func NewTransportFacade

func NewTransportFacade(ctx context.Context, kernel domain.KernelStore, logger *log.Logger, handlers []Handler,
	rpcServices []GRPCService) (*TransportFacade, func(), error)

NewTransportFacade create a new TransportFacade encapsulated sub-ecosystem

func (TransportFacade) GetKernel

func (f TransportFacade) GetKernel() domain.KernelStore

GetKernel get transport current kernel