bridge

package
v0.1.5 Latest Latest
Warning

This package is not in the latest version of its module.

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

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func Register

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

func Unregister

func Unregister(name string) []string

Types

type AdapterFactory

type AdapterFactory interface {
	New(serviceName string) ExtractorAdapter
}

type Bridge

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

func New

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

func (*Bridge) Extract

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

type ExtractorAdapter

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL