grpc_middleware

Documentation

Index

• func AuditEventUnaryInterceptor(logger *zap.Logger, eventPairChecker audit.EventPairChecker) grpc.UnaryServerInterceptor
• func ErrorUnaryInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• func EvaluationUnaryInterceptor(analyticsEnabled bool) grpc.UnaryServerInterceptor
• func FliptAcceptServerVersionFromContext(ctx context.Context) semver.Version
• func FliptAcceptServerVersionUnaryInterceptor(logger *zap.Logger) grpc.UnaryServerInterceptor
• func ForwardFliptAcceptServerVersion(ctx context.Context, req *http.Request) metadata.MD
• func ForwardFliptNamespace(ctx context.Context, req *http.Request) metadata.MD
• func ValidationUnaryInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• func WithFliptAcceptServerVersion(ctx context.Context, version semver.Version) context.Context
• type RequestIdentifiable
• type ResponseDurationRecordable

Functions

func AuditEventUnaryInterceptor

func AuditEventUnaryInterceptor(logger *zap.Logger, eventPairChecker audit.EventPairChecker) grpc.UnaryServerInterceptor

AuditEventUnaryInterceptor captures events and adds them to the trace span to be consumed downstream.

func ErrorUnaryInterceptor

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

ErrorUnaryInterceptor intercepts known errors and returns the appropriate GRPC status code

func EvaluationUnaryInterceptor

func EvaluationUnaryInterceptor(analyticsEnabled bool) grpc.UnaryServerInterceptor

EvaluationUnaryInterceptor sets required request/response fields. Note: this should be added before any caching interceptor to ensure the request id/response fields are unique.

func FliptAcceptServerVersionFromContext

func FliptAcceptServerVersionFromContext(ctx context.Context) semver.Version

FliptAcceptServerVersionFromContext returns the flipt-accept-server-version from the context if it exists or the default version.

func FliptAcceptServerVersionUnaryInterceptor

func FliptAcceptServerVersionUnaryInterceptor(logger *zap.Logger) grpc.UnaryServerInterceptor

FliptAcceptServerVersionUnaryInterceptor is a grpc client interceptor that sets the flipt-accept-server-version in the context if provided in the metadata/header.

func ForwardFliptAcceptServerVersion

func ForwardFliptAcceptServerVersion(ctx context.Context, req *http.Request) metadata.MD

ForwardFliptAcceptServerVersion extracts the "x-flipt-accept-server-version"" header from an HTTP request and forwards them as grpc metadata entries.

func ForwardFliptNamespace

func ForwardFliptNamespace(ctx context.Context, req *http.Request) metadata.MD

ForwardFliptNamespace extracts the "x-flipt-namespace" header from an HTTP request and forwards them as grpc metadata entries.

func ValidationUnaryInterceptor

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

ValidationUnaryInterceptor validates incoming requests

func WithFliptAcceptServerVersion

func WithFliptAcceptServerVersion(ctx context.Context, version semver.Version) context.Context

WithFliptAcceptServerVersion sets the flipt version in the context.

Types

type RequestIdentifiable

type RequestIdentifiable interface {
	// SetRequestIDIfNotBlank attempts to set the provided ID on the instance
	// If the ID was blank, it returns the ID provided to this call.
	// If the ID was not blank, it returns the ID found on the instance.
	SetRequestIDIfNotBlank(id string) string
}

type ResponseDurationRecordable

type ResponseDurationRecordable interface {
	// SetTimestamps records the start and end times on the target instance.
	SetTimestamps(start, end time.Time)
}