plugin

package

v0.0.0-...-0b43789 Latest Latest Go to latest Published: Apr 27, 2025 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/jrnd-io/jrv2

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetPluginMap() map[string]*Plugin
func ReadConfig(plugin string) ([]byte, error)
func RegisterLocalPlugin(name string, plugin *Plugin)
func RegisterRemotePlugin(name string, plugin *Plugin)
type Adapter
- func NewAdapter(jrpcProducer jrpc.Producer) *Adapter
- func (a *Adapter) Produce(_ context.Context, key []byte, v []byte, headers map[string]string, ...) (*jrpc.ProduceResponse, error)
type Plugin
- func GetPlugin(name string) *Plugin
- func New(jrPlugin string, logLevel hclog.Level) (*Plugin, error)
- func (c *Plugin) Close() error
- func (c *Plugin) Produce(ctx context.Context, key []byte, value []byte, headers map[string]string, ...) (*jrpc.ProduceResponse, error)
type Producer

Constants ¶

View Source

const (
	EnvJRPlugin = "JR_PLUGIN"

	PythonPlugin       = "python"
	PythonPluginScript = "plugin.py"
)

Variables ¶

This section is empty.

Functions ¶

func GetPluginMap ¶

func GetPluginMap() map[string]*Plugin

func ReadConfig ¶

func ReadConfig(plugin string) ([]byte, error)

func RegisterLocalPlugin ¶

func RegisterLocalPlugin(name string, plugin *Plugin)

func RegisterRemotePlugin ¶

func RegisterRemotePlugin(name string, plugin *Plugin)

Types ¶

type Adapter ¶

type Adapter struct {
	Producer
	// contains filtered or unexported fields
}

func NewAdapter ¶

func NewAdapter(jrpcProducer jrpc.Producer) *Adapter

func (*Adapter) Produce ¶

func (a *Adapter) Produce(_ context.Context,
	key []byte,
	v []byte,
	headers map[string]string,
	configParams map[string]string) (*jrpc.ProduceResponse, error)

type Plugin ¶

type Plugin struct {
	Name      string
	RPCClient plugin.ClientProtocol

	Producer Producer
	Command  string
	IsRemote bool
	// contains filtered or unexported fields
}

func GetPlugin ¶

func GetPlugin(name string) *Plugin

func New ¶

func New(jrPlugin string, logLevel hclog.Level) (*Plugin, error)

func (*Plugin) Close ¶

func (c *Plugin) Close() error

func (*Plugin) Produce ¶

func (c *Plugin) Produce(ctx context.Context, key []byte, value []byte, headers map[string]string, configParams map[string]string) (*jrpc.ProduceResponse, error)

type Producer ¶

type Producer interface {
	Produce(ctx context.Context, key []byte, v []byte, headers map[string]string, configParams map[string]string) (*jrpc.ProduceResponse, error)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
local
console
file
kafka

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