rk-gf

module
v0.0.10 Latest Latest
Warning

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

Go to latest
Published: Jan 18, 2022 License: Apache-2.0

README

rk-gf

build Go Report Card codecov License

Interceptor & bootstrapper designed for gogf/gf web framework. Documentation.

This belongs to rk-boot family. We suggest use this lib from rk-boot.

image

Table of Contents generated with DocToc

Architecture

image

Supported bootstrap

Bootstrap Description
YAML based Start gogf/gf microservice from YAML
Code based Start gogf/gf microservice from code

Supported instances

All instances could be configured via YAML or Code.

User can enable anyone of those as needed! No mandatory binding!

Instance Description
ghttp.Server Compatible with original gogf/gf service functionalities
Config Configure spf13/viper as config instance and reference it from YAML
Logger Configure uber-go/zap logger configuration and reference it from YAML
EventLogger Configure logging of RPC with rk-query and reference it from YAML
Credential Fetch credentials from remote datastore like ETCD.
Cert Fetch TLS/SSL certificates from remote datastore like ETCD and start microservice.
Prometheus Start prometheus client at client side and push metrics to pushgateway as needed.
Swagger Builtin swagger UI handler.
CommonService List of common APIs.
TV A Web UI shows microservice and environment information.
StaticFileHandler A Web UI shows files could be downloaded from server, currently support source of local and pkger.

Supported middlewares

All middlewares could be configured via YAML or Code.

User can enable anyone of those as needed! No mandatory binding!

Middleware Description
Metrics Collect RPC metrics and export to prometheus client.
Log Log every RPC requests as event with rk-query.
Trace Collect RPC trace and export it to stdout, file or jaeger with open-telemetry/opentelemetry-go.
Panic Recover from panic for RPC requests and log it.
Meta Send micsroservice metadata as header to client.
Auth Support [Basic Auth] and [API Key] authorization types.
RateLimit Limiting RPC rate globally or per path.
Timeout Timing out request by configuration.
CORS Server side CORS validation.
JWT Server side JWT validation.
Secure Server side secure validation.
CSRF Server side csrf validation.

Installation

go get github.com/rookie-ninja/rk-gf

Quick Start

In the bellow example, we will start microservice with bellow functionality and middlewares enabled via YAML.

  • gogf/gf server
  • Swagger UI
  • CommonService
  • TV
  • Prometheus Metrics (middleware)
  • Logging (middleware)
  • Meta (middleware)

Please refer example at example/boot/simple.

1.Create boot.yaml
---
gf:
  - name: greeter                     # Required
    port: 8080                        # Required
    enabled: true                     # Required
    tv:
      enabled: true                   # Optional, default: false
    prom:
      enabled: true                   # Optional, default: false
    sw:
      enabled: true                   # Optional, default: false
    commonService:
      enabled: true                   # Optional, default: false
    interceptors:
      loggingZap:
        enabled: true                 # Optional, default: false
      metricsProm:
        enabled: true                 # Optional, default: false
      meta:
        enabled: true                 # Optional, default: false
2.Create main.go
// Copyright (c) 2021 rookie-ninja
//
// Use of this source code is governed by an Apache-style
// license that can be found in the LICENSE file.
package main

import (
	"context"
	"github.com/gogf/gf/v2/net/ghttp"
	"github.com/rookie-ninja/rk-entry/entry"
	"github.com/rookie-ninja/rk-gf/boot"
	"net/http"
)

