filterchain

Documentation

Index

• type NetworkFilterChain
  • func CreateNetworkFilterChain(config model.FilterChain) *NetworkFilterChain
  • func (fc NetworkFilterChain) OnData(data interface{}) (interface{}, error)
  • func (fc NetworkFilterChain) OnDecode(data []byte) (interface{}, int, error)
  • func (fc NetworkFilterChain) OnEncode(p interface{}) ([]byte, error)
  • func (fc *NetworkFilterChain) OnTripleData(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error)
  • func (fc NetworkFilterChain) ServeHTTP(w http.ResponseWriter, r *http.Request)

Types

type NetworkFilterChain

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

func CreateNetworkFilterChain

func CreateNetworkFilterChain(config model.FilterChain) *NetworkFilterChain

CreateNetworkFilterChain create network filter chain

func (NetworkFilterChain) OnData

func (fc NetworkFilterChain) OnData(data interface{}) (interface{}, error)

OnData handle dubbo rpc invocation

func (NetworkFilterChain) OnDecode

func (fc NetworkFilterChain) OnDecode(data []byte) (interface{}, int, error)

OnDecode decode bytes received from getty listener

func (NetworkFilterChain) OnEncode

func (fc NetworkFilterChain) OnEncode(p interface{}) ([]byte, error)

OnEncode encode struct to bytes sent to getty listener

func (*NetworkFilterChain) OnTripleData

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

OnTripleData handle triple rpc invocation

func (NetworkFilterChain) ServeHTTP

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

ServeHTTP handle http request