Documentation ¶
Index ¶
- func MustNewEndpointBatchProcessor(e endpoint.Endpoint, d goduck.EndpointBatchDecoder) goduck.BatchProcessor
- func MustNewEndpointProcessor(e endpoint.Endpoint, d goduck.EndpointDecoder) goduck.Processor
- func NewEndpointBatchProcessor(e endpoint.Endpoint, d goduck.EndpointBatchDecoder) (goduck.BatchProcessor, error)
- func NewEndpointProcessor(e endpoint.Endpoint, d goduck.EndpointDecoder) (goduck.Processor, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MustNewEndpointBatchProcessor ¶
func MustNewEndpointBatchProcessor(e endpoint.Endpoint, d goduck.EndpointBatchDecoder) goduck.BatchProcessor
MustNewEndpointBatchProcessor calls NewEndpointProcessor and panics in case of error.
func MustNewEndpointProcessor ¶
MustNewEndpointProcessor calls NewEndpointProcessor and panics in case of error.
func NewEndpointBatchProcessor ¶
func NewEndpointBatchProcessor(e endpoint.Endpoint, d goduck.EndpointBatchDecoder) (goduck.BatchProcessor, error)
NewEndpointBatchProcessor returns a new goduck.Processor that
func NewEndpointProcessor ¶
NewEndpointProcessor returns a new goduck.Processor that
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.