Documentation
¶
Overview ¶
Package interceptors provides the interceptors for RPC.
Index ¶
Constants ¶
const ( // SlowThreshold is the threshold for slow RPC. SlowThreshold = 100 * gotime.Millisecond )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AdminAuthInterceptor ¶ added in v0.4.0
type AdminAuthInterceptor struct {
// contains filtered or unexported fields
}
AdminAuthInterceptor is an interceptor for authentication.
func NewAdminAuthInterceptor ¶ added in v0.4.0
func NewAdminAuthInterceptor(be *backend.Backend, tokenManager *auth.TokenManager) *AdminAuthInterceptor
NewAdminAuthInterceptor creates a new instance of AdminAuthInterceptor.
func (*AdminAuthInterceptor) Stream ¶ added in v0.4.0
func (i *AdminAuthInterceptor) Stream() grpc.StreamServerInterceptor
Stream creates a stream server interceptor for authentication.
func (*AdminAuthInterceptor) Unary ¶ added in v0.4.0
func (i *AdminAuthInterceptor) Unary() grpc.UnaryServerInterceptor
Unary creates a unary server interceptor for authentication.
type ContextInterceptor ¶
type ContextInterceptor struct {
// contains filtered or unexported fields
}
ContextInterceptor is an interceptor for building additional context.
func NewContextInterceptor ¶
func NewContextInterceptor(be *backend.Backend) *ContextInterceptor
NewContextInterceptor creates a new instance of ContextInterceptor.
func (*ContextInterceptor) Stream ¶
func (i *ContextInterceptor) Stream() grpc.StreamServerInterceptor
Stream creates a stream server interceptor for building additional context.
func (*ContextInterceptor) Unary ¶
func (i *ContextInterceptor) Unary() grpc.UnaryServerInterceptor
Unary creates a unary server interceptor for building additional context.
type DefaultInterceptor ¶
type DefaultInterceptor struct{}
DefaultInterceptor is a interceptor for default.
func NewDefaultInterceptor ¶
func NewDefaultInterceptor() *DefaultInterceptor
NewDefaultInterceptor creates a new instance of DefaultInterceptor.
func (*DefaultInterceptor) Stream ¶
func (i *DefaultInterceptor) Stream() grpc.StreamServerInterceptor
Stream creates a stream server interceptor for default.
func (*DefaultInterceptor) Unary ¶
func (i *DefaultInterceptor) Unary() grpc.UnaryServerInterceptor
Unary creates a unary server interceptor for default.
Source Files