code: func newLogsStreamer(c *Context) (empire.LogsStreamer, error) {
  	switch c.String(FlagLogsStreamer) {
  	case "kinesis":
  		return newKinesisLogsStreamer(c)
  	default:
  		log.Println("Streaming logs are disabled")
  		return nil, nil
  	}
  }
docs: // LogStreamer =========================