 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
This section is empty.
Variables ¶
      View Source
      
  
var DefaultBuiltinProcessors = map[string]ProcessorPluginConstructor{ "avro.decode": avro.NewDecodeProcessor, "avro.encode": avro.NewEncodeProcessor, "base64.decode": base64.NewDecodeProcessor, "base64.encode": base64.NewEncodeProcessor, "custom.javascript": custom.NewJavascriptProcessor, "filter": impl.NewFilterProcessor, "field.convert": field.NewConvertProcessor, "field.exclude": field.NewExcludeProcessor, "field.rename": field.NewRenameProcessor, "field.set": field.NewSetProcessor, "json.decode": json.NewDecodeProcessor, "json.encode": json.NewEncodeProcessor, "unwrap.debezium": unwrap.NewDebeziumProcessor, "unwrap.kafkaconnect": unwrap.NewKafkaConnectProcessor, "unwrap.opencdc": unwrap.NewOpenCDCProcessor, "webhook.http": webhook.NewHTTPProcessor, }
Functions ¶
This section is empty.
Types ¶
type ProcessorPluginConstructor ¶
func NewProcessorPluginConstructor ¶
func NewProcessorPluginConstructor(processorPlugin sdk.Processor) ProcessorPluginConstructor
type Registry ¶
type Registry struct {
	// contains filtered or unexported fields
}
    func NewRegistry ¶
func NewRegistry(logger log.CtxLogger, constructors map[string]ProcessorPluginConstructor) *Registry
       Directories
      ¶
      Directories
      ¶
    
    | Path | Synopsis | 
|---|---|
| 
          
            avro
            
            
          
           Package avro is a generated GoMock package. | Package avro is a generated GoMock package. | 
| 
          
            diff
            
            
          
           Package diff computes differences between text files or strings. | Package diff computes differences between text files or strings. | 
| 
          
            diff/difftest
            
            
          
           Package difftest supplies a set of tests that will operate on any implementation of a diff algorithm as exposed by "github.com/conduitio/conduit/pkg/plugin/processor/builtin/internal/diff" | Package difftest supplies a set of tests that will operate on any implementation of a diff algorithm as exposed by "github.com/conduitio/conduit/pkg/plugin/processor/builtin/internal/diff" | 
| 
          
            diff/lcs
            
            
          
           package lcs contains code to find longest-common-subsequences (and diffs) | package lcs contains code to find longest-common-subsequences (and diffs) | 
 Click to show internal directories. 
   Click to hide internal directories.