processor

package
v0.10.0 Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PluginService

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

func NewPluginService

func NewPluginService(logger log.CtxLogger, br registry, sr standaloneRegistry) *PluginService

func (*PluginService) Check

func (s *PluginService) Check(context.Context) error

func (*PluginService) List

func (*PluginService) NewProcessor

func (s *PluginService) NewProcessor(ctx context.Context, pluginName string, id string) (sdk.Processor, error)

func (*PluginService) RegisterStandalonePlugin added in v0.9.1

func (s *PluginService) RegisterStandalonePlugin(ctx context.Context, path string) (string, error)

RegisterStandalonePlugin registers a standalone processor plugin from the specified path and returns the full name of the plugin or an error.

Directories

Path Synopsis
impl/avro
Package avro is a generated GoMock package.
Package avro is a generated GoMock package.
internal/diff
Package diff computes differences between text files or strings.
Package diff computes differences between text files or strings.
internal/diff/difftest
Package difftest supplies a set of tests that will operate on any implementation of a diff algorithm as exposed by "github.com/conduitio/conduit/pkg/plugin/processor/builtin/internal/diff"
Package difftest supplies a set of tests that will operate on any implementation of a diff algorithm as exposed by "github.com/conduitio/conduit/pkg/plugin/processor/builtin/internal/diff"
internal/diff/lcs
package lcs contains code to find longest-common-subsequences (and diffs)
package lcs contains code to find longest-common-subsequences (and diffs)
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

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