plugin

Documentation

Index

• Constants
• Variables
• func Serve(opts *ServeOpts) error
• type GRPCFanOutPlugin
  • func (b *GRPCFanOutPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
  • func (b GRPCFanOutPlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error
• type ServeOpts

Constants

const PluginName = "fanOut"

Currently we only support one plugin type

Variables

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
}