pluginctl

type DataStream struct {
	Data       []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	ParentSrc  string `protobuf:"bytes,2,opt,name=parentSrc,proto3" json:"parentSrc,omitempty"`
	Id         string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	IsComplete bool   `protobuf:"varint,4,opt,name=isComplete,proto3" json:"isComplete,omitempty"`
	TotalLen   int64  `protobuf:"varint,5,opt,name=totalLen,proto3" json:"totalLen,omitempty"`
	// contains filtered or unexported fields
}

type Empty struct {
	// contains filtered or unexported fields
}

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type GRPCClient struct {
	Name string
	// contains filtered or unexported fields
}

type GRPCServer struct {
	// This is the real implementation
	Impl SecPipelinePluginable
	Name string
}

type InputSchema struct {
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type Plugin struct {
	// contains filtered or unexported fields
}

type PluginOption = helper.Option[Plugin]

type RunInputConfig struct {
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type RunLoop struct {
	// contains filtered or unexported fields
}

type SecPipelineGRPCPlugin struct {
	// GRPCPlugin must still implement the Plugin interface
	plugin.NetRPCUnsupportedPlugin
	Impl SecPipelinePluginable
	Name string
}

type SecPipelinePluginable interface {
	GetInputSchema() ([]byte, error)
	Config(config []byte) error
	Run(ctx context.Context, input <-chan *DataStream) (<-chan *DataStream, <-chan error)
}

type SecPipelinePluginsClient interface {
	GetInputSchema(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*InputSchema, error)
	Config(ctx context.Context, in *RunInputConfig, opts ...grpc.CallOption) (*Empty, error)
	Run(ctx context.Context, opts ...grpc.CallOption) (SecPipelinePlugins_RunClient, error)
}

type SecPipelinePluginsServer interface {
	GetInputSchema(context.Context, *Empty) (*InputSchema, error)
	Config(context.Context, *RunInputConfig) (*Empty, error)
	Run(SecPipelinePlugins_RunServer) error
	// contains filtered or unexported methods
}

type SecPipelinePlugins_RunClient interface {
	Send(*DataStream) error
	Recv() (*DataStream, error)
	grpc.ClientStream
}

type SecPipelinePlugins_RunServer interface {
	Send(*DataStream) error
	Recv() (*DataStream, error)
	grpc.ServerStream
}

type UnimplementedSecPipelinePluginsServer struct {
}

type UnsafeSecPipelinePluginsServer interface {
	// contains filtered or unexported methods
}