plugin

package
v0.86.0 Latest Latest
Warning

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

Go to latest
Published: May 8, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const PluginName = "fanOut"

Currently we only support one plugin type

Variables

View Source
var HandshakeConfig = plugin.HandshakeConfig{
	MagicCookieKey:   "CHAINLOOP_PLUGIN",
	MagicCookieValue: "e575e823-335c-4e3b-8bfd-acceef0ae074",
}

Functions

func Serve

func Serve(opts *ServeOpts) error

Serve is a helper function used to serve a backend plugin. This should be ran on the plugin's main process.

Types

type GRPCFanOutPlugin

type GRPCFanOutPlugin struct {

	// Embedding this will disable the netRPC protocol
	plugin.NetRPCUnsupportedPlugin
	// contains filtered or unexported fields
}

GRPCFanOutPlugin is the plugin.Plugin implementation that only supports GRPC transport

func (*GRPCFanOutPlugin) GRPCClient

func (b *GRPCFanOutPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (GRPCFanOutPlugin) GRPCServer

func (b GRPCFanOutPlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error

type ServeOpts

type ServeOpts struct {
	Factory sdk.FanOutFactory
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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