README
¶
interceptors
import "github.com/carousell/Orion/interceptors"
Overview
Imported Packages
- github.com/afex/hystrix-go/hystrix
- github.com/carousell/Orion/orion/modifiers
- github.com/carousell/Orion/utils
- github.com/carousell/Orion/utils/errors
- github.com/carousell/Orion/utils/errors/notifier
- github.com/carousell/Orion/utils/log
- github.com/carousell/Orion/utils/log/loggers
- github.com/grpc-ecosystem/go-grpc-middleware
- github.com/grpc-ecosystem/go-grpc-middleware/tags
- github.com/grpc-ecosystem/go-grpc-middleware/tracing/opentracing
- github.com/grpc-ecosystem/go-grpc-prometheus
- github.com/newrelic/go-agent
- google.golang.org/grpc
Index
- Variables
- func DebugLoggingInterceptor() grpc.UnaryServerInterceptor
- func DefaultClientInterceptor(address string) grpc.UnaryClientInterceptor
- func DefaultClientInterceptors(address string) []grpc.UnaryClientInterceptor
- func DefaultInterceptors() []grpc.UnaryServerInterceptor
- func DefaultStreamInterceptors() []grpc.StreamServerInterceptor
- func GRPCClientInterceptor() grpc.UnaryClientInterceptor
- func HystrixClientInterceptor() grpc.UnaryClientInterceptor
- func NewRelicClientInterceptor(address string) grpc.UnaryClientInterceptor
- func NewRelicInterceptor() grpc.UnaryServerInterceptor
- func PanicRecoveryInterceptor() grpc.UnaryServerInterceptor
- func ResponseTimeLoggingInterceptor() grpc.UnaryServerInterceptor
- func ResponseTimeLoggingStreamInterceptor() grpc.StreamServerInterceptor
- func ServerErrorInterceptor() grpc.UnaryServerInterceptor
- func ServerErrorStreamInterceptor() grpc.StreamServerInterceptor
- func WithHystrixName(name string) clientOption
Package files
documentations.go interceptors.go options.go
Variables
var (
//FilterMethods is the list of methods that are filtered by default
FilterMethods = []string{"Healthcheck"}
)
func DebugLoggingInterceptor
func DebugLoggingInterceptor() grpc.UnaryServerInterceptor
DebugLoggingInterceptor is the interceptor that logs all request/response from a handler
func DefaultClientInterceptor
func DefaultClientInterceptor(address string) grpc.UnaryClientInterceptor
DefaultClientInterceptor are the set of default interceptors that should be applied to all client calls
func DefaultClientInterceptors
func DefaultClientInterceptors(address string) []grpc.UnaryClientInterceptor
DefaultClientInterceptors are the set of default interceptors that should be applied to all client calls
func DefaultInterceptors
func DefaultInterceptors() []grpc.UnaryServerInterceptor
DefaultInterceptors are the set of default interceptors that are applied to all Orion methods
func DefaultStreamInterceptors
func DefaultStreamInterceptors() []grpc.StreamServerInterceptor
DefaultStreamInterceptors are the set of default interceptors that should be applied to all Orion streams
func GRPCClientInterceptor
func GRPCClientInterceptor() grpc.UnaryClientInterceptor
GRPCClientInterceptor is the interceptor that intercepts all cleint requests and adds tracing info to them
func HystrixClientInterceptor
func HystrixClientInterceptor() grpc.UnaryClientInterceptor
HystrixClientInterceptor is the interceptor that intercepts all cleint requests and adds hystrix info to them
func NewRelicClientInterceptor
func NewRelicClientInterceptor(address string) grpc.UnaryClientInterceptor
NewRelicClientInterceptor intercepts all client actions and reports them to newrelic
func NewRelicInterceptor
func NewRelicInterceptor() grpc.UnaryServerInterceptor
NewRelicInterceptor intercepts all server actions and reports them to newrelic
func PanicRecoveryInterceptor
func PanicRecoveryInterceptor() grpc.UnaryServerInterceptor
func ResponseTimeLoggingInterceptor
func ResponseTimeLoggingInterceptor() grpc.UnaryServerInterceptor
ResponseTimeLoggingInterceptor logs response time for each request on server
func ResponseTimeLoggingStreamInterceptor
func ResponseTimeLoggingStreamInterceptor() grpc.StreamServerInterceptor
ResponseTimeLoggingStreamInterceptor logs response time for stream RPCs.
func ServerErrorInterceptor
func ServerErrorInterceptor() grpc.UnaryServerInterceptor
ServerErrorInterceptor intercepts all server actions and reports them to error notifier
func ServerErrorStreamInterceptor
func ServerErrorStreamInterceptor() grpc.StreamServerInterceptor
ServerErrorStreamInterceptor intercepts server errors for stream RPCs and reports them to the error notifier.
func WithHystrixName
func WithHystrixName(name string) clientOption
WithHystrixName changes the hystrix name to be used in the client interceptors
Generated by godoc2ghmd
Documentation
¶
Index ¶
- Variables
- func DebugLoggingInterceptor() grpc.UnaryServerInterceptor
- func DefaultClientInterceptor(address string) grpc.UnaryClientInterceptor
- func DefaultClientInterceptors(address string) []grpc.UnaryClientInterceptor
- func DefaultInterceptors() []grpc.UnaryServerInterceptor
- func DefaultStreamClientInterceptor() grpc.StreamClientInterceptor
- func DefaultStreamClientInterceptors() []grpc.StreamClientInterceptor
- func DefaultStreamInterceptors() []grpc.StreamServerInterceptor
- func ForwardMetadataInterceptor() grpc.UnaryClientInterceptor
- func ForwardMetadataStreamClientInterceptor() grpc.StreamClientInterceptor
- func GRPCClientInterceptor() grpc.UnaryClientInterceptor
- func HystrixClientInterceptor() grpc.UnaryClientInterceptor
- func NewRelicClientInterceptor(address string) grpc.UnaryClientInterceptor
- func NewRelicInterceptor() grpc.UnaryServerInterceptor
- func PanicRecoveryInterceptor() grpc.UnaryServerInterceptor
- func ResponseTimeLoggingInterceptor() grpc.UnaryServerInterceptor
- func ResponseTimeLoggingStreamInterceptor() grpc.StreamServerInterceptor
- func ServerErrorInterceptor() grpc.UnaryServerInterceptor
- func ServerErrorStreamInterceptor() grpc.StreamServerInterceptor
- func WithHystrixFallbackFunc(f func(error) error) hystrixOption
- func WithHystrixIgnorableErrors(e ...error) hystrixOption
- func WithHystrixIgnorableGRPCCodes(c ...codes.Code) hystrixOption
- func WithHystrixName(name string) hystrixOption
Constants ¶
This section is empty.
Variables ¶
var ( //FilterMethods is the list of methods that are filtered by default FilterMethods = []string{"Healthcheck", "HealthCheck"} )
Functions ¶
func DebugLoggingInterceptor ¶
func DebugLoggingInterceptor() grpc.UnaryServerInterceptor
DebugLoggingInterceptor is the interceptor that logs all request/response from a handler
func DefaultClientInterceptor ¶
func DefaultClientInterceptor(address string) grpc.UnaryClientInterceptor
DefaultClientInterceptor are the set of default interceptors that should be applied to all client calls
func DefaultClientInterceptors ¶
func DefaultClientInterceptors(address string) []grpc.UnaryClientInterceptor
DefaultClientInterceptors are the set of default interceptors that should be applied to all client calls
func DefaultInterceptors ¶
func DefaultInterceptors() []grpc.UnaryServerInterceptor
DefaultInterceptors are the set of default interceptors that are applied to all Orion methods
func DefaultStreamClientInterceptor ¶
func DefaultStreamClientInterceptor() grpc.StreamClientInterceptor
DefaultStreamClientInterceptor are the set of default interceptors that should be applied to all client calls
func DefaultStreamClientInterceptors ¶
func DefaultStreamClientInterceptors() []grpc.StreamClientInterceptor
DefaultStreamClientInterceptors are the set of default interceptors that should be applied to all client streaming calls
func DefaultStreamInterceptors ¶
func DefaultStreamInterceptors() []grpc.StreamServerInterceptor
DefaultStreamInterceptors are the set of default interceptors that should be applied to all Orion streams
func ForwardMetadataInterceptor ¶
func ForwardMetadataInterceptor() grpc.UnaryClientInterceptor
ForwardMetadataInterceptor forwards metadata from upstream to downstream
func ForwardMetadataStreamClientInterceptor ¶
func ForwardMetadataStreamClientInterceptor() grpc.StreamClientInterceptor
ForwardMetadataInterceptor forwards metadata from upstream to downstream
func GRPCClientInterceptor ¶
func GRPCClientInterceptor() grpc.UnaryClientInterceptor
GRPCClientInterceptor is the interceptor that intercepts all cleint requests and adds tracing info to them
func HystrixClientInterceptor ¶
func HystrixClientInterceptor() grpc.UnaryClientInterceptor
HystrixClientInterceptor is the interceptor that intercepts all cleint requests and adds hystrix info to them
func NewRelicClientInterceptor ¶
func NewRelicClientInterceptor(address string) grpc.UnaryClientInterceptor
NewRelicClientInterceptor intercepts all client actions and reports them to newrelic
func NewRelicInterceptor ¶
func NewRelicInterceptor() grpc.UnaryServerInterceptor
NewRelicInterceptor intercepts all server actions and reports them to newrelic
func PanicRecoveryInterceptor ¶
func PanicRecoveryInterceptor() grpc.UnaryServerInterceptor
func ResponseTimeLoggingInterceptor ¶
func ResponseTimeLoggingInterceptor() grpc.UnaryServerInterceptor
ResponseTimeLoggingInterceptor logs response time for each request on server
func ResponseTimeLoggingStreamInterceptor ¶
func ResponseTimeLoggingStreamInterceptor() grpc.StreamServerInterceptor
ResponseTimeLoggingStreamInterceptor logs response time for stream RPCs.
func ServerErrorInterceptor ¶
func ServerErrorInterceptor() grpc.UnaryServerInterceptor
ServerErrorInterceptor intercepts all server actions and reports them to error notifier
func ServerErrorStreamInterceptor ¶
func ServerErrorStreamInterceptor() grpc.StreamServerInterceptor
ServerErrorStreamInterceptor intercepts server errors for stream RPCs and reports them to the error notifier.
func WithHystrixFallbackFunc ¶
func WithHystrixIgnorableErrors ¶
func WithHystrixIgnorableErrors(e ...error) hystrixOption
func WithHystrixName ¶
func WithHystrixName(name string) hystrixOption
WithHystrixName changes the hystrix name to be used in the client interceptors
Types ¶
This section is empty.
Source Files