dubboproxy

package

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

Details

View Source

const (
	Kind = constant.DubboConnectManagerFilter
)

This section is empty.

This section is empty.

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

DubboFilterManager manage filters

func NewDubboFilterManager(fs []*model.DubboFilter) *DubboFilterManager

NewDubboFilterManager create filter manager

type DubboProxyConnectionManager struct {
	filter.EmptyNetworkFilter
	// contains filtered or unexported fields
}

DubboProxyConnectionManager network filter for dubbo

func CreateDubboProxyConnectionManager(config *model.DubboProxyConnectionManagerConfig) *DubboProxyConnectionManager

CreateDubboProxyConnectionManager create dubbo proxy connection manager

func (dcm *DubboProxyConnectionManager) OnData(data any) (any, error)

OnData handle dubbo rpc invocation

func (dcm *DubboProxyConnectionManager) OnDecode(data []byte) (any, int, error)

OnDecode decode bytes to DecodeResult

func (dcm *DubboProxyConnectionManager) OnEncode(pkg any) ([]byte, error)

OnEncode encode Response to bytes

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

OnTripleData handle triple rpc invocation

type Plugin struct{}

Plugin the dubbo networkfilter plugin

func (p *Plugin) Config() any

Config return DubboProxyConnectionManagerConfig

func (p *Plugin) CreateFilter(config any) (filter.NetworkFilter, error)

CreateFilter create dubbo networkfilter

func (p *Plugin) Kind() string

Kind kind