com

Documentation

Index

• type FactoryInterface
• type ProducerInterface

Types

type FactoryInterface

type FactoryInterface interface {
	NewConsumer(ctx context.Context, config util.Config, respoinseListener func(msg string) error, errorListener func(msg string) error) (err error)
	NewProducer(ctx context.Context, config util.Config) (ProducerInterface, error)
}

type ProducerInterface

type ProducerInterface interface {
	Produce(topic string, message string) (err error)
	ProduceWithKey(topic string, key string, message string) (err error)
}