interceptors

Documentation

Overview

Package interceptors provides the interceptors for RPC.

Index

• Constants
• Variables
• type AdminAuthInterceptor
  • func NewAdminAuthInterceptor(be *backend.Backend, tokenManager *auth.TokenManager) *AdminAuthInterceptor
  • func (i *AdminAuthInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
  • func (i *AdminAuthInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
  • func (i *AdminAuthInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc
• type ContextInterceptor
  • func NewContextInterceptor(be *backend.Backend) *ContextInterceptor
  • func (i *ContextInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
  • func (i *ContextInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
  • func (i *ContextInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc
• type DefaultInterceptor
  • func NewDefaultInterceptor() *DefaultInterceptor
  • func (i *DefaultInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
  • func (i *DefaultInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
  • func (i *DefaultInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc

Constants

const (
	// SlowThreshold is the threshold for slow RPC.
	SlowThreshold = 100 * gotime.Millisecond
)

Variables

var ErrUnauthenticated = errors.New("authorization is not provided")

ErrUnauthenticated is returned when authentication is failed.

Types

type AdminAuthInterceptor

type AdminAuthInterceptor struct {
	// contains filtered or unexported fields
}

AdminAuthInterceptor is an interceptor for authentication.

func NewAdminAuthInterceptor

func NewAdminAuthInterceptor(be *backend.Backend, tokenManager *auth.TokenManager) *AdminAuthInterceptor

NewAdminAuthInterceptor creates a new instance of AdminAuthInterceptor.

func (*AdminAuthInterceptor) WrapStreamingClient

func (i *AdminAuthInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

WrapStreamingClient creates a stream client interceptor for authentication.

func (*AdminAuthInterceptor) WrapStreamingHandler

func (i *AdminAuthInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

WrapStreamingHandler creates a stream server interceptor for authentication.

func (*AdminAuthInterceptor) WrapUnary

func (i *AdminAuthInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc

WrapUnary 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) WrapStreamingClient

func (i *ContextInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

WrapStreamingClient creates a stream client interceptor for building additional context.

func (*ContextInterceptor) WrapStreamingHandler

func (i *ContextInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

WrapStreamingHandler creates a stream server interceptor for building additional context.

func (*ContextInterceptor) WrapUnary

func (i *ContextInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc

WrapUnary 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) WrapStreamingClient

func (i *DefaultInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

WrapStreamingClient creates a stream client interceptor for default.

func (*DefaultInterceptor) WrapStreamingHandler

func (i *DefaultInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

WrapStreamingHandler creates a stream server interceptor for default.

func (*DefaultInterceptor) WrapUnary

func (i *DefaultInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc

WrapUnary creates a unary server interceptor for default.