interceptors

package

v0.9.13 Latest Latest Go to latest Published: Nov 19, 2025 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewProcessingMetric(metrics *metrics.PrometheusMetrics) *ProcessingMetricInterceptor

func (*ProcessingMetricInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

WrapStreamingClient wraps the streaming server function

func (i *ProcessingMetricInterceptor) WrapStreamingHandler(_ connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

WrapStreamingHandler wraps the streaming server function

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

WrapUnary wraps the unary function

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

func NewSignInterceptor(
	settingService setting.ISettingService,
) *SignInterceptor

func (*SignInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

WrapStreamingClient wraps the streaming server function

func (i *SignInterceptor) WrapStreamingHandler(_ connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

WrapStreamingHandler wraps the streaming server function

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

WrapUnary wraps the unary function