input

type Input interface {
	Provide() chan dnszilla.DNSResult
}

type Kafka struct {
	Name       string
	Format     string   // example: jsonl, gob
	Endpoints  []string // example: localhost:9092
	Topic      string   // example: test
	Partition  int
	Offset     int64
	SSL        bool
	CAPath     string
	ClientCert string
	ClientKey  string
	Timeout    time.Duration
}

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