Versions in this module Expand all Collapse all v0 v0.0.1 Apr 23, 2024 Changes in this version + var DefaultHandshake = plugin.HandshakeConfig + var ErrJsonConvertion error = errors.New("failed to convert to/from json") + var ErrJsonSchemaConvertion error = errors.New("failed to convert to json format") + var File_pluginctl_plugins_proto protoreflect.FileDescriptor + var SecPipelinePlugins_ServiceDesc = grpc.ServiceDesc + func CleanupClients() + func RegisterSecPipelinePluginsServer(s grpc.ServiceRegistrar, srv SecPipelinePluginsServer) + type DataStream struct + Data []byte + Id string + IsComplete bool + ParentSrc string + TotalLen int64 + func (*DataStream) Descriptor() ([]byte, []int) + func (*DataStream) ProtoMessage() + func (x *DataStream) GetData() []byte + func (x *DataStream) GetId() string + func (x *DataStream) GetIsComplete() bool + func (x *DataStream) GetParentSrc() string + func (x *DataStream) GetTotalLen() int64 + func (x *DataStream) ProtoReflect() protoreflect.Message + func (x *DataStream) Reset() + func (x *DataStream) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type Error struct + Message string + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (x *Error) GetMessage() string + func (x *Error) ProtoReflect() protoreflect.Message + func (x *Error) Reset() + func (x *Error) String() string + type GRPCClient struct + Name string + func (m *GRPCClient) Config(config []byte) error + func (m *GRPCClient) GetInputSchema() ([]byte, error) + func (m *GRPCClient) Run(ctx context.Context, input <-chan *DataStream) (<-chan *DataStream, <-chan error) + type GRPCServer struct + Impl SecPipelinePluginable + Name string + func (m *GRPCServer) Config(ctx context.Context, config *RunInputConfig) (*Empty, error) + func (m *GRPCServer) GetInputSchema(context.Context, *Empty) (*InputSchema, error) + func (m *GRPCServer) Run(stream SecPipelinePlugins_RunServer) error + type InputSchema struct + Config []byte + func (*InputSchema) Descriptor() ([]byte, []int) + func (*InputSchema) ProtoMessage() + func (x *InputSchema) GetConfig() []byte + func (x *InputSchema) ProtoReflect() protoreflect.Message + func (x *InputSchema) Reset() + func (x *InputSchema) String() string + type Plugin struct + func NewPlugin(name string, opt ...PluginOption) *Plugin + func (p *Plugin) Cleanup() + func (p *Plugin) Connect() (SecPipelinePluginable, error) + func (p Plugin) Serve() + type PluginOption = helper.Option[Plugin] + func WithCmdConfig(cmd *exec.Cmd) PluginOption + func WithGRPCPlugin() PluginOption + func WithHandshakeConfig(handshakeConfig plugin.HandshakeConfig) PluginOption + func WithPath(path string) PluginOption + func WithPluginImplementation(plugin SecPipelinePluginable) PluginOption + func WithPluginProcessPath(path string) PluginOption + type RunInputConfig struct + Config []byte + func (*RunInputConfig) Descriptor() ([]byte, []int) + func (*RunInputConfig) ProtoMessage() + func (x *RunInputConfig) GetConfig() []byte + func (x *RunInputConfig) ProtoReflect() protoreflect.Message + func (x *RunInputConfig) Reset() + func (x *RunInputConfig) String() string + type RunLoop struct + func NewRunLoop() *RunLoop + func (rl *RunLoop) Recv(stream *DataStream) *DataStream + func (rl *RunLoop) Send(stream *DataStream) []*DataStream + type SecPipelineGRPCPlugin struct + Impl SecPipelinePluginable + Name string + func (p SecPipelineGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) + func (p SecPipelineGRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error + type SecPipelinePluginable interface + Config func(config []byte) error + GetInputSchema func() ([]byte, error) + Run func(ctx context.Context, input <-chan *DataStream) (<-chan *DataStream, <-chan error) + type SecPipelinePluginsClient interface + Config func(ctx context.Context, in *RunInputConfig, opts ...grpc.CallOption) (*Empty, error) + GetInputSchema func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*InputSchema, error) + Run func(ctx context.Context, opts ...grpc.CallOption) (SecPipelinePlugins_RunClient, error) + func NewSecPipelinePluginsClient(cc grpc.ClientConnInterface) SecPipelinePluginsClient + type SecPipelinePluginsServer interface + Config func(context.Context, *RunInputConfig) (*Empty, error) + GetInputSchema func(context.Context, *Empty) (*InputSchema, error) + Run func(SecPipelinePlugins_RunServer) error + type SecPipelinePlugins_RunClient interface + Recv func() (*DataStream, error) + Send func(*DataStream) error + type SecPipelinePlugins_RunServer interface + Recv func() (*DataStream, error) + Send func(*DataStream) error + type UnimplementedSecPipelinePluginsServer struct + func (UnimplementedSecPipelinePluginsServer) Config(context.Context, *RunInputConfig) (*Empty, error) + func (UnimplementedSecPipelinePluginsServer) GetInputSchema(context.Context, *Empty) (*InputSchema, error) + func (UnimplementedSecPipelinePluginsServer) Run(SecPipelinePlugins_RunServer) error + type UnsafeSecPipelinePluginsServer interface
Go to main page