func main() {
	// Bootstrap basic entries from boot config.
	rkentry.RegisterInternalEntriesFromConfig("example/boot/simple/boot.yaml")

	// Bootstrap gf entry from boot config
	res := rkgf.RegisterGfEntriesWithConfig("example/boot/simple/boot.yaml")

	// Get rkgf.GfEntry
	gfEntry := res["greeter"].(*rkgf.GfEntry)
	gfEntry.Server.BindHandler("/v1/greeter", func(ctx *ghttp.Request) {
		ctx.Response.WriteHeader(http.StatusOK)
		ctx.Response.WriteJson(map[string]string{
			"message": "Hello!",
		})
	})
	
	// Bootstrap gf entry
	gfEntry.Bootstrap(context.Background())

	// Wait for shutdown signal
	rkentry.GlobalAppCtx.WaitForShutdownSig()

	// Interrupt gf entry
	gfEntry.Interrupt(context.Background())
}
3.Start server
$ go run main.go
4.Validation
4.1 GoFrame server

Try to test GoFrame Service with curl

# Curl to common service
$ curl localhost:8080/rk/v1/healthy
{"healthy":true}
4.2 Swagger UI

Please refer documentation for details of configuration.

By default, we could access swagger UI at http://localhost:8080/sw

sw

4.3 TV

Please refer documentation for details of configuration.

By default, we could access TV at http://localhost:8080/rk/v1/tv

tv

4.4 Prometheus Metrics

Please refer documentation for details of configuration.

By default, we could access prometheus client at http://localhost:8080/metrics

prom

4.5 Logging

Please refer documentation for details of configuration.

By default, we enable zap logger and event logger with encoding type of [console]. Encoding type of [json] is also supported.

2021-12-29T00:28:29.030+0800    INFO    boot/gf_entry.go:1050   Bootstrap gfEntry     {"eventId": "619d9c74-f484-4ca0-b600-e91c96e6ddd8", "entryName": "greeter"}
------------------------------------------------------------------------
endTime=2021-12-29T00:28:29.032702+08:00
startTime=2021-12-29T00:28:29.030675+08:00
elapsedNano=2027178
timezone=CST
ids={"eventId":"619d9c74-f484-4ca0-b600-e91c96e6ddd8"}
app={"appName":"rk","appVersion":"","entryName":"greeter","entryType":"GfEntry"}
env={"arch":"amd64","az":"*","domain":"*","hostname":"lark.local","localIP":"192.168.101.5","os":"darwin","realm":"*","region":"*"}
payloads={"commonServiceEnabled":true,"commonServicePathPrefix":"/rk/v1/","gfPort":8080,"promEnabled":true,"promPath":"/metrics","promPort":8080,"swEnabled":true,"swPath":"/sw/","tvEnabled":true,"tvPath":"/rk/v1/tv/"}
error={}
counters={}
pairs={}
timing={}
remoteAddr=localhost
operation=Bootstrap
resCode=OK
eventStatus=Ended
EOE
4.6 Meta

Please refer documentation for details of configuration.

By default, we will send back some metadata to client including gateway with headers.

$ curl -vs localhost:8080/rk/v1/healthy
...
< HTTP/1.1 200 OK
< Content-Type: application/json
< Server: GoFrame HTTP Server
< X-Request-Id: 9cc18bda-da7c-456b-acbe-0f07778a30cf
< X-Rk-App-Name: rk
< X-Rk-App-Unix-Time: 2021-12-29T00:59:39.262428+08:00
< X-Rk-App-Version: 
< X-Rk-Received-Time: 2021-12-29T00:59:39.262428+08:00
< Date: Tue, 28 Dec 2021 16:59:39 GMT
...
4.7 Send request

We registered /v1/greeter API in gogf/gf server and let's validate it!

