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 ¶
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
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.