middleware

package

v0.1.0 Latest Latest Go to latest Published: Feb 18, 2024 License: MIT 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/kyamalabs/users

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AuthorizeUser(ctx context.Context, walletAddress string, ...) (*pb.AccessTokenPayload, error)
func CreateLimiterRedisStore(redisConnURL string) (limiter.Store, error)
func GrpcExtractMetadata(ctx context.Context, req any, _ *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
func GrpcLogger(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
func GrpcRateLimiter(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
func HTTPExtractMetadata(handler http.Handler) http.Handler
func HTTPLogger(handler http.Handler) http.Handler
func HTTPRateLimiter(handler http.Handler) http.Handler
func InitializeLimiters(store limiter.Store) error
type ErrorResponse
type ReqContextKey
type ResponseRecorder
- func (rec *ResponseRecorder) Write(body []byte) (int, error)
- func (rec *ResponseRecorder) WriteHeader(statusCode int)

Constants ¶

View Source

const (
	InternalServerError             string = "An unexpected error occurred while processing your request."
	RateLimitExceededError          string = "Slow down! Too many requests. Try again shortly. Thank you!"
	MissingXForwardedForHeaderError string = "X-Forwarded-For header is required for accurate processing."
)

Errors

Variables ¶

This section is empty.

Functions ¶

func AuthorizeUser ¶

func AuthorizeUser(ctx context.Context, walletAddress string, authService services.AuthGrpcService) (*pb.AccessTokenPayload, error)

func CreateLimiterRedisStore ¶

func CreateLimiterRedisStore(redisConnURL string) (limiter.Store, error)

func GrpcExtractMetadata ¶

func GrpcExtractMetadata(ctx context.Context, req any, _ *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

func GrpcLogger ¶

func GrpcLogger(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

func GrpcRateLimiter ¶

func GrpcRateLimiter(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

func HTTPExtractMetadata ¶

func HTTPExtractMetadata(handler http.Handler) http.Handler

func HTTPLogger ¶

func HTTPLogger(handler http.Handler) http.Handler

func HTTPRateLimiter ¶

func HTTPRateLimiter(handler http.Handler) http.Handler

func InitializeLimiters ¶

func InitializeLimiters(store limiter.Store) error

Types ¶

type ErrorResponse ¶

type ErrorResponse struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type ReqContextKey ¶

type ReqContextKey string

const (
	ClientIP              ReqContextKey = "client_ip"
	ServiceAuthentication ReqContextKey = "service_authentication"
	AuthenticatedService  ReqContextKey = "authenticated_service"
)

type ResponseRecorder ¶

type ResponseRecorder struct {
	http.ResponseWriter
	StatusCode int
	Body       []byte
}

func (*ResponseRecorder) Write ¶

func (rec *ResponseRecorder) Write(body []byte) (int, error)

func (*ResponseRecorder) WriteHeader ¶

func (rec *ResponseRecorder) WriteHeader(statusCode int)

Source Files ¶

View all Source files

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