type Factory struct {
// contains filtered or unexported fields
}
func NewSenderFactory(msgPersister persister.MessagePersister) *Factory
func (f *Factory) GetInstance(cfg *kafkaclient.Config, chirpConfig *config.Config) (MessageSender, error)
type MessageSender interface {
Send(map[string]model.Message) []model.Message
}
func NewKafkaSender(p kafkaclient.Producer, msgPersister persister.MessagePersister, chirpConfig *config.Config) MessageSender
func NewPubsubSender(msgPersister persister.MessagePersister, chirpConfig *config.Config) MessageSender