grpc

Documentation

Index

• Constants
• Variables
• type FilterGRPCPlugin
  • func (p *FilterGRPCPlugin) GRPCClient(ctx context.Context, broker *hplugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
  • func (p *FilterGRPCPlugin) GRPCServer(broker *hplugin.GRPCBroker, s *grpc.Server) error
• type GRPCClient
  • func (m *GRPCClient) Close() error
  • func (m *GRPCClient) Configure(data map[string]interface{}) error
  • func (m *GRPCClient) Filter(msg *core.Msg) (bool, error)
• type GRPCServer
  • func (m *GRPCServer) Configure(ctx context.Context, req *msgpb.ConfigureRequest) (*msgpb.ConfigureResponse, error)
  • func (m *GRPCServer) Filter(ctx context.Context, req *msgpb.FilterRequest) (*msgpb.FilterResponse, error)

Constants

const PluginName = "filter_grpc"

Variables

var (
	HandshakeConfig = hplugin.HandshakeConfig{
		ProtocolVersion:  1,
		MagicCookieKey:   "BASIC_PLUGIN",
		MagicCookieValue: "hello",
	}

	PluginMap = map[string]hplugin.Plugin{
		PluginName: &FilterGRPCPlugin{},
	}
)

Types

type FilterGRPCPlugin

type FilterGRPCPlugin struct {
	hplugin.Plugin
	Impl core.IFilter
}

func (*FilterGRPCPlugin) GRPCClient

func (p *FilterGRPCPlugin) GRPCClient(ctx context.Context, broker *hplugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*FilterGRPCPlugin) GRPCServer

func (p *FilterGRPCPlugin) GRPCServer(broker *hplugin.GRPCBroker, s *grpc.Server) error

type GRPCClient

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

func (*GRPCClient) Close

func (m *GRPCClient) Close() error

func (*GRPCClient) Configure

func (m *GRPCClient) Configure(data map[string]interface{}) error

func (*GRPCClient) Filter

func (m *GRPCClient) Filter(msg *core.Msg) (bool, error)

type GRPCServer

type GRPCServer struct {
	Impl core.IFilter
}

func (*GRPCServer) Configure

func (m *GRPCServer) Configure(ctx context.Context, req *msgpb.ConfigureRequest) (*msgpb.ConfigureResponse, error)

func (*GRPCServer) Filter

func (m *GRPCServer) Filter(ctx context.Context, req *msgpb.FilterRequest) (*msgpb.FilterResponse, error)