transport

package
v0.0.0-...-2af345c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 13, 2020 License: AGPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL