interceptors

package

v0.9.6-RC01 Latest Latest Go to latest Published: Sep 23, 2025 License: MIT Imports: 11 Imported by: 0

Details

View Source

const (
	ClientIDHeaderName = "X-Client-ID"
)

This section is empty.

This section is empty.

type ProcessingIdentityInterceptor struct {
	ID string
	// contains filtered or unexported fields
}

func NewProcessingIdentity(
	processingID, version string,
) *ProcessingIdentityInterceptor

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

WrapStreamingClient wraps the streaming server function

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

WrapStreamingHandler wraps the streaming server function

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

WrapUnary wraps the unary function

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

func NewSignInterceptor(
	clientService *clients.Service,
	disableCheckingSign bool,
) *SignInterceptor

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

WrapStreamingServer wraps the streaming server function

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

WrapStreamingServer wraps the streaming server function

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

WrapUnary wraps the unary function