filterchain

package

v1.1.0 Latest Latest Go to latest Published: Dec 28, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func CreateNetworkFilterChain(config model.FilterChain) *NetworkFilterChain

CreateNetworkFilterChain create network filter chain

func (fc *NetworkFilterChain) Close() error

Close closes the filter chain and all filters in it.

func (fc *NetworkFilterChain) OnData(data any) (any, error)

OnData handle dubbo rpc invocation

func (fc *NetworkFilterChain) OnDecode(data []byte) (any, int, error)

OnDecode decode bytes received from getty listener

func (fc *NetworkFilterChain) OnEncode(p any) ([]byte, error)

OnEncode encode struct to bytes sent to getty listener

func (fc *NetworkFilterChain) OnStreamRPC(stream model.RPCStream, info *model.RPCStreamInfo) error

OnStreamRPC handles a streaming RPC call.

func (fc *NetworkFilterChain) OnTripleData(ctx context.Context, methodName string, arguments []any) (any, error)

OnTripleData handle triple rpc invocation

func (fc *NetworkFilterChain) OnUnaryRPC(ctx context.Context, fullMethod string, req any) (any, error)

OnUnaryRPC handles a unary RPC call.

func (fc *NetworkFilterChain) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP handle http request