plugininterface

package

v0.0.0-...-e2d1181 Latest Latest Go to latest Published: Jun 15, 2020 License: MIT Imports: 2 Imported by: 0

Details

Contiene la interfaz y estructuras para desarrollar un plugin o cliente del mismo.

This section is empty.

This section is empty.

This section is empty.

type FilterEvent interface {
	FilterEvent(event []byte) (filtered []byte, err error)
}

FilterEvent es la interface que deben implementar los plugins que filtran eventos

type FilterEventPlugin struct {
	// Impl injeccion de la implementacion
	Impl FilterEvent
}

FilterEventPlugin es la implementacion de la interface Plugin

func (p *FilterEventPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

Client regresa una implementacion de nuestra interface que se comunica por RFC, en este caso la estructura FilterEventRPCClient

func (p *FilterEventPlugin) Server(b *plugin.MuxBroker) (interface{}, error)

Server retorna un servidor RPC, en este caso la estructura FilterEventRPCServer

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

FilterEventRPCClient implementacion del cliente RPC

func (f *FilterEventRPCClient) FilterEvent(event []byte) (filtered []byte, err error)

FilterEvent llama al servidor rpc para filtra un evento

type FilterEventRPCServer struct {
	// Impl es la implementacion real de FilterEvent
	Impl FilterEvent
}

FilterEventRPCServer es la implementacion de rpc servidor

func (f *FilterEventRPCServer) FilterEvent(event []byte, filtered *[]byte) error

FilterEvent recibe un evento del servidor y lo filtra