package
0.0.0-20241217144207-53ab948c626a
Repository: https://github.com/jorgeo3/flowcast.git
Documentation: pkg.go.dev

# Functions

NewConsumer creates a new Consumer instance with the provided brokers, topics, and configuration options.
NewProducer creates a new Producer instance.
WithConsumerConfig sets the configuration for the consumer.
WithConsumerCreateProcessUC sets the CreateProcess use case for the consumer.
WithConsumerDeleteProcessUC sets the DeleteProcess use case for the consumer.
WithConsumerLogger sets the logger for the consumer.
WithConsumerUpdateProcessUC sets the UpdateProcess use case for the consumer.
WithProducerConfig sets the configuration for the producer.
WithProducerLogger sets the logger for the producer.

# Structs

Consumer encapsulates the Redpanda consumer and related use cases.
Producer encapsulaes the redpanda consumer.

# Type aliases

ConsumerOpts is a function type used for configuring the Consumer instance.
ProducerOpts is used for configuring the Producer instance.