producer

type GoogleConfig struct {
	ProjectID string
	TopicName string
	Target    string
	Rate      int
	Payload   []byte
}

type GoogleProducer struct {
	// contains filtered or unexported fields
}

type KafkaAuth struct {
	Type     string
	Hash     string
	TLS      bool
	Username string
	Password string
}

type KafkaConfig struct {
	Address []string
	Topic   string
	Rate    int
	Payload []byte
	Auth    *KafkaAuth
}

type KafkaProducer struct {
	// contains filtered or unexported fields
}

type Producer interface {
	Broadcast() error
}

type SqsConfig struct {
	AccessKeyID     string
	SecretAccessKey string
	Region          string
	QueueName       string
	Payload         []byte
	Rate            int
}

type SqsProducer struct {
	// contains filtered or unexported fields
}