sources

package

v1.4.2 Latest Latest Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 38 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SourceProcessor struct {
	ISBSvcType     dfv1.ISBSvcType
	VertexInstance *dfv1.VertexInstance
}

func (sp *SourceProcessor) Start(ctx context.Context) error

Path	Synopsis
errors
forward Package forward is used for creating a data forwarder for the source vertex.	Package forward is used for creating a data forwarder for the source vertex.
applier
generator Package generator contains an implementation of an in-memory generator that generates payloads in json format.	Package generator contains an implementation of an in-memory generator that generates payloads in json format.
http
jetstream
kafka
nats
sourcer
transformer
builtin
builtin/event_time
builtin/filter
builtin/time_extraction_filter
udsource Package udsource implements user-defined source, enabling the platform to communicate with user-defined data sources through gRPC.	Package udsource implements user-defined source, enabling the platform to communicate with user-defined data sources through gRPC.