Documentation
¶
Index ¶
Constants ¶
View Source
const ( // Kind filter plugin kind Kind = constant.GRPCProxyConnectionFilter )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GrpcFilterManager ¶
type GrpcFilterManager struct {
// contains filtered or unexported fields
}
GrpcFilterManager manage gRPC filters, similar to DubboFilterManager
func NewGrpcFilterManager ¶
func NewGrpcFilterManager(fs []*model.GrpcFilter) *GrpcFilterManager
NewGrpcFilterManager create gRPC filter manager
type GrpcProxyConnectionManager ¶
type GrpcProxyConnectionManager struct {
filter.EmptyNetworkFilter
// contains filtered or unexported fields
}
GrpcProxyConnectionManager network filter for gRPC proxy, similar to DubboProxyConnectionManager
func CreateGrpcProxyConnectionManager ¶
func CreateGrpcProxyConnectionManager(config *model.GRPCConnectionManagerConfig) *GrpcProxyConnectionManager
CreateGrpcProxyConnectionManager create gRPC proxy connection manager
func (*GrpcProxyConnectionManager) Close ¶
func (gcm *GrpcProxyConnectionManager) Close() error
func (*GrpcProxyConnectionManager) OnStreamRPC ¶
func (gcm *GrpcProxyConnectionManager) OnStreamRPC(stream model.RPCStream, info *model.RPCStreamInfo) error
OnStreamRPC handles a streaming RPC call.
type Plugin ¶
type Plugin struct{}
Plugin gRPC connection manager plugin, similar to dubboproxy plugin
func (*Plugin) CreateFilter ¶
func (p *Plugin) CreateFilter(config any) (filter.NetworkFilter, error)
CreateFilter return the filter instance
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.