dubboproxy

Documentation

Index

• Constants
• type DubboFilterManager
  • func NewDubboFilterManager(fs []*model.DubboFilter) *DubboFilterManager
• type DubboProxyConnectionManager
  • func CreateDubboProxyConnectionManager(config *model.DubboProxyConnectionManagerConfig) *DubboProxyConnectionManager
  • func (dcm *DubboProxyConnectionManager) OnData(data interface{}) (interface{}, error)
  • func (dcm *DubboProxyConnectionManager) OnDecode(data []byte) (interface{}, int, error)
  • func (dcm *DubboProxyConnectionManager) OnEncode(pkg interface{}) ([]byte, error)
  • func (dcm *DubboProxyConnectionManager) OnTripleData(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error)
• type Plugin
  • func (p *Plugin) Config() interface{}
  • func (p *Plugin) CreateFilter(config interface{}) (filter.NetworkFilter, error)
  • func (p *Plugin) Kind() string

Constants

const (
	Kind = constant.DubboConnectManagerFilter
)

Types

type DubboFilterManager

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

DubboFilterManager manage filters

func NewDubboFilterManager

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

NewDubboFilterManager create filter manager

type DubboProxyConnectionManager

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

DubboProxyConnectionManager network filter for dubbo

func CreateDubboProxyConnectionManager

func CreateDubboProxyConnectionManager(config *model.DubboProxyConnectionManagerConfig) *DubboProxyConnectionManager

CreateDubboProxyConnectionManager create dubbo proxy connection manager

func (*DubboProxyConnectionManager) OnData

func (dcm *DubboProxyConnectionManager) OnData(data interface{}) (interface{}, error)

OnData handle dubbo rpc invocation

func (*DubboProxyConnectionManager) OnDecode

func (dcm *DubboProxyConnectionManager) OnDecode(data []byte) (interface{}, int, error)

OnDecode decode bytes to DecodeResult

func (*DubboProxyConnectionManager) OnEncode

func (dcm *DubboProxyConnectionManager) OnEncode(pkg interface{}) ([]byte, error)

OnEncode encode Response to bytes

func (*DubboProxyConnectionManager) OnTripleData

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

OnTripleData handle triple rpc invocation

type Plugin

type Plugin struct{}

Plugin the dubbo networkfilter plugin

func (*Plugin) Config

func (p *Plugin) Config() interface{}

Config return DubboProxyConnectionManagerConfig

func (*Plugin) CreateFilter

func (p *Plugin) CreateFilter(config interface{}) (filter.NetworkFilter, error)

CreateFilter create dubbo networkfilter

func (*Plugin) Kind

func (p *Plugin) Kind() string

Kind kind