$ curl -vs "localhost:8080/v1/greeter?name=rk-dev"
*   Trying ::1...
* TCP_NODELAY set
* Connected to localhost (::1) port 8080 (#0)
> GET /v1/greeter HTTP/1.1
> Host: localhost:8080
> User-Agent: curl/7.64.1
> Accept: */*
> 
< HTTP/1.1 200 OK
< Content-Type: application/json
< Server: GoFrame HTTP Server
< X-Request-Id: 5f08faa2-c682-4738-ae95-7792ae5743b8
< X-Rk-App-Name: rk
< X-Rk-App-Unix-Time: 2021-12-29T01:00:18.521554+08:00
< X-Rk-App-Version: 
< X-Rk-Received-Time: 2021-12-29T01:00:18.521554+08:00
< Date: Tue, 28 Dec 2021 17:00:18 GMT
< Content-Length: 20
< 
* Connection #0 to host localhost left intact
{"message":"Hello!"}
4.8 RPC logs

Bellow logs would be printed in stdout.

------------------------------------------------------------------------
endTime=2021-12-29T01:00:18.521684+08:00
startTime=2021-12-29T01:00:18.521544+08:00
elapsedNano=139743
timezone=CST
ids={"eventId":"5f08faa2-c682-4738-ae95-7792ae5743b8","requestId":"5f08faa2-c682-4738-ae95-7792ae5743b8"}
app={"appName":"rk","appVersion":"","entryName":"greeter","entryType":"GfEntry"}
env={"arch":"amd64","az":"*","domain":"*","hostname":"lark.local","localIP":"192.168.101.5","os":"darwin","realm":"*","region":"*"}
payloads={"apiMethod":"GET","apiPath":"/v1/greeter","apiProtocol":"HTTP/1.1","apiQuery":"","userAgent":"curl/7.64.1"}
error={}
counters={}
pairs={}
timing={}
remoteAddr=localhost:54594
operation=/v1/greeter
resCode=200
eventStatus=Ended
EOE
4.9 RPC prometheus metrics

Prometheus client will automatically register into gogf/gf instance at /metrics.

Access http://localhost:8080/metrics

image

YAML Options

User can start multiple gogf/gf instances at the same time. Please make sure use different port and name.

GoFrame
name description type default value
gf.name The name of gogf/gf server string N/A
gf.port The port of gogf/gf server integer nil, server won't start
gf.enabled Enable gogf/gf entry or not bool false
gf.description Description of gf entry. string ""
gf.cert.ref Reference of cert entry declared in cert entry string ""
gf.logger.zapLogger.ref Reference of zapLoggerEntry declared in zapLoggerEntry string ""
gf.logger.eventLogger.ref Reference of eventLoggerEntry declared in eventLoggerEntry string ""
CommonService
Path Description
/rk/v1/apis List APIs in current GfEntry.
/rk/v1/certs List CertEntry.
/rk/v1/configs List ConfigEntry.
/rk/v1/deps List dependencies related application, entire contents of go.mod file would be returned.
/rk/v1/entries List all Entries.
/rk/v1/gc Trigger GC
/rk/v1/healthy Get application healthy status.
/rk/v1/info Get application and process info.
/rk/v1/license Get license related application, entire contents of LICENSE file would be returned.
/rk/v1/logs List logger related entries.
/rk/v1/git Get git information.
/rk/v1/readme Get contents of README file.
/rk/v1/req List prometheus metrics of requests.
/rk/v1/sys Get OS stat.
/rk/v1/tv Get HTML page of /tv.
name description type default value
gf.commonService.enabled Enable embedded common service boolean false
Swagger
name description type default value
gf.sw.enabled Enable swagger service over gf server boolean false
gf.sw.path The path access swagger service from web string /sw
gf.sw.jsonPath Where the swagger.json files are stored locally string ""
gf.sw.headers Headers would be sent to caller as scheme of [key:value] []string []
Prometheus Client
name description type default value
gf.prom.enabled Enable prometheus boolean false
gf.prom.path Path of prometheus string /metrics
gf.prom.pusher.enabled Enable prometheus pusher bool false
gf.prom.pusher.jobName Job name would be attached as label while pushing to remote pushgateway string ""
gf.prom.pusher.remoteAddress PushGateWay address, could be form of http://x.x.x.x or x.x.x.x string ""
gf.prom.pusher.intervalMs Push interval in milliseconds string 1000
gf.prom.pusher.basicAuth Basic auth used to interact with remote pushgateway, form of [user:pass] string ""
gf.prom.pusher.cert.ref Reference of rkentry.CertEntry string ""
TV
name description type default value
gf.tv.enabled Enable RK TV boolean false
Static file handler
name description type default value
gf.static.enabled Optional, Enable static file handler boolean false
gf.static.path Optional, path of static file handler string /rk/v1/static
gf.static.sourceType Required, local and pkger supported string ""
gf.static.sourcePath Required, full path of source directory string ""
  • About pkger User can use pkger command line tool to embed static files into .go files.

Please use sourcePath like: github.com/rookie-ninja/rk-gf:/boot/assets

Middlewares
Log
name description type default value
gf.interceptors.loggingZap.enabled Enable log interceptor boolean false
gf.interceptors.loggingZap.zapLoggerEncoding json or console string console
gf.interceptors.loggingZap.zapLoggerOutputPaths Output paths []string stdout
gf.interceptors.loggingZap.eventLoggerEncoding json or console string console
gf.interceptors.loggingZap.eventLoggerOutputPaths Output paths []string false

We will log two types of log for every RPC call.

  • zapLogger

Contains user printed logging with requestId or traceId.

  • eventLogger

Contains per RPC metadata, response information, environment information and etc.

Field Description
endTime As name described
startTime As name described
elapsedNano Elapsed time for RPC in nanoseconds
timezone As name described
ids Contains three different ids(eventId, requestId and traceId). If meta interceptor was enabled or event.SetRequestId() was called by user, then requestId would be attached. eventId would be the same as requestId if meta interceptor was enabled. If trace interceptor was enabled, then traceId would be attached.
app Contains appName, appVersion, entryName, entryType.
env Contains arch, az, domain, hostname, localIP, os, realm, region. realm, region, az, domain were retrieved from environment variable named as REALM, REGION, AZ and DOMAIN. "*" means empty environment variable.
payloads Contains RPC related metadata
error Contains errors if occur
counters Set by calling event.SetCounter() by user.
pairs Set by calling event.AddPair() by user.
timing Set by calling event.StartTimer() and event.EndTimer() by user.
remoteAddr As name described
operation RPC method name
resCode Response code of RPC
eventStatus Ended or InProgress
  • example
------------------------------------------------------------------------
endTime=2021-11-01T23:31:01.706614+08:00
startTime=2021-11-01T23:31:01.706335+08:00
elapsedNano=278966
timezone=CST
ids={"eventId":"61cae46e-ea98-47b5-8a39-1090d015e09a","requestId":"61cae46e-ea98-47b5-8a39-1090d015e09a"}
app={"appName":"rk-gf","appVersion":"master-e4538d7","entryName":"greeter","entryType":"GfEntry"}
env={"arch":"amd64","az":"*","domain":"*","hostname":"lark.local","localIP":"192.168.1.104","os":"darwin","realm":"*","region":"*"}
payloads={"apiMethod":"GET","apiPath":"/rk/v1/healthy","apiProtocol":"HTTP/1.1","apiQuery":"","userAgent":"curl/7.64.1"}
error={}
counters={}
pairs={}
timing={}
remoteAddr=localhost:54376
operation=/rk/v1/healthy
resCode=200
eventStatus=Ended
EOE
Metrics
name description type default value
gf.interceptors.metricsProm.enabled Enable metrics interceptor boolean false
Auth

Enable the server side auth. codes.Unauthenticated would be returned to client if not authorized with user defined credential.

name description type default value
gf.interceptors.auth.enabled Enable auth interceptor boolean false
gf.interceptors.auth.basic Basic auth credentials as scheme of user:pass []string []
gf.interceptors.auth.apiKey API key auth []string []
gf.interceptors.auth.ignorePrefix The paths of prefix that will be ignored by interceptor []string []
Meta

Send application metadata as header to client.

name description type default value
gf.interceptors.meta.enabled Enable meta interceptor boolean false
gf.interceptors.meta.prefix Header key was formed as X--XXX string RK
Tracing
name description type default value
gf.interceptors.tracingTelemetry.enabled Enable tracing interceptor boolean false
gf.interceptors.tracingTelemetry.exporter.file.enabled Enable file exporter boolean RK
gf.interceptors.tracingTelemetry.exporter.file.outputPath Export tracing info to files string stdout
gf.interceptors.tracingTelemetry.exporter.jaeger.agent.enabled Export tracing info to jaeger agent boolean false
gf.interceptors.tracingTelemetry.exporter.jaeger.agent.host As name described string localhost
gf.interceptors.tracingTelemetry.exporter.jaeger.agent.port As name described int 6831
gf.interceptors.tracingTelemetry.exporter.jaeger.collector.enabled Export tracing info to jaeger collector boolean false
gf.interceptors.tracingTelemetry.exporter.jaeger.collector.endpoint As name described string http://localhost:16368/api/trace
gf.interceptors.tracingTelemetry.exporter.jaeger.collector.username As name described string ""
gf.interceptors.tracingTelemetry.exporter.jaeger.collector.password As name described string ""
RateLimit
name description type default value
gf.interceptors.rateLimit.enabled Enable rate limit interceptor boolean false
gf.interceptors.rateLimit.algorithm Provide algorithm, tokenBucket and leakyBucket are available options string tokenBucket
gf.interceptors.rateLimit.reqPerSec Request per second globally int 0
gf.interceptors.rateLimit.paths.path Full path string ""
gf.interceptors.rateLimit.paths.reqPerSec Request per second by full path int 0
CORS
name description type default value
gf.interceptors.cors.enabled Enable cors interceptor boolean false
gf.interceptors.cors.allowOrigins Provide allowed origins with wildcard enabled. []string *
gf.interceptors.cors.allowMethods Provide allowed methods returns as response header of OPTIONS request. []string All http methods
gf.interceptors.cors.allowHeaders Provide allowed headers returns as response header of OPTIONS request. []string Headers from request
gf.interceptors.cors.allowCredentials Returns as response header of OPTIONS request. bool false
gf.interceptors.cors.exposeHeaders Provide exposed headers returns as response header of OPTIONS request. []string ""
gf.interceptors.cors.maxAge Provide max age returns as response header of OPTIONS request. int 0
JWT

In order to make swagger UI and RK tv work under JWT without JWT token, we need to ignore prefixes of paths as bellow.

jwt:
  ...
  ignorePrefix:
   - "/rk/v1/tv"
   - "/sw"
   - "/rk/v1/assets"
name description type default value
gf.interceptors.jwt.enabled Enable JWT interceptor boolean false
gf.interceptors.jwt.signingKey Required, Provide signing key. string ""
gf.interceptors.jwt.ignorePrefix Provide ignoring path prefix. []string []
gf.interceptors.jwt.signingKeys Provide signing keys as scheme of :. []string []
gf.interceptors.jwt.signingAlgo Provide signing algorithm. string HS256
gf.interceptors.jwt.tokenLookup Provide token lookup scheme, please see bellow description. string "header:Authorization"
gf.interceptors.jwt.authScheme Provide auth scheme. string Bearer

The supported scheme of tokenLookup

// Optional. Default value "header:Authorization".
// Possible values:
// - "header:<name>"
// - "query:<name>"
// - "param:<name>"
// - "cookie:<name>"
// - "form:<name>"
// Multiply sources example:
// - "header: Authorization,cookie: myowncookie"
Secure
name description type default value
gf.interceptors.secure.enabled Enable secure interceptor boolean false
gf.interceptors.secure.xssProtection X-XSS-Protection header value. string "1; mode=block"
gf.interceptors.secure.contentTypeNosniff X-Content-Type-Options header value. string nosniff
gf.interceptors.secure.xFrameOptions X-Frame-Options header value. string SAMEORIGIN
gf.interceptors.secure.hstsMaxAge Strict-Transport-Security header value. int 0
gf.interceptors.secure.hstsExcludeSubdomains Excluding subdomains of HSTS. bool false
gf.interceptors.secure.hstsPreloadEnabled Enabling HSTS preload. bool false
gf.interceptors.secure.contentSecurityPolicy Content-Security-Policy header value. string ""
gf.interceptors.secure.cspReportOnly Content-Security-Policy-Report-Only header value. bool false
gf.interceptors.secure.referrerPolicy Referrer-Policy header value. string ""
gf.interceptors.secure.ignorePrefix Ignoring path prefix. []string []
CSRF
name description type default value
gf.interceptors.csrf.enabled Enable csrf interceptor boolean false
gf.interceptors.csrf.tokenLength Provide the length of the generated token. int 32
gf.interceptors.csrf.tokenLookup Provide csrf token lookup rules, please see code comments for details. string "header:X-CSRF-Token"
gf.interceptors.csrf.cookieName Provide name of the CSRF cookie. This cookie will store CSRF token. string _csrf
gf.interceptors.csrf.cookieDomain Domain of the CSRF cookie. string ""
gf.interceptors.csrf.cookiePath Path of the CSRF cookie. string ""
gf.interceptors.csrf.cookieMaxAge Provide max age (in seconds) of the CSRF cookie. int 86400
gf.interceptors.csrf.cookieHttpOnly Indicates if CSRF cookie is HTTP only. bool false
gf.interceptors.csrf.cookieSameSite Indicates SameSite mode of the CSRF cookie. Options: lax, strict, none, default string default
gf.interceptors.csrf.ignorePrefix Ignoring path prefix. []string []
Full YAML
---
#app:
#  description: "this is description"                      # Optional, default: ""
#  keywords: ["rk", "golang"]                              # Optional, default: []
#  homeUrl: "http://example.com"                           # Optional, default: ""
#  iconUrl: "http://example.com"                           # Optional, default: ""
#  docsUrl: ["http://example.com"]                         # Optional, default: []
#  maintainers: ["rk-dev"]                                 # Optional, default: []
#zapLogger:
#  - name: zap-logger                                      # Required
#    description: "Description of entry"                   # Optional
#eventLogger:
#  - name: event-logger                                    # Required
#    description: "Description of entry"                   # Optional
#cred:
#  - name: "local-cred"                                    # Required
#    provider: "localFs"                                   # Required, etcd, consul, localFs, remoteFs are supported options
#    description: "Description of entry"                   # Optional
#    locale: "*::*::*::*"                                  # Optional, default: *::*::*::*
#    paths:                                                # Optional
#      - "example/boot/full/cred.yaml"
#cert:
#  - name: "local-cert"                                    # Required
#    provider: "localFs"                                   # Required, etcd, consul, localFs, remoteFs are supported options
#    description: "Description of entry"                   # Optional
#    locale: "*::*::*::*"                                  # Optional, default: *::*::*::*
#    serverCertPath: "example/boot/full/server.pem"        # Optional, default: "", path of certificate on local FS
#    serverKeyPath: "example/boot/full/server-key.pem"     # Optional, default: "", path of certificate on local FS
#    clientCertPath: "example/client.pem"                  # Optional, default: "", path of certificate on local FS
#    clientKeyPath: "example/client.pem"                   # Optional, default: "", path of certificate on local FS
#config:
#  - name: rk-main                                         # Required
#    path: "example/boot/full/config.yaml"                 # Required
#    locale: "*::*::*::*"                                  # Required, default: *::*::*::*
#    description: "Description of entry"                   # Optional
gf:
  - name: greeter                                          # Required
    port: 8080                                             # Required
    enabled: true                                          # Required
#    description: "greeter server"                         # Optional, default: ""
#    cert:
#      ref: "local-cert"                                   # Optional, default: "", reference of cert entry declared above
#    sw:
#      enabled: true                                       # Optional, default: false
#      path: "sw"                                          # Optional, default: "sw"
#      jsonPath: ""                                        # Optional
#      headers: ["sw:rk"]                                  # Optional, default: []
#    commonService:
#      enabled: true                                       # Optional, default: false
#    static:
#      enabled: true                                       # Optional, default: false
#      path: "/rk/v1/static"                               # Optional, default: /rk/v1/static
#      sourceType: local                                   # Required, options: pkger, local
#      sourcePath: "."                                     # Required, full path of source directory
#    tv:
#      enabled:  true                                      # Optional, default: false
#    prom:
#      enabled: true                                       # Optional, default: false
#      path: ""                                            # Optional, default: "metrics"
#      pusher:
#        enabled: false                                    # Optional, default: false
#        jobName: "greeter-pusher"                         # Required
#        remoteAddress: "localhost:9091"                   # Required
#        basicAuth: "user:pass"                            # Optional, default: ""
#        intervalMs: 10000                                 # Optional, default: 1000
#        cert:                                             # Optional
#          ref: "local-test"                               # Optional, default: "", reference of cert entry declared above
#    logger:
#      zapLogger:
#        ref: zap-logger                                   # Optional, default: logger of STDOUT, reference of logger entry declared above
#      eventLogger:
#        ref: event-logger                                 # Optional, default: logger of STDOUT, reference of logger entry declared above
#    interceptors:
#      loggingZap:
#        enabled: true                                     # Optional, default: false
#        zapLoggerEncoding: "json"                         # Optional, default: "console"
#        zapLoggerOutputPaths: ["logs/app.log"]            # Optional, default: ["stdout"]
#        eventLoggerEncoding: "json"                       # Optional, default: "console"
#        eventLoggerOutputPaths: ["logs/event.log"]        # Optional, default: ["stdout"]
#      metricsProm:
#        enabled: true                                     # Optional, default: false
#      auth:
#        enabled: true                                     # Optional, default: false
#        basic:
#          - "user:pass"                                   # Optional, default: []
#        ignorePrefix:
#          - "/rk/v1"                                      # Optional, default: []
#        apiKey:
#          - "keys"                                        # Optional, default: []
#      meta:
#        enabled: true                                     # Optional, default: false
#        prefix: "rk"                                      # Optional, default: "rk"
#      tracingTelemetry:
#        enabled: true                                     # Optional, default: false
#        exporter:                                         # Optional, default will create a stdout exporter
#          file:
#            enabled: true                                 # Optional, default: false
#            outputPath: "logs/trace.log"                  # Optional, default: stdout
#          jaeger:
#            agent:
#              enabled: false                              # Optional, default: false
#              host: ""                                    # Optional, default: localhost
#              port: 0                                     # Optional, default: 6831
#            collector:
#              enabled: true                               # Optional, default: false
#              endpoint: ""                                # Optional, default: http://localhost:14268/api/traces
#              username: ""                                # Optional, default: ""
#              password: ""                                # Optional, default: ""
#      rateLimit:
#        enabled: false                                    # Optional, default: false
#        algorithm: "leakyBucket"                          # Optional, default: "tokenBucket"
#        reqPerSec: 100                                    # Optional, default: 1000000
#        paths:
#          - path: "/rk/v1/healthy"                        # Optional, default: ""
#            reqPerSec: 0                                  # Optional, default: 1000000
#      jwt:
#        enabled: true                                     # Optional, default: false
#        signingKey: "my-secret"                           # Required
#        ignorePrefix:                                     # Optional, default: []
#          - "/rk/v1/tv"
#          - "/sw"
#          - "/rk/v1/assets"
#        signingKeys:                                      # Optional
#          - "key:value"
#        signingAlgo: ""                                   # Optional, default: "HS256"
#        tokenLookup: "header:<name>"                      # Optional, default: "header:Authorization"
#        authScheme: "Bearer"                              # Optional, default: "Bearer"
#      secure:
#        enabled: true                                     # Optional, default: false
#        xssProtection: ""                                 # Optional, default: "1; mode=block"
#        contentTypeNosniff: ""                            # Optional, default: nosniff
#        xFrameOptions: ""                                 # Optional, default: SAMEORIGIN
#        hstsMaxAge: 0                                     # Optional, default: 0
#        hstsExcludeSubdomains: false                      # Optional, default: false
#        hstsPreloadEnabled: false                         # Optional, default: false
#        contentSecurityPolicy: ""                         # Optional, default: ""
#        cspReportOnly: false                              # Optional, default: false
#        referrerPolicy: ""                                # Optional, default: ""
#        ignorePrefix: []                                  # Optional, default: []
#      csrf:
#        enabled: true
#        tokenLength: 32                                   # Optional, default: 32
#        tokenLookup: "header:X-CSRF-Token"                # Optional, default: "header:X-CSRF-Token"
#        cookieName: "_csrf"                               # Optional, default: _csrf
#        cookieDomain: ""                                  # Optional, default: ""
#        cookiePath: ""                                    # Optional, default: ""
#        cookieMaxAge: 86400                               # Optional, default: 86400
#        cookieHttpOnly: false                             # Optional, default: false
#        cookieSameSite: "default"                         # Optional, default: "default", options: lax, strict, none, default
#        ignorePrefix: []                                  # Optional, default: []
Development Status: Stable

Build instruction

Simply run make all to validate your changes. Or run codes in example/ folder.

  • make all

Run unit-test, golangci-lint, doctoc and gofmt.

  • make swag

Generate swagger config for CommonService

  • make pkger

If files in boot/assets have been modified, then we need to run it.

Test instruction

Run unit test with make test command.

github workflow will automatically run unit test and golangci-lint for testing and lint validation.

Contributing

We encourage and support an active, healthy community of contributors — including you! Details are in the contribution guide and the code of conduct. The rk maintainers keep an eye on issues and pull requests, but you can also report any negative conduct to lark@rkdev.info.

Released under the Apache 2.0 License.

Directories

Path Synopsis
example
Package rkgfinter provides common utility functions for middleware of GoFrame framework
Package rkgfinter provides common utility functions for middleware of GoFrame framework
auth
Package rkgfauth is auth middleware for GoFrame framework
Package rkgfauth is auth middleware for GoFrame framework
context
Package rkgfctx defines utility functions and variables used by GoFrame middleware
Package rkgfctx defines utility functions and variables used by GoFrame middleware
csrf
Package rkgfcsrf is a middleware for GoFrame framework which validating csrf token for RPC
Package rkgfcsrf is a middleware for GoFrame framework which validating csrf token for RPC
jwt
log/zap
Package rkgflog is a middleware for GoFrame framework for logging RPC.
Package rkgflog is a middleware for GoFrame framework for logging RPC.
meta
Package rkgfmeta is a middleware of GoFrame framework for adding metadata in RPC response
Package rkgfmeta is a middleware of GoFrame framework for adding metadata in RPC response
metrics/prom
Package rkgfmetrics is a middleware for GoFrame framework which record prometheus metrics for RPC
Package rkgfmetrics is a middleware for GoFrame framework which record prometheus metrics for RPC
panic
Package rkgfpanic is a middleware of GoFrame framework for recovering from panic
Package rkgfpanic is a middleware of GoFrame framework for recovering from panic
ratelimit
Package rkgflimit is a middleware of GoFrame framework for adding rate limit in RPC response
Package rkgflimit is a middleware of GoFrame framework for adding rate limit in RPC response
tracing/telemetry
Package rkgftrace is aa middleware of GoFrame framework for recording trace info of RPC
Package rkgftrace is aa middleware of GoFrame framework for recording trace info of RPC

Jump to

Keyboard shortcuts

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