bridge

package

v0.1.5 Latest Latest Go to latest Published: May 24, 2019 License: LGPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var AdapterFactories = &adapterFactoryExt{
	newExtensionPoint(new(AdapterFactory)),
}

func Register(component interface{}, name string) []string

func Unregister(name string) []string

type AdapterFactory interface {
	New(serviceName string) ExtractorAdapter
}

type Bridge struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New(serviceName string) (*Bridge, error)

func (b *Bridge) Extract(message []byte) map[string]interface{}

type ExtractorAdapter interface {
	Extract(message []byte) map[string]interface{}
}