loader

package
v0.0.0-...-efe2023 Latest Latest
Warning

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

Go to latest
Published: Aug 28, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package loader provides helpers for loading sources. The follow loaders are are available:

  • Go plugin: Loads a source from a go plugin.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GRPCSink

type GRPCSink struct {
	events.Streamer
	// contains filtered or unexported fields
}

func NewGRPCSink

func NewGRPCSink(address string) (*GRPCSink, error)

func (*GRPCSink) Load

func (g *GRPCSink) Load(stream events.Streamer) error

func (*GRPCSink) Start

func (g *GRPCSink) Start() error

func (*GRPCSink) Stop

func (g *GRPCSink) Stop() error

type GoPluginSink

type GoPluginSink struct {
	sink.Sink
}

func NewGoPluginSink

func NewGoPluginSink(pluginpath string) (*GoPluginSink, error)

func (*GoPluginSink) Load

func (d *GoPluginSink) Load(stream events.Streamer) error

func (*GoPluginSink) Start

func (g *GoPluginSink) Start() error

func (*GoPluginSink) Stop

func (g *GoPluginSink) Stop() error

type GoPluginSource

type GoPluginSource struct {
	source.Source
}

func NewGoPluginSource

func NewGoPluginSource(pluginpath string) (*GoPluginSource, error)

type Plugins

type Plugins struct {
	Sources []source.Source
	Sinks   []sink.Sink
}

func LoadPlugins

func LoadPlugins(runtimepath, dir string) (plugins *Plugins, err error)

type Runtime

type Runtime struct {
	runtime.Runtime
}

func LoadRuntime

func LoadRuntime(pluginpath string) (*Runtime, error)

Jump to

Keyboard shortcuts

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