gateway

package

v0.0.0-...-c188a41 Latest Latest Go to latest Published: Oct 12, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/billyyoyo/microj

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func LogHandler(next fasthttp.RequestHandler) fasthttp.RequestHandler
func RecoverHandler(next fasthttp.RequestHandler) fasthttp.RequestHandler
func RetFailed(ctx *fasthttp.RequestCtx, code int, msg ...string)
type Doer
type GatewayServer
- func NewGateway() *GatewayServer
type Route
- func (r *Route) String() string

Constants ¶

View Source

const (
	MICRO_SERVICE_NAME   = "micro-service-name"
	MICRO_SERVICE_PATH   = "micro-service-path"
	MICRO_SERVICE_SCHEMA = "micro-service-schema"

	CONTENT_TYPE = "application/json"
)

Variables ¶

This section is empty.

Functions ¶

func LogHandler ¶

func LogHandler(next fasthttp.RequestHandler) fasthttp.RequestHandler

func RecoverHandler ¶

func RecoverHandler(next fasthttp.RequestHandler) fasthttp.RequestHandler

func RetFailed ¶

func RetFailed(ctx *fasthttp.RequestCtx, code int, msg ...string)

Types ¶

type Doer ¶

type Doer interface {
	LBName() string
	ServiceName() string
	Do(ctx context.Context, method, path string, in []byte) (out []byte, err error)
}

type GatewayServer ¶

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

func NewGateway ¶

func NewGateway() *GatewayServer

func (*GatewayServer) AddInterceptor ¶

func (s *GatewayServer) AddInterceptor(i int32, n func(next fasthttp.RequestHandler) fasthttp.RequestHandler) *GatewayServer

func (*GatewayServer) AddRpcEndpoint ¶

func (s *GatewayServer) AddRpcEndpoint(d Doer) *GatewayServer

func (*GatewayServer) Init ¶

func (s *GatewayServer) Init()

func (*GatewayServer) Run ¶

func (s *GatewayServer) Run()

func (*GatewayServer) Stop ¶

func (s *GatewayServer) Stop()

type Route ¶

type Route struct {
	Id     string `yaml:"id"`
	Path   string `yaml:"path"`
	Schema string `yaml:"schema"`
}

func (*Route) String ¶

func (r *Route) String() string

Source Files ¶

View all Source files

gateway.go

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